cosmos-sdk/x/ibc/04-channel/types/query.pb.go

4681 lines
119 KiB
Go
Raw Normal View History

// Code generated by protoc-gen-gogo. DO NOT EDIT.
// source: ibc/channel/query.proto
package types
import (
context "context"
fmt "fmt"
query "github.com/cosmos/cosmos-sdk/types/query"
_ "github.com/gogo/protobuf/gogoproto"
grpc1 "github.com/gogo/protobuf/grpc"
proto "github.com/gogo/protobuf/proto"
grpc "google.golang.org/grpc"
codes "google.golang.org/grpc/codes"
status "google.golang.org/grpc/status"
io "io"
math "math"
math_bits "math/bits"
)
// Reference imports to suppress errors if they are not otherwise used.
var _ = proto.Marshal
var _ = fmt.Errorf
var _ = math.Inf
// This is a compile-time assertion to ensure that this generated file
// is compatible with the proto package it is being compiled against.
// A compilation error at this line likely means your copy of the
// proto package needs to be updated.
const _ = proto.GoGoProtoPackageIsVersion3 // please upgrade the proto package
// QueryChannelRequest is the request type for the Query/Channel RPC method
type QueryChannelRequest struct {
// port unique identifier
PortID string `protobuf:"bytes,1,opt,name=port_id,json=portId,proto3" json:"port_id,omitempty"`
// channel unique identifier
ChannelID string `protobuf:"bytes,2,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"`
}
func (m *QueryChannelRequest) Reset() { *m = QueryChannelRequest{} }
func (m *QueryChannelRequest) String() string { return proto.CompactTextString(m) }
func (*QueryChannelRequest) ProtoMessage() {}
func (*QueryChannelRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_2150995751d4f15a, []int{0}
}
func (m *QueryChannelRequest) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *QueryChannelRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_QueryChannelRequest.Marshal(b, m, deterministic)
} else {
b = b[:cap(b)]
n, err := m.MarshalToSizedBuffer(b)
if err != nil {
return nil, err
}
return b[:n], nil
}
}
func (m *QueryChannelRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_QueryChannelRequest.Merge(m, src)
}
func (m *QueryChannelRequest) XXX_Size() int {
return m.Size()
}
func (m *QueryChannelRequest) XXX_DiscardUnknown() {
xxx_messageInfo_QueryChannelRequest.DiscardUnknown(m)
}
var xxx_messageInfo_QueryChannelRequest proto.InternalMessageInfo
func (m *QueryChannelRequest) GetPortID() string {
if m != nil {
return m.PortID
}
return ""
}
func (m *QueryChannelRequest) GetChannelID() string {
if m != nil {
return m.ChannelID
}
return ""
}
// QueryChannelResponse is the response type for the Query/Channel RPC method.
// Besides the Channel end, it includes a proof and the height from which the
// proof was retrieved.
type QueryChannelResponse struct {
// channel associated with the request identifiers
Channel *Channel `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
// merkle proof of existence
Proof []byte `protobuf:"bytes,2,opt,name=proof,proto3" json:"proof,omitempty"`
// merkle proof path
ProofPath string `protobuf:"bytes,3,opt,name=proof_path,json=proofPath,proto3" json:"proof_path,omitempty"`
// height at which the proof was retrieved
ProofHeight uint64 `protobuf:"varint,4,opt,name=proof_height,json=proofHeight,proto3" json:"proof_height,omitempty"`
}
func (m *QueryChannelResponse) Reset() { *m = QueryChannelResponse{} }
func (m *QueryChannelResponse) String() string { return proto.CompactTextString(m) }
func (*QueryChannelResponse) ProtoMessage() {}
func (*QueryChannelResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_2150995751d4f15a, []int{1}
}
func (m *QueryChannelResponse) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *QueryChannelResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_QueryChannelResponse.Marshal(b, m, deterministic)
} else {
b = b[:cap(b)]
n, err := m.MarshalToSizedBuffer(b)
if err != nil {
return nil, err
}
return b[:n], nil
}
}
func (m *QueryChannelResponse) XXX_Merge(src proto.Message) {
xxx_messageInfo_QueryChannelResponse.Merge(m, src)
}
func (m *QueryChannelResponse) XXX_Size() int {
return m.Size()
}
func (m *QueryChannelResponse) XXX_DiscardUnknown() {
xxx_messageInfo_QueryChannelResponse.DiscardUnknown(m)
}
var xxx_messageInfo_QueryChannelResponse proto.InternalMessageInfo
func (m *QueryChannelResponse) GetChannel() *Channel {
if m != nil {
return m.Channel
}
return nil
}
func (m *QueryChannelResponse) GetProof() []byte {
if m != nil {
return m.Proof
}
return nil
}
func (m *QueryChannelResponse) GetProofPath() string {
if m != nil {
return m.ProofPath
}
return ""
}
func (m *QueryChannelResponse) GetProofHeight() uint64 {
if m != nil {
return m.ProofHeight
}
return 0
}
// QueryChannelsRequest is the request type for the Query/Channels RPC method
type QueryChannelsRequest struct {
// pagination request
Req *query.PageRequest `protobuf:"bytes,1,opt,name=req,proto3" json:"req,omitempty"`
}
func (m *QueryChannelsRequest) Reset() { *m = QueryChannelsRequest{} }
func (m *QueryChannelsRequest) String() string { return proto.CompactTextString(m) }
func (*QueryChannelsRequest) ProtoMessage() {}
func (*QueryChannelsRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_2150995751d4f15a, []int{2}
}
func (m *QueryChannelsRequest) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *QueryChannelsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_QueryChannelsRequest.Marshal(b, m, deterministic)
} else {
b = b[:cap(b)]
n, err := m.MarshalToSizedBuffer(b)
if err != nil {
return nil, err
}
return b[:n], nil
}
}
func (m *QueryChannelsRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_QueryChannelsRequest.Merge(m, src)
}
func (m *QueryChannelsRequest) XXX_Size() int {
return m.Size()
}
func (m *QueryChannelsRequest) XXX_DiscardUnknown() {
xxx_messageInfo_QueryChannelsRequest.DiscardUnknown(m)
}
var xxx_messageInfo_QueryChannelsRequest proto.InternalMessageInfo
func (m *QueryChannelsRequest) GetReq() *query.PageRequest {
if m != nil {
return m.Req
}
return nil
}
// QueryChannelsResponse is the response type for the Query/Channels RPC method.
type QueryChannelsResponse struct {
// list of stored channels of the chain.
Channels []*IdentifiedChannel `protobuf:"bytes,1,rep,name=channels,proto3" json:"channels,omitempty"`
// pagination response
Res *query.PageResponse `protobuf:"bytes,2,opt,name=res,proto3" json:"res,omitempty"`
// query block height
Height int64 `protobuf:"varint,3,opt,name=height,proto3" json:"height,omitempty"`
}
func (m *QueryChannelsResponse) Reset() { *m = QueryChannelsResponse{} }
func (m *QueryChannelsResponse) String() string { return proto.CompactTextString(m) }
func (*QueryChannelsResponse) ProtoMessage() {}
func (*QueryChannelsResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_2150995751d4f15a, []int{3}
}
func (m *QueryChannelsResponse) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *QueryChannelsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_QueryChannelsResponse.Marshal(b, m, deterministic)
} else {
b = b[:cap(b)]
n, err := m.MarshalToSizedBuffer(b)
if err != nil {
return nil, err
}
return b[:n], nil
}
}
func (m *QueryChannelsResponse) XXX_Merge(src proto.Message) {
xxx_messageInfo_QueryChannelsResponse.Merge(m, src)
}
func (m *QueryChannelsResponse) XXX_Size() int {
return m.Size()
}
func (m *QueryChannelsResponse) XXX_DiscardUnknown() {
xxx_messageInfo_QueryChannelsResponse.DiscardUnknown(m)
}
var xxx_messageInfo_QueryChannelsResponse proto.InternalMessageInfo
func (m *QueryChannelsResponse) GetChannels() []*IdentifiedChannel {
if m != nil {
return m.Channels
}
return nil
}
func (m *QueryChannelsResponse) GetRes() *query.PageResponse {
if m != nil {
return m.Res
}
return nil
}
func (m *QueryChannelsResponse) GetHeight() int64 {
if m != nil {
return m.Height
}
return 0
}
// QueryConnectionChannelsRequest is the request type for the Query/QueryConnectionChannels RPC method
type QueryConnectionChannelsRequest struct {
// connection unique identifier
Connection string `protobuf:"bytes,1,opt,name=connection,proto3" json:"connection,omitempty"`
// pagination request
Req *query.PageRequest `protobuf:"bytes,2,opt,name=req,proto3" json:"req,omitempty"`
}
func (m *QueryConnectionChannelsRequest) Reset() { *m = QueryConnectionChannelsRequest{} }
func (m *QueryConnectionChannelsRequest) String() string { return proto.CompactTextString(m) }
func (*QueryConnectionChannelsRequest) ProtoMessage() {}
func (*QueryConnectionChannelsRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_2150995751d4f15a, []int{4}
}
func (m *QueryConnectionChannelsRequest) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *QueryConnectionChannelsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_QueryConnectionChannelsRequest.Marshal(b, m, deterministic)
} else {
b = b[:cap(b)]
n, err := m.MarshalToSizedBuffer(b)
if err != nil {
return nil, err
}
return b[:n], nil
}
}
func (m *QueryConnectionChannelsRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_QueryConnectionChannelsRequest.Merge(m, src)
}
func (m *QueryConnectionChannelsRequest) XXX_Size() int {
return m.Size()
}
func (m *QueryConnectionChannelsRequest) XXX_DiscardUnknown() {
xxx_messageInfo_QueryConnectionChannelsRequest.DiscardUnknown(m)
}
var xxx_messageInfo_QueryConnectionChannelsRequest proto.InternalMessageInfo
func (m *QueryConnectionChannelsRequest) GetConnection() string {
if m != nil {
return m.Connection
}
return ""
}
func (m *QueryConnectionChannelsRequest) GetReq() *query.PageRequest {
if m != nil {
return m.Req
}
return nil
}
// QueryConnectionChannelsResponse is the Response type for the Query/QueryConnectionChannels RPC method
type QueryConnectionChannelsResponse struct {
// list of channels associated with a connection.
Channels []*IdentifiedChannel `protobuf:"bytes,1,rep,name=channels,proto3" json:"channels,omitempty"`
// pagination response
Res *query.PageResponse `protobuf:"bytes,2,opt,name=res,proto3" json:"res,omitempty"`
// query block height
Height int64 `protobuf:"varint,3,opt,name=height,proto3" json:"height,omitempty"`
}
func (m *QueryConnectionChannelsResponse) Reset() { *m = QueryConnectionChannelsResponse{} }
func (m *QueryConnectionChannelsResponse) String() string { return proto.CompactTextString(m) }
func (*QueryConnectionChannelsResponse) ProtoMessage() {}
func (*QueryConnectionChannelsResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_2150995751d4f15a, []int{5}
}
func (m *QueryConnectionChannelsResponse) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *QueryConnectionChannelsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_QueryConnectionChannelsResponse.Marshal(b, m, deterministic)
} else {
b = b[:cap(b)]
n, err := m.MarshalToSizedBuffer(b)
if err != nil {
return nil, err
}
return b[:n], nil
}
}
func (m *QueryConnectionChannelsResponse) XXX_Merge(src proto.Message) {
xxx_messageInfo_QueryConnectionChannelsResponse.Merge(m, src)
}
func (m *QueryConnectionChannelsResponse) XXX_Size() int {
return m.Size()
}
func (m *QueryConnectionChannelsResponse) XXX_DiscardUnknown() {
xxx_messageInfo_QueryConnectionChannelsResponse.DiscardUnknown(m)
}
var xxx_messageInfo_QueryConnectionChannelsResponse proto.InternalMessageInfo
func (m *QueryConnectionChannelsResponse) GetChannels() []*IdentifiedChannel {
if m != nil {
return m.Channels
}
return nil
}
func (m *QueryConnectionChannelsResponse) GetRes() *query.PageResponse {
if m != nil {
return m.Res
}
return nil
}
func (m *QueryConnectionChannelsResponse) GetHeight() int64 {
if m != nil {
return m.Height
}
return 0
}
// QueryPacketCommitmentRequest is the request type for the Query/PacketCommitment RPC method
type QueryPacketCommitmentRequest struct {
// port unique identifier
PortID string `protobuf:"bytes,1,opt,name=port_id,json=portId,proto3" json:"port_id,omitempty"`
// channel unique identifier
ChannelID string `protobuf:"bytes,2,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"`
// packet sequence
Sequence uint64 `protobuf:"varint,3,opt,name=sequence,proto3" json:"sequence,omitempty"`
}
func (m *QueryPacketCommitmentRequest) Reset() { *m = QueryPacketCommitmentRequest{} }
func (m *QueryPacketCommitmentRequest) String() string { return proto.CompactTextString(m) }
func (*QueryPacketCommitmentRequest) ProtoMessage() {}
func (*QueryPacketCommitmentRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_2150995751d4f15a, []int{6}
}
func (m *QueryPacketCommitmentRequest) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *QueryPacketCommitmentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_QueryPacketCommitmentRequest.Marshal(b, m, deterministic)
} else {
b = b[:cap(b)]
n, err := m.MarshalToSizedBuffer(b)
if err != nil {
return nil, err
}
return b[:n], nil
}
}
func (m *QueryPacketCommitmentRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_QueryPacketCommitmentRequest.Merge(m, src)
}
func (m *QueryPacketCommitmentRequest) XXX_Size() int {
return m.Size()
}
func (m *QueryPacketCommitmentRequest) XXX_DiscardUnknown() {
xxx_messageInfo_QueryPacketCommitmentRequest.DiscardUnknown(m)
}
var xxx_messageInfo_QueryPacketCommitmentRequest proto.InternalMessageInfo
func (m *QueryPacketCommitmentRequest) GetPortID() string {
if m != nil {
return m.PortID
}
return ""
}
func (m *QueryPacketCommitmentRequest) GetChannelID() string {
if m != nil {
return m.ChannelID
}
return ""
}
func (m *QueryPacketCommitmentRequest) GetSequence() uint64 {
if m != nil {
return m.Sequence
}
return 0
}
// QueryPacketCommitmentResponse defines the client query response for a packet which also
// includes a proof, its path and the height form which the proof was retrieved
type QueryPacketCommitmentResponse struct {
// packet associated with the request fields
Commitment []byte `protobuf:"bytes,1,opt,name=commitment,proto3" json:"commitment,omitempty"`
// merkle proof of existence
Proof []byte `protobuf:"bytes,2,opt,name=proof,proto3" json:"proof,omitempty"`
// merkle proof path
ProofPath string `protobuf:"bytes,3,opt,name=proof_path,json=proofPath,proto3" json:"proof_path,omitempty"`
// height at which the proof was retrieved
ProofHeight uint64 `protobuf:"varint,4,opt,name=proof_height,json=proofHeight,proto3" json:"proof_height,omitempty"`
}
func (m *QueryPacketCommitmentResponse) Reset() { *m = QueryPacketCommitmentResponse{} }
func (m *QueryPacketCommitmentResponse) String() string { return proto.CompactTextString(m) }
func (*QueryPacketCommitmentResponse) ProtoMessage() {}
func (*QueryPacketCommitmentResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_2150995751d4f15a, []int{7}
}
func (m *QueryPacketCommitmentResponse) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *QueryPacketCommitmentResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_QueryPacketCommitmentResponse.Marshal(b, m, deterministic)
} else {
b = b[:cap(b)]
n, err := m.MarshalToSizedBuffer(b)
if err != nil {
return nil, err
}
return b[:n], nil
}
}
func (m *QueryPacketCommitmentResponse) XXX_Merge(src proto.Message) {
xxx_messageInfo_QueryPacketCommitmentResponse.Merge(m, src)
}
func (m *QueryPacketCommitmentResponse) XXX_Size() int {
return m.Size()
}
func (m *QueryPacketCommitmentResponse) XXX_DiscardUnknown() {
xxx_messageInfo_QueryPacketCommitmentResponse.DiscardUnknown(m)
}
var xxx_messageInfo_QueryPacketCommitmentResponse proto.InternalMessageInfo
func (m *QueryPacketCommitmentResponse) GetCommitment() []byte {
if m != nil {
return m.Commitment
}
return nil
}
func (m *QueryPacketCommitmentResponse) GetProof() []byte {
if m != nil {
return m.Proof
}
return nil
}
func (m *QueryPacketCommitmentResponse) GetProofPath() string {
if m != nil {
return m.ProofPath
}
return ""
}
func (m *QueryPacketCommitmentResponse) GetProofHeight() uint64 {
if m != nil {
return m.ProofHeight
}
return 0
}
// QueryPacketCommitmentsRequest is the request type for the Query/QueryPacketCommitments RPC method
type QueryPacketCommitmentsRequest struct {
// port unique identifier
PortID string `protobuf:"bytes,1,opt,name=port_id,json=portId,proto3" json:"port_id,omitempty"`
// channel unique identifier
ChannelID string `protobuf:"bytes,2,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"`
// pagination request
Req *query.PageRequest `protobuf:"bytes,3,opt,name=req,proto3" json:"req,omitempty"`
}
func (m *QueryPacketCommitmentsRequest) Reset() { *m = QueryPacketCommitmentsRequest{} }
func (m *QueryPacketCommitmentsRequest) String() string { return proto.CompactTextString(m) }
func (*QueryPacketCommitmentsRequest) ProtoMessage() {}
func (*QueryPacketCommitmentsRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_2150995751d4f15a, []int{8}
}
func (m *QueryPacketCommitmentsRequest) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *QueryPacketCommitmentsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_QueryPacketCommitmentsRequest.Marshal(b, m, deterministic)
} else {
b = b[:cap(b)]
n, err := m.MarshalToSizedBuffer(b)
if err != nil {
return nil, err
}
return b[:n], nil
}
}
func (m *QueryPacketCommitmentsRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_QueryPacketCommitmentsRequest.Merge(m, src)
}
func (m *QueryPacketCommitmentsRequest) XXX_Size() int {
return m.Size()
}
func (m *QueryPacketCommitmentsRequest) XXX_DiscardUnknown() {
xxx_messageInfo_QueryPacketCommitmentsRequest.DiscardUnknown(m)
}
var xxx_messageInfo_QueryPacketCommitmentsRequest proto.InternalMessageInfo
func (m *QueryPacketCommitmentsRequest) GetPortID() string {
if m != nil {
return m.PortID
}
return ""
}
func (m *QueryPacketCommitmentsRequest) GetChannelID() string {
if m != nil {
return m.ChannelID
}
return ""
}
func (m *QueryPacketCommitmentsRequest) GetReq() *query.PageRequest {
if m != nil {
return m.Req
}
return nil
}
// QueryPacketCommitmentsResponse is the request type for the Query/QueryPacketCommitments RPC method
type QueryPacketCommitmentsResponse struct {
Commitments []*PacketAckCommitment `protobuf:"bytes,1,rep,name=commitments,proto3" json:"commitments,omitempty"`
// pagination response
Res *query.PageResponse `protobuf:"bytes,2,opt,name=res,proto3" json:"res,omitempty"`
// query block height
Height int64 `protobuf:"varint,3,opt,name=height,proto3" json:"height,omitempty"`
}
func (m *QueryPacketCommitmentsResponse) Reset() { *m = QueryPacketCommitmentsResponse{} }
func (m *QueryPacketCommitmentsResponse) String() string { return proto.CompactTextString(m) }
func (*QueryPacketCommitmentsResponse) ProtoMessage() {}
func (*QueryPacketCommitmentsResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_2150995751d4f15a, []int{9}
}
func (m *QueryPacketCommitmentsResponse) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *QueryPacketCommitmentsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_QueryPacketCommitmentsResponse.Marshal(b, m, deterministic)
} else {
b = b[:cap(b)]
n, err := m.MarshalToSizedBuffer(b)
if err != nil {
return nil, err
}
return b[:n], nil
}
}
func (m *QueryPacketCommitmentsResponse) XXX_Merge(src proto.Message) {
xxx_messageInfo_QueryPacketCommitmentsResponse.Merge(m, src)
}
func (m *QueryPacketCommitmentsResponse) XXX_Size() int {
return m.Size()
}
func (m *QueryPacketCommitmentsResponse) XXX_DiscardUnknown() {
xxx_messageInfo_QueryPacketCommitmentsResponse.DiscardUnknown(m)
}
var xxx_messageInfo_QueryPacketCommitmentsResponse proto.InternalMessageInfo
func (m *QueryPacketCommitmentsResponse) GetCommitments() []*PacketAckCommitment {
if m != nil {
return m.Commitments
}
return nil
}
func (m *QueryPacketCommitmentsResponse) GetRes() *query.PageResponse {
if m != nil {
return m.Res
}
return nil
}
func (m *QueryPacketCommitmentsResponse) GetHeight() int64 {
if m != nil {
return m.Height
}
return 0
}
// QueryUnrelayedPacketsRequest is the request type for the Query/QueryConnectionChannels RPC method
type QueryUnrelayedPacketsRequest struct {
// port unique identifier
PortID string `protobuf:"bytes,1,opt,name=port_id,json=portId,proto3" json:"port_id,omitempty"`
// channel unique identifier
ChannelID string `protobuf:"bytes,2,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"`
// list of packet sequences
Sequences []uint64 `protobuf:"varint,3,rep,packed,name=sequences,proto3" json:"sequences,omitempty"`
// pagination request
Req *query.PageRequest `protobuf:"bytes,4,opt,name=req,proto3" json:"req,omitempty"`
}
func (m *QueryUnrelayedPacketsRequest) Reset() { *m = QueryUnrelayedPacketsRequest{} }
func (m *QueryUnrelayedPacketsRequest) String() string { return proto.CompactTextString(m) }
func (*QueryUnrelayedPacketsRequest) ProtoMessage() {}
func (*QueryUnrelayedPacketsRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_2150995751d4f15a, []int{10}
}
func (m *QueryUnrelayedPacketsRequest) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *QueryUnrelayedPacketsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_QueryUnrelayedPacketsRequest.Marshal(b, m, deterministic)
} else {
b = b[:cap(b)]
n, err := m.MarshalToSizedBuffer(b)
if err != nil {
return nil, err
}
return b[:n], nil
}
}
func (m *QueryUnrelayedPacketsRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_QueryUnrelayedPacketsRequest.Merge(m, src)
}
func (m *QueryUnrelayedPacketsRequest) XXX_Size() int {
return m.Size()
}
func (m *QueryUnrelayedPacketsRequest) XXX_DiscardUnknown() {
xxx_messageInfo_QueryUnrelayedPacketsRequest.DiscardUnknown(m)
}
var xxx_messageInfo_QueryUnrelayedPacketsRequest proto.InternalMessageInfo
func (m *QueryUnrelayedPacketsRequest) GetPortID() string {
if m != nil {
return m.PortID
}
return ""
}
func (m *QueryUnrelayedPacketsRequest) GetChannelID() string {
if m != nil {
return m.ChannelID
}
return ""
}
func (m *QueryUnrelayedPacketsRequest) GetSequences() []uint64 {
if m != nil {
return m.Sequences
}
return nil
}
func (m *QueryUnrelayedPacketsRequest) GetReq() *query.PageRequest {
if m != nil {
return m.Req
}
return nil
}
// QueryUnrelayedPacketsResponse is the request type for the Query/QueryConnectionChannels RPC method
type QueryUnrelayedPacketsResponse struct {
// list of unrelayed packets sequences
Packets []uint64 `protobuf:"varint,1,rep,packed,name=packets,proto3" json:"packets,omitempty"`
// pagination response
Res *query.PageResponse `protobuf:"bytes,2,opt,name=res,proto3" json:"res,omitempty"`
// query block height
Height int64 `protobuf:"varint,3,opt,name=height,proto3" json:"height,omitempty"`
}
func (m *QueryUnrelayedPacketsResponse) Reset() { *m = QueryUnrelayedPacketsResponse{} }
func (m *QueryUnrelayedPacketsResponse) String() string { return proto.CompactTextString(m) }
func (*QueryUnrelayedPacketsResponse) ProtoMessage() {}
func (*QueryUnrelayedPacketsResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_2150995751d4f15a, []int{11}
}
func (m *QueryUnrelayedPacketsResponse) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *QueryUnrelayedPacketsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_QueryUnrelayedPacketsResponse.Marshal(b, m, deterministic)
} else {
b = b[:cap(b)]
n, err := m.MarshalToSizedBuffer(b)
if err != nil {
return nil, err
}
return b[:n], nil
}
}
func (m *QueryUnrelayedPacketsResponse) XXX_Merge(src proto.Message) {
xxx_messageInfo_QueryUnrelayedPacketsResponse.Merge(m, src)
}
func (m *QueryUnrelayedPacketsResponse) XXX_Size() int {
return m.Size()
}
func (m *QueryUnrelayedPacketsResponse) XXX_DiscardUnknown() {
xxx_messageInfo_QueryUnrelayedPacketsResponse.DiscardUnknown(m)
}
var xxx_messageInfo_QueryUnrelayedPacketsResponse proto.InternalMessageInfo
func (m *QueryUnrelayedPacketsResponse) GetPackets() []uint64 {
if m != nil {
return m.Packets
}
return nil
}
func (m *QueryUnrelayedPacketsResponse) GetRes() *query.PageResponse {
if m != nil {
return m.Res
}
return nil
}
func (m *QueryUnrelayedPacketsResponse) GetHeight() int64 {
if m != nil {
return m.Height
}
return 0
}
// QueryNextSequenceReceiveRequest is the request type for the Query/QueryNextSequenceReceiveRequest RPC method
type QueryNextSequenceReceiveRequest struct {
// port unique identifier
PortID string `protobuf:"bytes,1,opt,name=port_id,json=portId,proto3" json:"port_id,omitempty"`
// channel unique identifier
ChannelID string `protobuf:"bytes,2,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"`
}
func (m *QueryNextSequenceReceiveRequest) Reset() { *m = QueryNextSequenceReceiveRequest{} }
func (m *QueryNextSequenceReceiveRequest) String() string { return proto.CompactTextString(m) }
func (*QueryNextSequenceReceiveRequest) ProtoMessage() {}
func (*QueryNextSequenceReceiveRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_2150995751d4f15a, []int{12}
}
func (m *QueryNextSequenceReceiveRequest) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *QueryNextSequenceReceiveRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_QueryNextSequenceReceiveRequest.Marshal(b, m, deterministic)
} else {
b = b[:cap(b)]
n, err := m.MarshalToSizedBuffer(b)
if err != nil {
return nil, err
}
return b[:n], nil
}
}
func (m *QueryNextSequenceReceiveRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_QueryNextSequenceReceiveRequest.Merge(m, src)
}
func (m *QueryNextSequenceReceiveRequest) XXX_Size() int {
return m.Size()
}
func (m *QueryNextSequenceReceiveRequest) XXX_DiscardUnknown() {
xxx_messageInfo_QueryNextSequenceReceiveRequest.DiscardUnknown(m)
}
var xxx_messageInfo_QueryNextSequenceReceiveRequest proto.InternalMessageInfo
func (m *QueryNextSequenceReceiveRequest) GetPortID() string {
if m != nil {
return m.PortID
}
return ""
}
func (m *QueryNextSequenceReceiveRequest) GetChannelID() string {
if m != nil {
return m.ChannelID
}
return ""
}
// QuerySequenceResponse is the request type for the Query/QueryNextSequenceReceiveResponse RPC method
type QueryNextSequenceReceiveResponse struct {
// next sequence receive number
NextSequenceReceive uint64 `protobuf:"varint,1,opt,name=next_sequence_receive,json=nextSequenceReceive,proto3" json:"next_sequence_receive,omitempty"`
// merkle proof of existence
Proof []byte `protobuf:"bytes,2,opt,name=proof,proto3" json:"proof,omitempty"`
// merkle proof path
ProofPath string `protobuf:"bytes,3,opt,name=proof_path,json=proofPath,proto3" json:"proof_path,omitempty"`
// height at which the proof was retrieved
ProofHeight uint64 `protobuf:"varint,4,opt,name=proof_height,json=proofHeight,proto3" json:"proof_height,omitempty"`
}
func (m *QueryNextSequenceReceiveResponse) Reset() { *m = QueryNextSequenceReceiveResponse{} }
func (m *QueryNextSequenceReceiveResponse) String() string { return proto.CompactTextString(m) }
func (*QueryNextSequenceReceiveResponse) ProtoMessage() {}
func (*QueryNextSequenceReceiveResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_2150995751d4f15a, []int{13}
}
func (m *QueryNextSequenceReceiveResponse) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *QueryNextSequenceReceiveResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_QueryNextSequenceReceiveResponse.Marshal(b, m, deterministic)
} else {
b = b[:cap(b)]
n, err := m.MarshalToSizedBuffer(b)
if err != nil {
return nil, err
}
return b[:n], nil
}
}
func (m *QueryNextSequenceReceiveResponse) XXX_Merge(src proto.Message) {
xxx_messageInfo_QueryNextSequenceReceiveResponse.Merge(m, src)
}
func (m *QueryNextSequenceReceiveResponse) XXX_Size() int {
return m.Size()
}
func (m *QueryNextSequenceReceiveResponse) XXX_DiscardUnknown() {
xxx_messageInfo_QueryNextSequenceReceiveResponse.DiscardUnknown(m)
}
var xxx_messageInfo_QueryNextSequenceReceiveResponse proto.InternalMessageInfo
func (m *QueryNextSequenceReceiveResponse) GetNextSequenceReceive() uint64 {
if m != nil {
return m.NextSequenceReceive
}
return 0
}
func (m *QueryNextSequenceReceiveResponse) GetProof() []byte {
if m != nil {
return m.Proof
}
return nil
}
func (m *QueryNextSequenceReceiveResponse) GetProofPath() string {
if m != nil {
return m.ProofPath
}
return ""
}
func (m *QueryNextSequenceReceiveResponse) GetProofHeight() uint64 {
if m != nil {
return m.ProofHeight
}
return 0
}
// QueryChannelClientStateRequest is the request type for the Query/ClientState RPC method
type QueryChannelClientStateRequest struct {
// port unique identifier
PortID string `protobuf:"bytes,1,opt,name=port_id,json=portId,proto3" json:"port_id,omitempty"`
// channel unique identifier
ChannelID string `protobuf:"bytes,2,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"`
}
func (m *QueryChannelClientStateRequest) Reset() { *m = QueryChannelClientStateRequest{} }
func (m *QueryChannelClientStateRequest) String() string { return proto.CompactTextString(m) }
func (*QueryChannelClientStateRequest) ProtoMessage() {}
func (*QueryChannelClientStateRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_2150995751d4f15a, []int{14}
}
func (m *QueryChannelClientStateRequest) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *QueryChannelClientStateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_QueryChannelClientStateRequest.Marshal(b, m, deterministic)
} else {
b = b[:cap(b)]
n, err := m.MarshalToSizedBuffer(b)
if err != nil {
return nil, err
}
return b[:n], nil
}
}
func (m *QueryChannelClientStateRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_QueryChannelClientStateRequest.Merge(m, src)
}
func (m *QueryChannelClientStateRequest) XXX_Size() int {
return m.Size()
}
func (m *QueryChannelClientStateRequest) XXX_DiscardUnknown() {
xxx_messageInfo_QueryChannelClientStateRequest.DiscardUnknown(m)
}
var xxx_messageInfo_QueryChannelClientStateRequest proto.InternalMessageInfo
func (m *QueryChannelClientStateRequest) GetPortID() string {
if m != nil {
return m.PortID
}
return ""
}
func (m *QueryChannelClientStateRequest) GetChannelID() string {
if m != nil {
return m.ChannelID
}
return ""
}
func init() {
proto.RegisterType((*QueryChannelRequest)(nil), "ibc.channel.QueryChannelRequest")
proto.RegisterType((*QueryChannelResponse)(nil), "ibc.channel.QueryChannelResponse")
proto.RegisterType((*QueryChannelsRequest)(nil), "ibc.channel.QueryChannelsRequest")
proto.RegisterType((*QueryChannelsResponse)(nil), "ibc.channel.QueryChannelsResponse")
proto.RegisterType((*QueryConnectionChannelsRequest)(nil), "ibc.channel.QueryConnectionChannelsRequest")
proto.RegisterType((*QueryConnectionChannelsResponse)(nil), "ibc.channel.QueryConnectionChannelsResponse")
proto.RegisterType((*QueryPacketCommitmentRequest)(nil), "ibc.channel.QueryPacketCommitmentRequest")
proto.RegisterType((*QueryPacketCommitmentResponse)(nil), "ibc.channel.QueryPacketCommitmentResponse")
proto.RegisterType((*QueryPacketCommitmentsRequest)(nil), "ibc.channel.QueryPacketCommitmentsRequest")
proto.RegisterType((*QueryPacketCommitmentsResponse)(nil), "ibc.channel.QueryPacketCommitmentsResponse")
proto.RegisterType((*QueryUnrelayedPacketsRequest)(nil), "ibc.channel.QueryUnrelayedPacketsRequest")
proto.RegisterType((*QueryUnrelayedPacketsResponse)(nil), "ibc.channel.QueryUnrelayedPacketsResponse")
proto.RegisterType((*QueryNextSequenceReceiveRequest)(nil), "ibc.channel.QueryNextSequenceReceiveRequest")
proto.RegisterType((*QueryNextSequenceReceiveResponse)(nil), "ibc.channel.QueryNextSequenceReceiveResponse")
proto.RegisterType((*QueryChannelClientStateRequest)(nil), "ibc.channel.QueryChannelClientStateRequest")
}
func init() { proto.RegisterFile("ibc/channel/query.proto", fileDescriptor_2150995751d4f15a) }
var fileDescriptor_2150995751d4f15a = []byte{
// 827 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xcc, 0x56, 0xbd, 0x72, 0xd3, 0x4a,
0x14, 0xb6, 0x62, 0xc7, 0x8e, 0x8f, 0x73, 0x67, 0xee, 0xdd, 0x38, 0x17, 0x47, 0x93, 0x28, 0x8e,
0x68, 0x0c, 0x49, 0x64, 0xc6, 0xa1, 0xa2, 0x23, 0x4e, 0x81, 0x0b, 0x18, 0xa3, 0x0c, 0x0d, 0x8d,
0x47, 0x96, 0x37, 0xb6, 0xc6, 0xb1, 0x24, 0x6b, 0x37, 0x4c, 0x52, 0xf1, 0x04, 0xcc, 0xd0, 0x31,
0x34, 0x50, 0xd0, 0x51, 0xf0, 0x04, 0x3c, 0x00, 0x65, 0x4a, 0xaa, 0x0c, 0x38, 0x2f, 0xc2, 0x68,
0x7f, 0x1c, 0xff, 0x48, 0x19, 0x15, 0xf1, 0x0c, 0x95, 0xb4, 0x67, 0xbf, 0x3d, 0xe7, 0x7c, 0xdf,
0x9e, 0x3d, 0xbb, 0x70, 0xcf, 0x69, 0xdb, 0x55, 0xbb, 0x67, 0xb9, 0x2e, 0x3e, 0xad, 0x0e, 0xcf,
0x70, 0x70, 0x61, 0xf8, 0x81, 0x47, 0x3d, 0x54, 0x70, 0xda, 0xb6, 0x21, 0x26, 0xd4, 0x62, 0xd7,
0xeb, 0x7a, 0xcc, 0x5e, 0x0d, 0xff, 0x38, 0x44, 0xdd, 0xb2, 0x3d, 0x32, 0xf0, 0x08, 0x5f, 0x56,
0xf5, 0xad, 0xae, 0xe3, 0x5a, 0xd4, 0xf1, 0x5c, 0x31, 0xbd, 0x31, 0xe9, 0x5a, 0x7c, 0xf9, 0x94,
0xde, 0x83, 0xb5, 0x97, 0xe1, 0xa2, 0x3a, 0xb7, 0x9a, 0x78, 0x78, 0x86, 0x09, 0x45, 0xf7, 0x21,
0xe7, 0x7b, 0x01, 0x6d, 0x39, 0x9d, 0x92, 0x52, 0x56, 0x2a, 0xf9, 0x43, 0x18, 0x5d, 0x6d, 0x67,
0x9b, 0x5e, 0x40, 0x1b, 0x47, 0x66, 0x36, 0x9c, 0x6a, 0x74, 0xd0, 0x1e, 0x80, 0x70, 0x16, 0xe2,
0x96, 0x18, 0xee, 0x9f, 0xd1, 0xd5, 0x76, 0x5e, 0x38, 0x6b, 0x1c, 0x99, 0x79, 0x01, 0x68, 0x74,
0xf4, 0x4f, 0x0a, 0x14, 0xa7, 0x43, 0x11, 0xdf, 0x73, 0x09, 0x46, 0x06, 0xe4, 0x04, 0x8a, 0xc5,
0x2a, 0xd4, 0x8a, 0xc6, 0x04, 0x63, 0x43, 0xc2, 0x25, 0x08, 0x15, 0x61, 0xd9, 0x0f, 0x3c, 0xef,
0x84, 0x45, 0x5c, 0x35, 0xf9, 0x00, 0x6d, 0x01, 0xb0, 0x9f, 0x96, 0x6f, 0xd1, 0x5e, 0x29, 0x1d,
0x26, 0x63, 0xe6, 0x99, 0xa5, 0x69, 0xd1, 0x1e, 0xda, 0x81, 0x55, 0x3e, 0xdd, 0xc3, 0x4e, 0xb7,
0x47, 0x4b, 0x99, 0xb2, 0x52, 0xc9, 0x98, 0x05, 0x66, 0x7b, 0xc6, 0x4c, 0x7a, 0x7d, 0x3a, 0x3f,
0x22, 0xb5, 0xd8, 0x85, 0x74, 0x80, 0x87, 0x22, 0xb7, 0x0d, 0x83, 0x4b, 0x6d, 0xf0, 0x1d, 0x6a,
0x5a, 0x5d, 0x2c, 0x70, 0x66, 0x88, 0xd2, 0x3f, 0x2a, 0xb0, 0x3e, 0xe3, 0x45, 0xd0, 0x7c, 0x02,
0x2b, 0x82, 0x01, 0x29, 0x29, 0xe5, 0x74, 0xa5, 0x50, 0xd3, 0xa6, 0x78, 0x36, 0x3a, 0xd8, 0xa5,
0xce, 0x89, 0x83, 0x3b, 0x92, 0xf1, 0x18, 0x8f, 0xf6, 0xc2, 0x14, 0x08, 0x23, 0x5c, 0xa8, 0xa9,
0x51, 0x29, 0xf0, 0x20, 0x61, 0x0e, 0x04, 0xfd, 0x0f, 0x59, 0xc1, 0x32, 0x94, 0x21, 0x6d, 0x8a,
0x91, 0x3e, 0x00, 0x8d, 0xa7, 0xe6, 0xb9, 0x2e, 0xb6, 0xc3, 0xfa, 0x98, 0xa5, 0xaa, 0x01, 0xd8,
0xe3, 0x49, 0xbe, 0xf3, 0xe6, 0x84, 0x45, 0x4a, 0xb1, 0x94, 0x48, 0x8a, 0x2f, 0x0a, 0x6c, 0xc7,
0xc6, 0xfb, 0x6b, 0x44, 0x79, 0xa7, 0xc0, 0x26, 0xcb, 0xb2, 0x69, 0xd9, 0x7d, 0x4c, 0xeb, 0xde,
0x60, 0xe0, 0xd0, 0x01, 0x76, 0xe9, 0xe2, 0x8e, 0x02, 0x52, 0x61, 0x85, 0x84, 0xde, 0x5d, 0x1b,
0xb3, 0x6c, 0x32, 0xe6, 0x78, 0xac, 0x7f, 0x50, 0x60, 0x2b, 0x26, 0x1f, 0xa1, 0x19, 0xdb, 0x24,
0x69, 0x65, 0x39, 0xad, 0x9a, 0x13, 0x96, 0x85, 0x9d, 0x8f, 0xcf, 0x71, 0x99, 0x91, 0x05, 0x4a,
0x25, 0x2a, 0x2e, 0x9d, 0xa8, 0xe2, 0xbe, 0x2a, 0xa2, 0xc2, 0x23, 0x32, 0x14, 0xe2, 0x1d, 0x42,
0xe1, 0x46, 0x2a, 0x59, 0x73, 0xe5, 0xa9, 0x9a, 0xe3, 0x8b, 0x9f, 0xda, 0xfd, 0x09, 0xed, 0x27,
0x17, 0xdd, 0x51, 0xe1, 0x7d, 0x97, 0x85, 0xf7, 0xca, 0x0d, 0xf0, 0xa9, 0x75, 0x81, 0x3b, 0x3c,
0xf0, 0x22, 0xd5, 0xdc, 0x84, 0xbc, 0x2c, 0x34, 0x52, 0x4a, 0x97, 0xd3, 0x95, 0x8c, 0x79, 0x63,
0x90, 0x5a, 0x67, 0x12, 0x69, 0xfd, 0x56, 0x14, 0xc3, 0x7c, 0xf6, 0x42, 0xe9, 0x12, 0xe4, 0x7c,
0x6e, 0x62, 0x2a, 0x67, 0x4c, 0x39, 0xbc, 0x23, 0xfd, 0xa8, 0xe8, 0x2e, 0x2f, 0xf0, 0x39, 0x3d,
0x16, 0x1c, 0x4c, 0x6c, 0x63, 0xe7, 0x0d, 0x5e, 0xe0, 0x2d, 0xf6, 0x4d, 0x81, 0x72, 0x7c, 0x58,
0x41, 0xbd, 0x06, 0xeb, 0x2e, 0x3e, 0xa7, 0x2d, 0x29, 0x6d, 0x2b, 0xe0, 0x00, 0x96, 0x45, 0xc6,
0x5c, 0x73, 0xe7, 0xd7, 0x2e, 0xec, 0xd4, 0x12, 0xd9, 0xf4, 0x39, 0x85, 0xfa, 0xa9, 0x83, 0x5d,
0x7a, 0x4c, 0x2d, 0xba, 0x40, 0x95, 0x6a, 0xbf, 0x97, 0x61, 0x99, 0x45, 0x45, 0x4d, 0xc8, 0x09,
0x04, 0x9a, 0x3e, 0x65, 0x11, 0xaf, 0x0e, 0x75, 0xe7, 0x16, 0x04, 0x97, 0x56, 0x4f, 0xa1, 0x63,
0x58, 0x91, 0xd7, 0x08, 0x8a, 0x5f, 0x20, 0x4f, 0x91, 0xaa, 0xdf, 0x06, 0x19, 0x3b, 0x1d, 0x02,
0x9a, 0xbf, 0xa5, 0xd0, 0x6e, 0xc4, 0xda, 0xb8, 0xbb, 0x53, 0xdd, 0x4b, 0x06, 0x1e, 0x87, 0xec,
0xc3, 0xbf, 0xb3, 0x6d, 0x0a, 0x3d, 0x98, 0xf7, 0x11, 0x73, 0x2d, 0xa9, 0x0f, 0x93, 0x40, 0xc7,
0xc1, 0x5c, 0xf8, 0x6f, 0xae, 0x27, 0xa2, 0x04, 0x2e, 0xc6, 0xec, 0x76, 0x13, 0x61, 0x27, 0xc9,
0xcd, 0x36, 0x86, 0x28, 0x72, 0x31, 0xad, 0x2f, 0x8a, 0x5c, 0x5c, 0x9f, 0xd1, 0x53, 0x88, 0xc2,
0x5a, 0xc4, 0x69, 0x44, 0x11, 0x1b, 0x12, 0xdf, 0x2b, 0xd4, 0xfd, 0x84, 0x68, 0x19, 0xf5, 0xf0,
0xf9, 0x8f, 0x91, 0xa6, 0x5c, 0x8e, 0x34, 0xe5, 0xd7, 0x48, 0x53, 0xde, 0x5f, 0x6b, 0xa9, 0xcb,
0x6b, 0x2d, 0xf5, 0xf3, 0x5a, 0x4b, 0xbd, 0x3e, 0xe8, 0x3a, 0xb4, 0x77, 0xd6, 0x36, 0x6c, 0x6f,
0x50, 0x15, 0x0f, 0x73, 0xfe, 0xd9, 0x27, 0x9d, 0x7e, 0xf5, 0xbc, 0x1a, 0xbe, 0xc6, 0x1f, 0x3d,
0xde, 0x97, 0x0f, 0x72, 0x7a, 0xe1, 0x63, 0xd2, 0xce, 0xb2, 0xf7, 0xf8, 0xc1, 0x9f, 0x00, 0x00,
0x00, 0xff, 0xff, 0xdf, 0x68, 0xc7, 0x94, 0x07, 0x0c, 0x00, 0x00,
}
// Reference imports to suppress errors if they are not otherwise used.
var _ context.Context
var _ grpc.ClientConn
// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
const _ = grpc.SupportPackageIsVersion4
// QueryClient is the client API for Query service.
//
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
type QueryClient interface {
// Channel queries an IBC Channel.
Channel(ctx context.Context, in *QueryChannelRequest, opts ...grpc.CallOption) (*QueryChannelResponse, error)
// Channels queries all the IBC channels of a chain.
Channels(ctx context.Context, in *QueryChannelsRequest, opts ...grpc.CallOption) (*QueryChannelsResponse, error)
// ConnectionChannels queries all the channels associated with a connection end.
ConnectionChannels(ctx context.Context, in *QueryConnectionChannelsRequest, opts ...grpc.CallOption) (*QueryConnectionChannelsResponse, error)
// PacketCommitment queries a stored packet commitment hash.
PacketCommitment(ctx context.Context, in *QueryPacketCommitmentRequest, opts ...grpc.CallOption) (*QueryPacketCommitmentResponse, error)
// PacketCommitments returns the all the packet commitments hashes associated with a channel.
PacketCommitments(ctx context.Context, in *QueryPacketCommitmentsRequest, opts ...grpc.CallOption) (*QueryPacketCommitmentsResponse, error)
// UnrelayedPackets returns all the unrelayed IBC packets associated with a channel and sequences.
UnrelayedPackets(ctx context.Context, in *QueryUnrelayedPacketsRequest, opts ...grpc.CallOption) (*QueryUnrelayedPacketsResponse, error)
// NextSequenceReceive returns the next receive sequence for a given channel
NextSequenceReceive(ctx context.Context, in *QueryNextSequenceReceiveRequest, opts ...grpc.CallOption) (*QueryNextSequenceReceiveResponse, error)
}
type queryClient struct {
cc grpc1.ClientConn
}
func NewQueryClient(cc grpc1.ClientConn) QueryClient {
return &queryClient{cc}
}
func (c *queryClient) Channel(ctx context.Context, in *QueryChannelRequest, opts ...grpc.CallOption) (*QueryChannelResponse, error) {
out := new(QueryChannelResponse)
err := c.cc.Invoke(ctx, "/ibc.channel.Query/Channel", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *queryClient) Channels(ctx context.Context, in *QueryChannelsRequest, opts ...grpc.CallOption) (*QueryChannelsResponse, error) {
out := new(QueryChannelsResponse)
err := c.cc.Invoke(ctx, "/ibc.channel.Query/Channels", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *queryClient) ConnectionChannels(ctx context.Context, in *QueryConnectionChannelsRequest, opts ...grpc.CallOption) (*QueryConnectionChannelsResponse, error) {
out := new(QueryConnectionChannelsResponse)
err := c.cc.Invoke(ctx, "/ibc.channel.Query/ConnectionChannels", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *queryClient) PacketCommitment(ctx context.Context, in *QueryPacketCommitmentRequest, opts ...grpc.CallOption) (*QueryPacketCommitmentResponse, error) {
out := new(QueryPacketCommitmentResponse)
err := c.cc.Invoke(ctx, "/ibc.channel.Query/PacketCommitment", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *queryClient) PacketCommitments(ctx context.Context, in *QueryPacketCommitmentsRequest, opts ...grpc.CallOption) (*QueryPacketCommitmentsResponse, error) {
out := new(QueryPacketCommitmentsResponse)
err := c.cc.Invoke(ctx, "/ibc.channel.Query/PacketCommitments", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *queryClient) UnrelayedPackets(ctx context.Context, in *QueryUnrelayedPacketsRequest, opts ...grpc.CallOption) (*QueryUnrelayedPacketsResponse, error) {
out := new(QueryUnrelayedPacketsResponse)
err := c.cc.Invoke(ctx, "/ibc.channel.Query/UnrelayedPackets", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *queryClient) NextSequenceReceive(ctx context.Context, in *QueryNextSequenceReceiveRequest, opts ...grpc.CallOption) (*QueryNextSequenceReceiveResponse, error) {
out := new(QueryNextSequenceReceiveResponse)
err := c.cc.Invoke(ctx, "/ibc.channel.Query/NextSequenceReceive", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
// QueryServer is the server API for Query service.
type QueryServer interface {
// Channel queries an IBC Channel.
Channel(context.Context, *QueryChannelRequest) (*QueryChannelResponse, error)
// Channels queries all the IBC channels of a chain.
Channels(context.Context, *QueryChannelsRequest) (*QueryChannelsResponse, error)
// ConnectionChannels queries all the channels associated with a connection end.
ConnectionChannels(context.Context, *QueryConnectionChannelsRequest) (*QueryConnectionChannelsResponse, error)
// PacketCommitment queries a stored packet commitment hash.
PacketCommitment(context.Context, *QueryPacketCommitmentRequest) (*QueryPacketCommitmentResponse, error)
// PacketCommitments returns the all the packet commitments hashes associated with a channel.
PacketCommitments(context.Context, *QueryPacketCommitmentsRequest) (*QueryPacketCommitmentsResponse, error)
// UnrelayedPackets returns all the unrelayed IBC packets associated with a channel and sequences.
UnrelayedPackets(context.Context, *QueryUnrelayedPacketsRequest) (*QueryUnrelayedPacketsResponse, error)
// NextSequenceReceive returns the next receive sequence for a given channel
NextSequenceReceive(context.Context, *QueryNextSequenceReceiveRequest) (*QueryNextSequenceReceiveResponse, error)
}
// UnimplementedQueryServer can be embedded to have forward compatible implementations.
type UnimplementedQueryServer struct {
}
func (*UnimplementedQueryServer) Channel(ctx context.Context, req *QueryChannelRequest) (*QueryChannelResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method Channel not implemented")
}
func (*UnimplementedQueryServer) Channels(ctx context.Context, req *QueryChannelsRequest) (*QueryChannelsResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method Channels not implemented")
}
func (*UnimplementedQueryServer) ConnectionChannels(ctx context.Context, req *QueryConnectionChannelsRequest) (*QueryConnectionChannelsResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method ConnectionChannels not implemented")
}
func (*UnimplementedQueryServer) PacketCommitment(ctx context.Context, req *QueryPacketCommitmentRequest) (*QueryPacketCommitmentResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method PacketCommitment not implemented")
}
func (*UnimplementedQueryServer) PacketCommitments(ctx context.Context, req *QueryPacketCommitmentsRequest) (*QueryPacketCommitmentsResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method PacketCommitments not implemented")
}
func (*UnimplementedQueryServer) UnrelayedPackets(ctx context.Context, req *QueryUnrelayedPacketsRequest) (*QueryUnrelayedPacketsResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method UnrelayedPackets not implemented")
}
func (*UnimplementedQueryServer) NextSequenceReceive(ctx context.Context, req *QueryNextSequenceReceiveRequest) (*QueryNextSequenceReceiveResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method NextSequenceReceive not implemented")
}
func RegisterQueryServer(s grpc1.Server, srv QueryServer) {
s.RegisterService(&_Query_serviceDesc, srv)
}
func _Query_Channel_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(QueryChannelRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(QueryServer).Channel(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/ibc.channel.Query/Channel",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(QueryServer).Channel(ctx, req.(*QueryChannelRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Query_Channels_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(QueryChannelsRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(QueryServer).Channels(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/ibc.channel.Query/Channels",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(QueryServer).Channels(ctx, req.(*QueryChannelsRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Query_ConnectionChannels_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(QueryConnectionChannelsRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(QueryServer).ConnectionChannels(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/ibc.channel.Query/ConnectionChannels",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(QueryServer).ConnectionChannels(ctx, req.(*QueryConnectionChannelsRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Query_PacketCommitment_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(QueryPacketCommitmentRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(QueryServer).PacketCommitment(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/ibc.channel.Query/PacketCommitment",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(QueryServer).PacketCommitment(ctx, req.(*QueryPacketCommitmentRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Query_PacketCommitments_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(QueryPacketCommitmentsRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(QueryServer).PacketCommitments(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/ibc.channel.Query/PacketCommitments",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(QueryServer).PacketCommitments(ctx, req.(*QueryPacketCommitmentsRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Query_UnrelayedPackets_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(QueryUnrelayedPacketsRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(QueryServer).UnrelayedPackets(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/ibc.channel.Query/UnrelayedPackets",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(QueryServer).UnrelayedPackets(ctx, req.(*QueryUnrelayedPacketsRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Query_NextSequenceReceive_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(QueryNextSequenceReceiveRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(QueryServer).NextSequenceReceive(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/ibc.channel.Query/NextSequenceReceive",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(QueryServer).NextSequenceReceive(ctx, req.(*QueryNextSequenceReceiveRequest))
}
return interceptor(ctx, in, info, handler)
}
var _Query_serviceDesc = grpc.ServiceDesc{
ServiceName: "ibc.channel.Query",
HandlerType: (*QueryServer)(nil),
Methods: []grpc.MethodDesc{
{
MethodName: "Channel",
Handler: _Query_Channel_Handler,
},
{
MethodName: "Channels",
Handler: _Query_Channels_Handler,
},
{
MethodName: "ConnectionChannels",
Handler: _Query_ConnectionChannels_Handler,
},
{
MethodName: "PacketCommitment",
Handler: _Query_PacketCommitment_Handler,
},
{
MethodName: "PacketCommitments",
Handler: _Query_PacketCommitments_Handler,
},
{
MethodName: "UnrelayedPackets",
Handler: _Query_UnrelayedPackets_Handler,
},
{
MethodName: "NextSequenceReceive",
Handler: _Query_NextSequenceReceive_Handler,
},
},
Streams: []grpc.StreamDesc{},
Metadata: "ibc/channel/query.proto",
}
func (m *QueryChannelRequest) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalToSizedBuffer(dAtA[:size])
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *QueryChannelRequest) MarshalTo(dAtA []byte) (int, error) {
size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *QueryChannelRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i
var l int
_ = l
if len(m.ChannelID) > 0 {
i -= len(m.ChannelID)
copy(dAtA[i:], m.ChannelID)
i = encodeVarintQuery(dAtA, i, uint64(len(m.ChannelID)))
i--
dAtA[i] = 0x12
}
if len(m.PortID) > 0 {
i -= len(m.PortID)
copy(dAtA[i:], m.PortID)
i = encodeVarintQuery(dAtA, i, uint64(len(m.PortID)))
i--
dAtA[i] = 0xa
}
return len(dAtA) - i, nil
}
func (m *QueryChannelResponse) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalToSizedBuffer(dAtA[:size])
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *QueryChannelResponse) MarshalTo(dAtA []byte) (int, error) {
size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *QueryChannelResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i
var l int
_ = l
if m.ProofHeight != 0 {
i = encodeVarintQuery(dAtA, i, uint64(m.ProofHeight))
i--
dAtA[i] = 0x20
}
if len(m.ProofPath) > 0 {
i -= len(m.ProofPath)
copy(dAtA[i:], m.ProofPath)
i = encodeVarintQuery(dAtA, i, uint64(len(m.ProofPath)))
i--
dAtA[i] = 0x1a
}
if len(m.Proof) > 0 {
i -= len(m.Proof)
copy(dAtA[i:], m.Proof)
i = encodeVarintQuery(dAtA, i, uint64(len(m.Proof)))
i--
dAtA[i] = 0x12
}
if m.Channel != nil {
{
size, err := m.Channel.MarshalToSizedBuffer(dAtA[:i])
if err != nil {
return 0, err
}
i -= size
i = encodeVarintQuery(dAtA, i, uint64(size))
}
i--
dAtA[i] = 0xa
}
return len(dAtA) - i, nil
}
func (m *QueryChannelsRequest) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalToSizedBuffer(dAtA[:size])
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *QueryChannelsRequest) MarshalTo(dAtA []byte) (int, error) {
size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *QueryChannelsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i
var l int
_ = l
if m.Req != nil {
{
size, err := m.Req.MarshalToSizedBuffer(dAtA[:i])
if err != nil {
return 0, err
}
i -= size
i = encodeVarintQuery(dAtA, i, uint64(size))
}
i--
dAtA[i] = 0xa
}
return len(dAtA) - i, nil
}
func (m *QueryChannelsResponse) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalToSizedBuffer(dAtA[:size])
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *QueryChannelsResponse) MarshalTo(dAtA []byte) (int, error) {
size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *QueryChannelsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i
var l int
_ = l
if m.Height != 0 {
i = encodeVarintQuery(dAtA, i, uint64(m.Height))
i--
dAtA[i] = 0x18
}
if m.Res != nil {
{
size, err := m.Res.MarshalToSizedBuffer(dAtA[:i])
if err != nil {
return 0, err
}
i -= size
i = encodeVarintQuery(dAtA, i, uint64(size))
}
i--
dAtA[i] = 0x12
}
if len(m.Channels) > 0 {
for iNdEx := len(m.Channels) - 1; iNdEx >= 0; iNdEx-- {
{
size, err := m.Channels[iNdEx].MarshalToSizedBuffer(dAtA[:i])
if err != nil {
return 0, err
}
i -= size
i = encodeVarintQuery(dAtA, i, uint64(size))
}
i--
dAtA[i] = 0xa
}
}
return len(dAtA) - i, nil
}
func (m *QueryConnectionChannelsRequest) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalToSizedBuffer(dAtA[:size])
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *QueryConnectionChannelsRequest) MarshalTo(dAtA []byte) (int, error) {
size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *QueryConnectionChannelsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i
var l int
_ = l
if m.Req != nil {
{
size, err := m.Req.MarshalToSizedBuffer(dAtA[:i])
if err != nil {
return 0, err
}
i -= size
i = encodeVarintQuery(dAtA, i, uint64(size))
}
i--
dAtA[i] = 0x12
}
if len(m.Connection) > 0 {
i -= len(m.Connection)
copy(dAtA[i:], m.Connection)
i = encodeVarintQuery(dAtA, i, uint64(len(m.Connection)))
i--
dAtA[i] = 0xa
}
return len(dAtA) - i, nil
}
func (m *QueryConnectionChannelsResponse) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalToSizedBuffer(dAtA[:size])
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *QueryConnectionChannelsResponse) MarshalTo(dAtA []byte) (int, error) {
size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *QueryConnectionChannelsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i
var l int
_ = l
if m.Height != 0 {
i = encodeVarintQuery(dAtA, i, uint64(m.Height))
i--
dAtA[i] = 0x18
}
if m.Res != nil {
{
size, err := m.Res.MarshalToSizedBuffer(dAtA[:i])
if err != nil {
return 0, err
}
i -= size
i = encodeVarintQuery(dAtA, i, uint64(size))
}
i--
dAtA[i] = 0x12
}
if len(m.Channels) > 0 {
for iNdEx := len(m.Channels) - 1; iNdEx >= 0; iNdEx-- {
{
size, err := m.Channels[iNdEx].MarshalToSizedBuffer(dAtA[:i])
if err != nil {
return 0, err
}
i -= size
i = encodeVarintQuery(dAtA, i, uint64(size))
}
i--
dAtA[i] = 0xa
}
}
return len(dAtA) - i, nil
}
func (m *QueryPacketCommitmentRequest) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalToSizedBuffer(dAtA[:size])
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *QueryPacketCommitmentRequest) MarshalTo(dAtA []byte) (int, error) {
size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *QueryPacketCommitmentRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i
var l int
_ = l
if m.Sequence != 0 {
i = encodeVarintQuery(dAtA, i, uint64(m.Sequence))
i--
dAtA[i] = 0x18
}
if len(m.ChannelID) > 0 {
i -= len(m.ChannelID)
copy(dAtA[i:], m.ChannelID)
i = encodeVarintQuery(dAtA, i, uint64(len(m.ChannelID)))
i--
dAtA[i] = 0x12
}
if len(m.PortID) > 0 {
i -= len(m.PortID)
copy(dAtA[i:], m.PortID)
i = encodeVarintQuery(dAtA, i, uint64(len(m.PortID)))
i--
dAtA[i] = 0xa
}
return len(dAtA) - i, nil
}
func (m *QueryPacketCommitmentResponse) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalToSizedBuffer(dAtA[:size])
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *QueryPacketCommitmentResponse) MarshalTo(dAtA []byte) (int, error) {
size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *QueryPacketCommitmentResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i
var l int
_ = l
if m.ProofHeight != 0 {
i = encodeVarintQuery(dAtA, i, uint64(m.ProofHeight))
i--
dAtA[i] = 0x20
}
if len(m.ProofPath) > 0 {
i -= len(m.ProofPath)
copy(dAtA[i:], m.ProofPath)
i = encodeVarintQuery(dAtA, i, uint64(len(m.ProofPath)))
i--
dAtA[i] = 0x1a
}
if len(m.Proof) > 0 {
i -= len(m.Proof)
copy(dAtA[i:], m.Proof)
i = encodeVarintQuery(dAtA, i, uint64(len(m.Proof)))
i--
dAtA[i] = 0x12
}
if len(m.Commitment) > 0 {
i -= len(m.Commitment)
copy(dAtA[i:], m.Commitment)
i = encodeVarintQuery(dAtA, i, uint64(len(m.Commitment)))
i--
dAtA[i] = 0xa
}
return len(dAtA) - i, nil
}
func (m *QueryPacketCommitmentsRequest) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalToSizedBuffer(dAtA[:size])
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *QueryPacketCommitmentsRequest) MarshalTo(dAtA []byte) (int, error) {
size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *QueryPacketCommitmentsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i
var l int
_ = l
if m.Req != nil {
{
size, err := m.Req.MarshalToSizedBuffer(dAtA[:i])
if err != nil {
return 0, err
}
i -= size
i = encodeVarintQuery(dAtA, i, uint64(size))
}
i--
dAtA[i] = 0x1a
}
if len(m.ChannelID) > 0 {
i -= len(m.ChannelID)
copy(dAtA[i:], m.ChannelID)
i = encodeVarintQuery(dAtA, i, uint64(len(m.ChannelID)))
i--
dAtA[i] = 0x12
}
if len(m.PortID) > 0 {
i -= len(m.PortID)
copy(dAtA[i:], m.PortID)
i = encodeVarintQuery(dAtA, i, uint64(len(m.PortID)))
i--
dAtA[i] = 0xa
}
return len(dAtA) - i, nil
}
func (m *QueryPacketCommitmentsResponse) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalToSizedBuffer(dAtA[:size])
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *QueryPacketCommitmentsResponse) MarshalTo(dAtA []byte) (int, error) {
size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *QueryPacketCommitmentsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i
var l int
_ = l
if m.Height != 0 {
i = encodeVarintQuery(dAtA, i, uint64(m.Height))
i--
dAtA[i] = 0x18
}
if m.Res != nil {
{
size, err := m.Res.MarshalToSizedBuffer(dAtA[:i])
if err != nil {
return 0, err
}
i -= size
i = encodeVarintQuery(dAtA, i, uint64(size))
}
i--
dAtA[i] = 0x12
}
if len(m.Commitments) > 0 {
for iNdEx := len(m.Commitments) - 1; iNdEx >= 0; iNdEx-- {
{
size, err := m.Commitments[iNdEx].MarshalToSizedBuffer(dAtA[:i])
if err != nil {
return 0, err
}
i -= size
i = encodeVarintQuery(dAtA, i, uint64(size))
}
i--
dAtA[i] = 0xa
}
}
return len(dAtA) - i, nil
}
func (m *QueryUnrelayedPacketsRequest) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalToSizedBuffer(dAtA[:size])
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *QueryUnrelayedPacketsRequest) MarshalTo(dAtA []byte) (int, error) {
size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *QueryUnrelayedPacketsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i
var l int
_ = l
if m.Req != nil {
{
size, err := m.Req.MarshalToSizedBuffer(dAtA[:i])
if err != nil {
return 0, err
}
i -= size
i = encodeVarintQuery(dAtA, i, uint64(size))
}
i--
dAtA[i] = 0x22
}
if len(m.Sequences) > 0 {
dAtA10 := make([]byte, len(m.Sequences)*10)
var j9 int
for _, num := range m.Sequences {
for num >= 1<<7 {
dAtA10[j9] = uint8(uint64(num)&0x7f | 0x80)
num >>= 7
j9++
}
dAtA10[j9] = uint8(num)
j9++
}
i -= j9
copy(dAtA[i:], dAtA10[:j9])
i = encodeVarintQuery(dAtA, i, uint64(j9))
i--
dAtA[i] = 0x1a
}
if len(m.ChannelID) > 0 {
i -= len(m.ChannelID)
copy(dAtA[i:], m.ChannelID)
i = encodeVarintQuery(dAtA, i, uint64(len(m.ChannelID)))
i--
dAtA[i] = 0x12
}
if len(m.PortID) > 0 {
i -= len(m.PortID)
copy(dAtA[i:], m.PortID)
i = encodeVarintQuery(dAtA, i, uint64(len(m.PortID)))
i--
dAtA[i] = 0xa
}
return len(dAtA) - i, nil
}
func (m *QueryUnrelayedPacketsResponse) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalToSizedBuffer(dAtA[:size])
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *QueryUnrelayedPacketsResponse) MarshalTo(dAtA []byte) (int, error) {
size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *QueryUnrelayedPacketsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i
var l int
_ = l
if m.Height != 0 {
i = encodeVarintQuery(dAtA, i, uint64(m.Height))
i--
dAtA[i] = 0x18
}
if m.Res != nil {
{
size, err := m.Res.MarshalToSizedBuffer(dAtA[:i])
if err != nil {
return 0, err
}
i -= size
i = encodeVarintQuery(dAtA, i, uint64(size))
}
i--
dAtA[i] = 0x12
}
if len(m.Packets) > 0 {
dAtA13 := make([]byte, len(m.Packets)*10)
var j12 int
for _, num := range m.Packets {
for num >= 1<<7 {
dAtA13[j12] = uint8(uint64(num)&0x7f | 0x80)
num >>= 7
j12++
}
dAtA13[j12] = uint8(num)
j12++
}
i -= j12
copy(dAtA[i:], dAtA13[:j12])
i = encodeVarintQuery(dAtA, i, uint64(j12))
i--
dAtA[i] = 0xa
}
return len(dAtA) - i, nil
}
func (m *QueryNextSequenceReceiveRequest) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalToSizedBuffer(dAtA[:size])
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *QueryNextSequenceReceiveRequest) MarshalTo(dAtA []byte) (int, error) {
size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *QueryNextSequenceReceiveRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i
var l int
_ = l
if len(m.ChannelID) > 0 {
i -= len(m.ChannelID)
copy(dAtA[i:], m.ChannelID)
i = encodeVarintQuery(dAtA, i, uint64(len(m.ChannelID)))
i--
dAtA[i] = 0x12
}
if len(m.PortID) > 0 {
i -= len(m.PortID)
copy(dAtA[i:], m.PortID)
i = encodeVarintQuery(dAtA, i, uint64(len(m.PortID)))
i--
dAtA[i] = 0xa
}
return len(dAtA) - i, nil
}
func (m *QueryNextSequenceReceiveResponse) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalToSizedBuffer(dAtA[:size])
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *QueryNextSequenceReceiveResponse) MarshalTo(dAtA []byte) (int, error) {
size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *QueryNextSequenceReceiveResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i
var l int
_ = l
if m.ProofHeight != 0 {
i = encodeVarintQuery(dAtA, i, uint64(m.ProofHeight))
i--
dAtA[i] = 0x20
}
if len(m.ProofPath) > 0 {
i -= len(m.ProofPath)
copy(dAtA[i:], m.ProofPath)
i = encodeVarintQuery(dAtA, i, uint64(len(m.ProofPath)))
i--
dAtA[i] = 0x1a
}
if len(m.Proof) > 0 {
i -= len(m.Proof)
copy(dAtA[i:], m.Proof)
i = encodeVarintQuery(dAtA, i, uint64(len(m.Proof)))
i--
dAtA[i] = 0x12
}
if m.NextSequenceReceive != 0 {
i = encodeVarintQuery(dAtA, i, uint64(m.NextSequenceReceive))
i--
dAtA[i] = 0x8
}
return len(dAtA) - i, nil
}
func (m *QueryChannelClientStateRequest) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalToSizedBuffer(dAtA[:size])
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *QueryChannelClientStateRequest) MarshalTo(dAtA []byte) (int, error) {
size := m.Size()
return m.MarshalToSizedBuffer(dAtA[:size])
}
func (m *QueryChannelClientStateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) {
i := len(dAtA)
_ = i
var l int
_ = l
if len(m.ChannelID) > 0 {
i -= len(m.ChannelID)
copy(dAtA[i:], m.ChannelID)
i = encodeVarintQuery(dAtA, i, uint64(len(m.ChannelID)))
i--
dAtA[i] = 0x12
}
if len(m.PortID) > 0 {
i -= len(m.PortID)
copy(dAtA[i:], m.PortID)
i = encodeVarintQuery(dAtA, i, uint64(len(m.PortID)))
i--
dAtA[i] = 0xa
}
return len(dAtA) - i, nil
}
func encodeVarintQuery(dAtA []byte, offset int, v uint64) int {
offset -= sovQuery(v)
base := offset
for v >= 1<<7 {
dAtA[offset] = uint8(v&0x7f | 0x80)
v >>= 7
offset++
}
dAtA[offset] = uint8(v)
return base
}
func (m *QueryChannelRequest) Size() (n int) {
if m == nil {
return 0
}
var l int
_ = l
l = len(m.PortID)
if l > 0 {
n += 1 + l + sovQuery(uint64(l))
}
l = len(m.ChannelID)
if l > 0 {
n += 1 + l + sovQuery(uint64(l))
}
return n
}
func (m *QueryChannelResponse) Size() (n int) {
if m == nil {
return 0
}
var l int
_ = l
if m.Channel != nil {
l = m.Channel.Size()
n += 1 + l + sovQuery(uint64(l))
}
l = len(m.Proof)
if l > 0 {
n += 1 + l + sovQuery(uint64(l))
}
l = len(m.ProofPath)
if l > 0 {
n += 1 + l + sovQuery(uint64(l))
}
if m.ProofHeight != 0 {
n += 1 + sovQuery(uint64(m.ProofHeight))
}
return n
}
func (m *QueryChannelsRequest) Size() (n int) {
if m == nil {
return 0
}
var l int
_ = l
if m.Req != nil {
l = m.Req.Size()
n += 1 + l + sovQuery(uint64(l))
}
return n
}
func (m *QueryChannelsResponse) Size() (n int) {
if m == nil {
return 0
}
var l int
_ = l
if len(m.Channels) > 0 {
for _, e := range m.Channels {
l = e.Size()
n += 1 + l + sovQuery(uint64(l))
}
}
if m.Res != nil {
l = m.Res.Size()
n += 1 + l + sovQuery(uint64(l))
}
if m.Height != 0 {
n += 1 + sovQuery(uint64(m.Height))
}
return n
}
func (m *QueryConnectionChannelsRequest) Size() (n int) {
if m == nil {
return 0
}
var l int
_ = l
l = len(m.Connection)
if l > 0 {
n += 1 + l + sovQuery(uint64(l))
}
if m.Req != nil {
l = m.Req.Size()
n += 1 + l + sovQuery(uint64(l))
}
return n
}
func (m *QueryConnectionChannelsResponse) Size() (n int) {
if m == nil {
return 0
}
var l int
_ = l
if len(m.Channels) > 0 {
for _, e := range m.Channels {
l = e.Size()
n += 1 + l + sovQuery(uint64(l))
}
}
if m.Res != nil {
l = m.Res.Size()
n += 1 + l + sovQuery(uint64(l))
}
if m.Height != 0 {
n += 1 + sovQuery(uint64(m.Height))
}
return n
}
func (m *QueryPacketCommitmentRequest) Size() (n int) {
if m == nil {
return 0
}
var l int
_ = l
l = len(m.PortID)
if l > 0 {
n += 1 + l + sovQuery(uint64(l))
}
l = len(m.ChannelID)
if l > 0 {
n += 1 + l + sovQuery(uint64(l))
}
if m.Sequence != 0 {
n += 1 + sovQuery(uint64(m.Sequence))
}
return n
}
func (m *QueryPacketCommitmentResponse) Size() (n int) {
if m == nil {
return 0
}
var l int
_ = l
l = len(m.Commitment)
if l > 0 {
n += 1 + l + sovQuery(uint64(l))
}
l = len(m.Proof)
if l > 0 {
n += 1 + l + sovQuery(uint64(l))
}
l = len(m.ProofPath)
if l > 0 {
n += 1 + l + sovQuery(uint64(l))
}
if m.ProofHeight != 0 {
n += 1 + sovQuery(uint64(m.ProofHeight))
}
return n
}
func (m *QueryPacketCommitmentsRequest) Size() (n int) {
if m == nil {
return 0
}
var l int
_ = l
l = len(m.PortID)
if l > 0 {
n += 1 + l + sovQuery(uint64(l))
}
l = len(m.ChannelID)
if l > 0 {
n += 1 + l + sovQuery(uint64(l))
}
if m.Req != nil {
l = m.Req.Size()
n += 1 + l + sovQuery(uint64(l))
}
return n
}
func (m *QueryPacketCommitmentsResponse) Size() (n int) {
if m == nil {
return 0
}
var l int
_ = l
if len(m.Commitments) > 0 {
for _, e := range m.Commitments {
l = e.Size()
n += 1 + l + sovQuery(uint64(l))
}
}
if m.Res != nil {
l = m.Res.Size()
n += 1 + l + sovQuery(uint64(l))
}
if m.Height != 0 {
n += 1 + sovQuery(uint64(m.Height))
}
return n
}
func (m *QueryUnrelayedPacketsRequest) Size() (n int) {
if m == nil {
return 0
}
var l int
_ = l
l = len(m.PortID)
if l > 0 {
n += 1 + l + sovQuery(uint64(l))
}
l = len(m.ChannelID)
if l > 0 {
n += 1 + l + sovQuery(uint64(l))
}
if len(m.Sequences) > 0 {
l = 0
for _, e := range m.Sequences {
l += sovQuery(uint64(e))
}
n += 1 + sovQuery(uint64(l)) + l
}
if m.Req != nil {
l = m.Req.Size()
n += 1 + l + sovQuery(uint64(l))
}
return n
}
func (m *QueryUnrelayedPacketsResponse) Size() (n int) {
if m == nil {
return 0
}
var l int
_ = l
if len(m.Packets) > 0 {
l = 0
for _, e := range m.Packets {
l += sovQuery(uint64(e))
}
n += 1 + sovQuery(uint64(l)) + l
}
if m.Res != nil {
l = m.Res.Size()
n += 1 + l + sovQuery(uint64(l))
}
if m.Height != 0 {
n += 1 + sovQuery(uint64(m.Height))
}
return n
}
func (m *QueryNextSequenceReceiveRequest) Size() (n int) {
if m == nil {
return 0
}
var l int
_ = l
l = len(m.PortID)
if l > 0 {
n += 1 + l + sovQuery(uint64(l))
}
l = len(m.ChannelID)
if l > 0 {
n += 1 + l + sovQuery(uint64(l))
}
return n
}
func (m *QueryNextSequenceReceiveResponse) Size() (n int) {
if m == nil {
return 0
}
var l int
_ = l
if m.NextSequenceReceive != 0 {
n += 1 + sovQuery(uint64(m.NextSequenceReceive))
}
l = len(m.Proof)
if l > 0 {
n += 1 + l + sovQuery(uint64(l))
}
l = len(m.ProofPath)
if l > 0 {
n += 1 + l + sovQuery(uint64(l))
}
if m.ProofHeight != 0 {
n += 1 + sovQuery(uint64(m.ProofHeight))
}
return n
}
func (m *QueryChannelClientStateRequest) Size() (n int) {
if m == nil {
return 0
}
var l int
_ = l
l = len(m.PortID)
if l > 0 {
n += 1 + l + sovQuery(uint64(l))
}
l = len(m.ChannelID)
if l > 0 {
n += 1 + l + sovQuery(uint64(l))
}
return n
}
func sovQuery(x uint64) (n int) {
return (math_bits.Len64(x|1) + 6) / 7
}
func sozQuery(x uint64) (n int) {
return sovQuery(uint64((x << 1) ^ uint64((int64(x) >> 63))))
}
func (m *QueryChannelRequest) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= uint64(b&0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: QueryChannelRequest: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: QueryChannelRequest: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field PortID", wireType)
}
var stringLen uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
stringLen |= uint64(b&0x7F) << shift
if b < 0x80 {
break
}
}
intStringLen := int(stringLen)
if intStringLen < 0 {
return ErrInvalidLengthQuery
}
postIndex := iNdEx + intStringLen
if postIndex < 0 {
return ErrInvalidLengthQuery
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.PortID = string(dAtA[iNdEx:postIndex])
iNdEx = postIndex
case 2:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field ChannelID", wireType)
}
var stringLen uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
stringLen |= uint64(b&0x7F) << shift
if b < 0x80 {
break
}
}
intStringLen := int(stringLen)
if intStringLen < 0 {
return ErrInvalidLengthQuery
}
postIndex := iNdEx + intStringLen
if postIndex < 0 {
return ErrInvalidLengthQuery
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.ChannelID = string(dAtA[iNdEx:postIndex])
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skipQuery(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthQuery
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthQuery
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *QueryChannelResponse) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= uint64(b&0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: QueryChannelResponse: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: QueryChannelResponse: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Channel", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthQuery
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return ErrInvalidLengthQuery
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
if m.Channel == nil {
m.Channel = &Channel{}
}
if err := m.Channel.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 2:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Proof", wireType)
}
var byteLen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
byteLen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if byteLen < 0 {
return ErrInvalidLengthQuery
}
postIndex := iNdEx + byteLen
if postIndex < 0 {
return ErrInvalidLengthQuery
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.Proof = append(m.Proof[:0], dAtA[iNdEx:postIndex]...)
if m.Proof == nil {
m.Proof = []byte{}
}
iNdEx = postIndex
case 3:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field ProofPath", wireType)
}
var stringLen uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
stringLen |= uint64(b&0x7F) << shift
if b < 0x80 {
break
}
}
intStringLen := int(stringLen)
if intStringLen < 0 {
return ErrInvalidLengthQuery
}
postIndex := iNdEx + intStringLen
if postIndex < 0 {
return ErrInvalidLengthQuery
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.ProofPath = string(dAtA[iNdEx:postIndex])
iNdEx = postIndex
case 4:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field ProofHeight", wireType)
}
m.ProofHeight = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.ProofHeight |= uint64(b&0x7F) << shift
if b < 0x80 {
break
}
}
default:
iNdEx = preIndex
skippy, err := skipQuery(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthQuery
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthQuery
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *QueryChannelsRequest) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= uint64(b&0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: QueryChannelsRequest: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: QueryChannelsRequest: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Req", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthQuery
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return ErrInvalidLengthQuery
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
if m.Req == nil {
m.Req = &query.PageRequest{}
}
if err := m.Req.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skipQuery(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthQuery
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthQuery
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *QueryChannelsResponse) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= uint64(b&0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: QueryChannelsResponse: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: QueryChannelsResponse: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Channels", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthQuery
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return ErrInvalidLengthQuery
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.Channels = append(m.Channels, &IdentifiedChannel{})
if err := m.Channels[len(m.Channels)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 2:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Res", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthQuery
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return ErrInvalidLengthQuery
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
if m.Res == nil {
m.Res = &query.PageResponse{}
}
if err := m.Res.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 3:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field Height", wireType)
}
m.Height = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.Height |= int64(b&0x7F) << shift
if b < 0x80 {
break
}
}
default:
iNdEx = preIndex
skippy, err := skipQuery(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthQuery
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthQuery
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *QueryConnectionChannelsRequest) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= uint64(b&0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: QueryConnectionChannelsRequest: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: QueryConnectionChannelsRequest: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Connection", wireType)
}
var stringLen uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
stringLen |= uint64(b&0x7F) << shift
if b < 0x80 {
break
}
}
intStringLen := int(stringLen)
if intStringLen < 0 {
return ErrInvalidLengthQuery
}
postIndex := iNdEx + intStringLen
if postIndex < 0 {
return ErrInvalidLengthQuery
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.Connection = string(dAtA[iNdEx:postIndex])
iNdEx = postIndex
case 2:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Req", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthQuery
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return ErrInvalidLengthQuery
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
if m.Req == nil {
m.Req = &query.PageRequest{}
}
if err := m.Req.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skipQuery(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthQuery
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthQuery
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *QueryConnectionChannelsResponse) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= uint64(b&0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: QueryConnectionChannelsResponse: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: QueryConnectionChannelsResponse: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Channels", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthQuery
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return ErrInvalidLengthQuery
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.Channels = append(m.Channels, &IdentifiedChannel{})
if err := m.Channels[len(m.Channels)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 2:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Res", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthQuery
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return ErrInvalidLengthQuery
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
if m.Res == nil {
m.Res = &query.PageResponse{}
}
if err := m.Res.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 3:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field Height", wireType)
}
m.Height = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.Height |= int64(b&0x7F) << shift
if b < 0x80 {
break
}
}
default:
iNdEx = preIndex
skippy, err := skipQuery(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthQuery
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthQuery
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *QueryPacketCommitmentRequest) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= uint64(b&0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: QueryPacketCommitmentRequest: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: QueryPacketCommitmentRequest: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field PortID", wireType)
}
var stringLen uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
stringLen |= uint64(b&0x7F) << shift
if b < 0x80 {
break
}
}
intStringLen := int(stringLen)
if intStringLen < 0 {
return ErrInvalidLengthQuery
}
postIndex := iNdEx + intStringLen
if postIndex < 0 {
return ErrInvalidLengthQuery
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.PortID = string(dAtA[iNdEx:postIndex])
iNdEx = postIndex
case 2:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field ChannelID", wireType)
}
var stringLen uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
stringLen |= uint64(b&0x7F) << shift
if b < 0x80 {
break
}
}
intStringLen := int(stringLen)
if intStringLen < 0 {
return ErrInvalidLengthQuery
}
postIndex := iNdEx + intStringLen
if postIndex < 0 {
return ErrInvalidLengthQuery
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.ChannelID = string(dAtA[iNdEx:postIndex])
iNdEx = postIndex
case 3:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field Sequence", wireType)
}
m.Sequence = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.Sequence |= uint64(b&0x7F) << shift
if b < 0x80 {
break
}
}
default:
iNdEx = preIndex
skippy, err := skipQuery(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthQuery
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthQuery
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *QueryPacketCommitmentResponse) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= uint64(b&0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: QueryPacketCommitmentResponse: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: QueryPacketCommitmentResponse: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Commitment", wireType)
}
var byteLen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
byteLen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if byteLen < 0 {
return ErrInvalidLengthQuery
}
postIndex := iNdEx + byteLen
if postIndex < 0 {
return ErrInvalidLengthQuery
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.Commitment = append(m.Commitment[:0], dAtA[iNdEx:postIndex]...)
if m.Commitment == nil {
m.Commitment = []byte{}
}
iNdEx = postIndex
case 2:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Proof", wireType)
}
var byteLen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
byteLen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if byteLen < 0 {
return ErrInvalidLengthQuery
}
postIndex := iNdEx + byteLen
if postIndex < 0 {
return ErrInvalidLengthQuery
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.Proof = append(m.Proof[:0], dAtA[iNdEx:postIndex]...)
if m.Proof == nil {
m.Proof = []byte{}
}
iNdEx = postIndex
case 3:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field ProofPath", wireType)
}
var stringLen uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
stringLen |= uint64(b&0x7F) << shift
if b < 0x80 {
break
}
}
intStringLen := int(stringLen)
if intStringLen < 0 {
return ErrInvalidLengthQuery
}
postIndex := iNdEx + intStringLen
if postIndex < 0 {
return ErrInvalidLengthQuery
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.ProofPath = string(dAtA[iNdEx:postIndex])
iNdEx = postIndex
case 4:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field ProofHeight", wireType)
}
m.ProofHeight = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.ProofHeight |= uint64(b&0x7F) << shift
if b < 0x80 {
break
}
}
default:
iNdEx = preIndex
skippy, err := skipQuery(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthQuery
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthQuery
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *QueryPacketCommitmentsRequest) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= uint64(b&0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: QueryPacketCommitmentsRequest: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: QueryPacketCommitmentsRequest: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field PortID", wireType)
}
var stringLen uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
stringLen |= uint64(b&0x7F) << shift
if b < 0x80 {
break
}
}
intStringLen := int(stringLen)
if intStringLen < 0 {
return ErrInvalidLengthQuery
}
postIndex := iNdEx + intStringLen
if postIndex < 0 {
return ErrInvalidLengthQuery
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.PortID = string(dAtA[iNdEx:postIndex])
iNdEx = postIndex
case 2:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field ChannelID", wireType)
}
var stringLen uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
stringLen |= uint64(b&0x7F) << shift
if b < 0x80 {
break
}
}
intStringLen := int(stringLen)
if intStringLen < 0 {
return ErrInvalidLengthQuery
}
postIndex := iNdEx + intStringLen
if postIndex < 0 {
return ErrInvalidLengthQuery
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.ChannelID = string(dAtA[iNdEx:postIndex])
iNdEx = postIndex
case 3:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Req", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthQuery
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return ErrInvalidLengthQuery
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
if m.Req == nil {
m.Req = &query.PageRequest{}
}
if err := m.Req.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skipQuery(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthQuery
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthQuery
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *QueryPacketCommitmentsResponse) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= uint64(b&0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: QueryPacketCommitmentsResponse: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: QueryPacketCommitmentsResponse: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Commitments", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthQuery
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return ErrInvalidLengthQuery
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.Commitments = append(m.Commitments, &PacketAckCommitment{})
if err := m.Commitments[len(m.Commitments)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 2:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Res", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthQuery
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return ErrInvalidLengthQuery
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
if m.Res == nil {
m.Res = &query.PageResponse{}
}
if err := m.Res.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 3:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field Height", wireType)
}
m.Height = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.Height |= int64(b&0x7F) << shift
if b < 0x80 {
break
}
}
default:
iNdEx = preIndex
skippy, err := skipQuery(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthQuery
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthQuery
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *QueryUnrelayedPacketsRequest) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= uint64(b&0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: QueryUnrelayedPacketsRequest: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: QueryUnrelayedPacketsRequest: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field PortID", wireType)
}
var stringLen uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
stringLen |= uint64(b&0x7F) << shift
if b < 0x80 {
break
}
}
intStringLen := int(stringLen)
if intStringLen < 0 {
return ErrInvalidLengthQuery
}
postIndex := iNdEx + intStringLen
if postIndex < 0 {
return ErrInvalidLengthQuery
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.PortID = string(dAtA[iNdEx:postIndex])
iNdEx = postIndex
case 2:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field ChannelID", wireType)
}
var stringLen uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
stringLen |= uint64(b&0x7F) << shift
if b < 0x80 {
break
}
}
intStringLen := int(stringLen)
if intStringLen < 0 {
return ErrInvalidLengthQuery
}
postIndex := iNdEx + intStringLen
if postIndex < 0 {
return ErrInvalidLengthQuery
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.ChannelID = string(dAtA[iNdEx:postIndex])
iNdEx = postIndex
case 3:
if wireType == 0 {
var v uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
v |= uint64(b&0x7F) << shift
if b < 0x80 {
break
}
}
m.Sequences = append(m.Sequences, v)
} else if wireType == 2 {
var packedLen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
packedLen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if packedLen < 0 {
return ErrInvalidLengthQuery
}
postIndex := iNdEx + packedLen
if postIndex < 0 {
return ErrInvalidLengthQuery
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
var elementCount int
var count int
for _, integer := range dAtA[iNdEx:postIndex] {
if integer < 128 {
count++
}
}
elementCount = count
if elementCount != 0 && len(m.Sequences) == 0 {
m.Sequences = make([]uint64, 0, elementCount)
}
for iNdEx < postIndex {
var v uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
v |= uint64(b&0x7F) << shift
if b < 0x80 {
break
}
}
m.Sequences = append(m.Sequences, v)
}
} else {
return fmt.Errorf("proto: wrong wireType = %d for field Sequences", wireType)
}
case 4:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Req", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthQuery
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return ErrInvalidLengthQuery
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
if m.Req == nil {
m.Req = &query.PageRequest{}
}
if err := m.Req.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skipQuery(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthQuery
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthQuery
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *QueryUnrelayedPacketsResponse) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= uint64(b&0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: QueryUnrelayedPacketsResponse: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: QueryUnrelayedPacketsResponse: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType == 0 {
var v uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
v |= uint64(b&0x7F) << shift
if b < 0x80 {
break
}
}
m.Packets = append(m.Packets, v)
} else if wireType == 2 {
var packedLen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
packedLen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if packedLen < 0 {
return ErrInvalidLengthQuery
}
postIndex := iNdEx + packedLen
if postIndex < 0 {
return ErrInvalidLengthQuery
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
var elementCount int
var count int
for _, integer := range dAtA[iNdEx:postIndex] {
if integer < 128 {
count++
}
}
elementCount = count
if elementCount != 0 && len(m.Packets) == 0 {
m.Packets = make([]uint64, 0, elementCount)
}
for iNdEx < postIndex {
var v uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
v |= uint64(b&0x7F) << shift
if b < 0x80 {
break
}
}
m.Packets = append(m.Packets, v)
}
} else {
return fmt.Errorf("proto: wrong wireType = %d for field Packets", wireType)
}
case 2:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Res", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthQuery
}
postIndex := iNdEx + msglen
if postIndex < 0 {
return ErrInvalidLengthQuery
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
if m.Res == nil {
m.Res = &query.PageResponse{}
}
if err := m.Res.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 3:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field Height", wireType)
}
m.Height = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.Height |= int64(b&0x7F) << shift
if b < 0x80 {
break
}
}
default:
iNdEx = preIndex
skippy, err := skipQuery(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthQuery
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthQuery
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *QueryNextSequenceReceiveRequest) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= uint64(b&0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: QueryNextSequenceReceiveRequest: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: QueryNextSequenceReceiveRequest: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field PortID", wireType)
}
var stringLen uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
stringLen |= uint64(b&0x7F) << shift
if b < 0x80 {
break
}
}
intStringLen := int(stringLen)
if intStringLen < 0 {
return ErrInvalidLengthQuery
}
postIndex := iNdEx + intStringLen
if postIndex < 0 {
return ErrInvalidLengthQuery
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.PortID = string(dAtA[iNdEx:postIndex])
iNdEx = postIndex
case 2:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field ChannelID", wireType)
}
var stringLen uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
stringLen |= uint64(b&0x7F) << shift
if b < 0x80 {
break
}
}
intStringLen := int(stringLen)
if intStringLen < 0 {
return ErrInvalidLengthQuery
}
postIndex := iNdEx + intStringLen
if postIndex < 0 {
return ErrInvalidLengthQuery
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.ChannelID = string(dAtA[iNdEx:postIndex])
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skipQuery(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthQuery
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthQuery
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *QueryNextSequenceReceiveResponse) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= uint64(b&0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: QueryNextSequenceReceiveResponse: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: QueryNextSequenceReceiveResponse: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field NextSequenceReceive", wireType)
}
m.NextSequenceReceive = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.NextSequenceReceive |= uint64(b&0x7F) << shift
if b < 0x80 {
break
}
}
case 2:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Proof", wireType)
}
var byteLen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
byteLen |= int(b&0x7F) << shift
if b < 0x80 {
break
}
}
if byteLen < 0 {
return ErrInvalidLengthQuery
}
postIndex := iNdEx + byteLen
if postIndex < 0 {
return ErrInvalidLengthQuery
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.Proof = append(m.Proof[:0], dAtA[iNdEx:postIndex]...)
if m.Proof == nil {
m.Proof = []byte{}
}
iNdEx = postIndex
case 3:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field ProofPath", wireType)
}
var stringLen uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
stringLen |= uint64(b&0x7F) << shift
if b < 0x80 {
break
}
}
intStringLen := int(stringLen)
if intStringLen < 0 {
return ErrInvalidLengthQuery
}
postIndex := iNdEx + intStringLen
if postIndex < 0 {
return ErrInvalidLengthQuery
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.ProofPath = string(dAtA[iNdEx:postIndex])
iNdEx = postIndex
case 4:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field ProofHeight", wireType)
}
m.ProofHeight = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.ProofHeight |= uint64(b&0x7F) << shift
if b < 0x80 {
break
}
}
default:
iNdEx = preIndex
skippy, err := skipQuery(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthQuery
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthQuery
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *QueryChannelClientStateRequest) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= uint64(b&0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: QueryChannelClientStateRequest: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: QueryChannelClientStateRequest: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field PortID", wireType)
}
var stringLen uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
stringLen |= uint64(b&0x7F) << shift
if b < 0x80 {
break
}
}
intStringLen := int(stringLen)
if intStringLen < 0 {
return ErrInvalidLengthQuery
}
postIndex := iNdEx + intStringLen
if postIndex < 0 {
return ErrInvalidLengthQuery
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.PortID = string(dAtA[iNdEx:postIndex])
iNdEx = postIndex
case 2:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field ChannelID", wireType)
}
var stringLen uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowQuery
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
stringLen |= uint64(b&0x7F) << shift
if b < 0x80 {
break
}
}
intStringLen := int(stringLen)
if intStringLen < 0 {
return ErrInvalidLengthQuery
}
postIndex := iNdEx + intStringLen
if postIndex < 0 {
return ErrInvalidLengthQuery
}
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.ChannelID = string(dAtA[iNdEx:postIndex])
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skipQuery(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthQuery
}
if (iNdEx + skippy) < 0 {
return ErrInvalidLengthQuery
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func skipQuery(dAtA []byte) (n int, err error) {
l := len(dAtA)
iNdEx := 0
depth := 0
for iNdEx < l {
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return 0, ErrIntOverflowQuery
}
if iNdEx >= l {
return 0, io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
wireType := int(wire & 0x7)
switch wireType {
case 0:
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return 0, ErrIntOverflowQuery
}
if iNdEx >= l {
return 0, io.ErrUnexpectedEOF
}
iNdEx++
if dAtA[iNdEx-1] < 0x80 {
break
}
}
case 1:
iNdEx += 8
case 2:
var length int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return 0, ErrIntOverflowQuery
}
if iNdEx >= l {
return 0, io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
length |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if length < 0 {
return 0, ErrInvalidLengthQuery
}
iNdEx += length
case 3:
depth++
case 4:
if depth == 0 {
return 0, ErrUnexpectedEndOfGroupQuery
}
depth--
case 5:
iNdEx += 4
default:
return 0, fmt.Errorf("proto: illegal wireType %d", wireType)
}
if iNdEx < 0 {
return 0, ErrInvalidLengthQuery
}
if depth == 0 {
return iNdEx, nil
}
}
return 0, io.ErrUnexpectedEOF
}
var (
ErrInvalidLengthQuery = fmt.Errorf("proto: negative length found during unmarshaling")
ErrIntOverflowQuery = fmt.Errorf("proto: integer overflow")
ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group")
)