packet

package
v0.0.0-...-a76333c Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 21, 2022 License: Apache-2.0 Imports: 26 Imported by: 0

Documentation

Overview

Package packet is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	// ModuleName is the name of the IBC module
	ModuleName = "tibc"

	// StoreKey is the string store representation
	StoreKey string = ModuleName

	// QuerierRoute is the querier route for the IBC module
	QuerierRoute string = ModuleName

	// RouterKey is the msg router key for the IBC module
	RouterKey string = ModuleName
)
View Source 
const (
	KeyClientState                 = "clientState"
	KeyConsensusStatePrefix        = "consensusStates"
	KeyPortPrefix                  = "ports"
	KeySequencePrefix              = "sequences"
	KeyNextSeqSendPrefix           = "nextSequenceSend"
	KeyNextSeqRecvPrefix           = "nextSequenceRecv"
	KeyNextSeqAckPrefix            = "nextSequenceAck"
	KeyPacketCommitmentPrefix      = "commitments"
	KeyPacketAckPrefix             = "acks"
	KeyPacketReceiptPrefix         = "receipts"
	KeyCleanPacketCommitmentPrefix = "clean"
)

KVStore key prefixes for IBC

Variables

View Source 
var (
	ErrSequenceSendNotFound     = types.Register(moduleName, 2, "sequence send not found")
	ErrSequenceReceiveNotFound  = types.Register(moduleName, 3, "sequence receive not found")
	ErrSequenceAckNotFound      = types.Register(moduleName, 4, "sequence acknowledgement not found")
	ErrInvalidPacket            = types.Register(moduleName, 5, "invalid packet")
	ErrInvalidAcknowledgement   = types.Register(moduleName, 6, "invalid acknowledgement")
	ErrPacketCommitmentNotFound = types.Register(moduleName, 7, "packet commitment not found")
	ErrPacketReceived           = types.Register(moduleName, 8, "packet already received")
	ErrAcknowledgementExists    = types.Register(moduleName, 9, "acknowledgement for packet already exists")
	ErrInvalidCleanPacket       = types.Register(moduleName, 10, "invalid clean packet")
)

TIBC packet sentinel errors

View Source 
var (
	ErrInvalidLengthGenesis        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGenesis          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGenesis = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthPacket        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPacket          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupPacket = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthQuery        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQuery          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthTx        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTx          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTx = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	KeyClientStorePrefix = []byte("clients")
)

KVStore key prefixes for IBC

View Source 
var (
	ModuleCdc = codec.NewAminoCodec(amino)
)

Functions

func CleanPacketCommitmentKey 

func CleanPacketCommitmentKey(sourceChain, destinationChain string) []byte

CleanPacketCommitmentKey returns the store key of under which a clean packet commitment is stored

func CleanPacketCommitmentPath 

func CleanPacketCommitmentPath(sourceChain, destinationChain string) string

CleanPacketCommitmentPrefixPath defines the prefix for commitments to packet data fields store path.

func ClientStateKey 

func ClientStateKey() []byte

ClientStateKey returns a store key under which a particular client state is stored in a client prefixed store

func ConsensusStateKey 

func ConsensusStateKey(height tibcclient.Height) []byte

ConsensusStateKey returns the store key for a the consensus state of a particular client stored in a client prefixed store.

func ConsensusStatePath 

func ConsensusStatePath(height tibcclient.Height) string

ConsensusStatePath returns the suffix store key for the consensus state at a particular height stored in a client prefixed store.

func FullClientKey 

func FullClientKey(chainName string, path []byte) []byte

FullClientKey returns the full path of specific client path in the format: "clients/{chainName}/{path}" as a byte array.

func FullClientPath 

func FullClientPath(chainName string, path string) string

FullClientPath returns the full path of a specific client path in the format: "clients/{chainName}/{path}" as a string.

func FullClientStateKey 

func FullClientStateKey(chainName string) []byte

FullClientStateKey takes a client identifier and returns a Key under which to store a particular client state.

func FullClientStatePath 

func FullClientStatePath(chainName string) string

FullClientStatePath takes a client identifier and returns a Path under which to store a particular client state

func FullConsensusStateKey 

func FullConsensusStateKey(chainName string, height tibcclient.Height) []byte

FullConsensusStateKey returns the store key for the consensus state of a particular client.

func FullConsensusStatePath 

func FullConsensusStatePath(chainName string, height tibcclient.Height) string

FullConsensusStatePath takes a client identifier and returns a Path under which to store the consensus state of a client.

func NextSequenceSendKey 

func NextSequenceSendKey(sourceChain, destChain string) []byte

NextSequenceSendKey returns the store key for the send sequence of a particular channel binded to a specific port.

func NextSequenceSendPath 

func NextSequenceSendPath(sourceChain, destChain string) string

NextSequenceSendPath defines the next send sequence counter store path

func PacketAcknowledgementKey 

func PacketAcknowledgementKey(sourceChain, destinationChain string, sequence uint64) []byte

PacketAcknowledgementKey returns the store key of under which a packet acknowledgement is stored

func PacketAcknowledgementPath 

func PacketAcknowledgementPath(sourceChain, destinationChain string, sequence uint64) string

PacketAcknowledgementPath defines the packet acknowledgement store path

func PacketAcknowledgementPrefixPath 

func PacketAcknowledgementPrefixPath(sourceChain, destinationChain string) string

PacketAcknowledgementPrefixPath defines the prefix for commitments to packet data fields store path.

func PacketCommitmentKey 

func PacketCommitmentKey(sourceChain, destinationChain string, sequence uint64) []byte

PacketCommitmentKey returns the store key of under which a packet commitment is stored

func PacketCommitmentPath 

func PacketCommitmentPath(sourceChain, destinationChain string, sequence uint64) string

PacketCommitmentPath defines the commitments to packet data fields store path

func PacketCommitmentPrefixPath 

func PacketCommitmentPrefixPath(sourceChain, destinationChain string) string

PacketCommitmentPrefixPath defines the prefix for commitments to packet data fields store path.

func PacketReceiptKey 

func PacketReceiptKey(sourceChain, destinationChain string, sequence uint64) []byte

PacketReceiptKey returns the store key of under which a packet receipt is stored

func PacketReceiptPath 

func PacketReceiptPath(sourceChain, destinationChain string, sequence uint64) string

PacketReceiptPath defines the packet receipt store path

func PacketReceiptPrefixPath 

func PacketReceiptPrefixPath(sourceChain, destinationChain string) string

PacketReceiptKey returns the store key of under which a packet receipt is stored

func PortPath 

func PortPath(portID string) string

PortPath defines the path under which ports paths are stored on the capability module

func RegisterInterfaces 

func RegisterInterfaces(registry types.InterfaceRegistry)

func RegisterMsgServer 

func RegisterMsgServer(s grpc1.Server, srv MsgServer)

func RegisterQueryHandler 

func RegisterQueryHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterQueryHandler registers the http handlers for service Query to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterQueryHandlerClient 

func RegisterQueryHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryClient) error

RegisterQueryHandlerClient registers the http handlers for service Query to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "QueryClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "QueryClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "QueryClient" to call the correct interceptors.

func RegisterQueryHandlerFromEndpoint 

func RegisterQueryHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterQueryHandlerFromEndpoint is same as RegisterQueryHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterQueryHandlerServer 

func RegisterQueryHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryServer) error

RegisterQueryHandlerServer registers the http handlers for service Query to "mux". UnaryRPC :call QueryServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features (such as grpc.SendHeader, etc) to stop working. Consider using RegisterQueryHandlerFromEndpoint instead.

func RegisterQueryServer 

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

Types

type Acknowledgement 

type Acknowledgement struct {
	// response contains either a result or an error and must be non-empty
	//
	// Types that are valid to be assigned to Response:
	//	*Acknowledgement_Result
	//	*Acknowledgement_Error
	Response isAcknowledgement_Response `protobuf_oneof:"response"`
}

Acknowledgement is the recommended acknowledgement format to be used by app-specific protocols. NOTE: The field numbers 21 and 22 were explicitly chosen to avoid accidental conflicts with other protobuf message formats used for acknowledgements. The first byte of any message with this format will be the non-ASCII values `0xaa` (result) or `0xb2` (error). Implemented as defined by ICS: https://github.com/cosmos/ics/tree/master/spec/ics-004-channel-and-packet-semantics#acknowledgement-envelope

func (*Acknowledgement) Descriptor 

func (*Acknowledgement) Descriptor() ([]byte, []int)

func (*Acknowledgement) GetError 

func (m *Acknowledgement) GetError() string

func (*Acknowledgement) GetResponse 

func (m *Acknowledgement) GetResponse() isAcknowledgement_Response

func (*Acknowledgement) GetResult 

func (m *Acknowledgement) GetResult() []byte

func (*Acknowledgement) Marshal 

func (m *Acknowledgement) Marshal() (dAtA []byte, err error)

func (*Acknowledgement) MarshalTo 

func (m *Acknowledgement) MarshalTo(dAtA []byte) (int, error)

func (*Acknowledgement) MarshalToSizedBuffer 

func (m *Acknowledgement) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Acknowledgement) ProtoMessage 

func (*Acknowledgement) ProtoMessage()

func (*Acknowledgement) Reset 

func (m *Acknowledgement) Reset()

func (*Acknowledgement) Size 

func (m *Acknowledgement) Size() (n int)

func (*Acknowledgement) String 

func (m *Acknowledgement) String() string

func (*Acknowledgement) Unmarshal 

func (m *Acknowledgement) Unmarshal(dAtA []byte) error

func (*Acknowledgement) XXX_DiscardUnknown 

func (m *Acknowledgement) XXX_DiscardUnknown()

func (*Acknowledgement) XXX_Marshal 

func (m *Acknowledgement) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Acknowledgement) XXX_Merge 

func (m *Acknowledgement) XXX_Merge(src proto.Message)

func (*Acknowledgement) XXX_OneofWrappers 

func (*Acknowledgement) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Acknowledgement) XXX_Size 

func (m *Acknowledgement) XXX_Size() int

func (*Acknowledgement) XXX_Unmarshal 

func (m *Acknowledgement) XXX_Unmarshal(b []byte) error

type Acknowledgement_Error 

type Acknowledgement_Error struct {
	Error string `protobuf:"bytes,22,opt,name=error,proto3,oneof" json:"error,omitempty"`
}

func (*Acknowledgement_Error) MarshalTo 

func (m *Acknowledgement_Error) MarshalTo(dAtA []byte) (int, error)

func (*Acknowledgement_Error) MarshalToSizedBuffer 

func (m *Acknowledgement_Error) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Acknowledgement_Error) Size 

func (m *Acknowledgement_Error) Size() (n int)

type Acknowledgement_Result 

type Acknowledgement_Result struct {
	Result []byte `protobuf:"bytes,21,opt,name=result,proto3,oneof" json:"result,omitempty"`
}

func (*Acknowledgement_Result) MarshalTo 

func (m *Acknowledgement_Result) MarshalTo(dAtA []byte) (int, error)

func (*Acknowledgement_Result) MarshalToSizedBuffer 

func (m *Acknowledgement_Result) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Acknowledgement_Result) Size 

func (m *Acknowledgement_Result) Size() (n int)

type CleanPacket 

type CleanPacket struct {
	// number corresponds to the order of sends and receives, where a Packet
	// with an earlier sequence number must be sent and received before a Packet
	// with a later sequence number.
	Sequence uint64 `protobuf:"varint,1,opt,name=sequence,proto3" json:"sequence,omitempty"`
	// identifies the chain id of the sending chain.
	SourceChain string `protobuf:"bytes,3,opt,name=source_chain,json=sourceChain,proto3" json:"source_chain,omitempty" yaml:"source_chain"`
	// identifies the chain id of the receiving chain.
	DestinationChain string `` /* 133-byte string literal not displayed */
	// identifies the chain id of the relay chain.
	RelayChain string `protobuf:"bytes,5,opt,name=relay_chain,json=relayChain,proto3" json:"relay_chain,omitempty" yaml:"relay_chain"`
}

CleanPacket defines a type that carries data across different chains through IBC

func (*CleanPacket) Descriptor 

func (*CleanPacket) Descriptor() ([]byte, []int)

func (CleanPacket) GetDestChain 

func (p CleanPacket) GetDestChain() string

GetDestinationChain implements PacketI interface

func (CleanPacket) GetRelayChain 

func (p CleanPacket) GetRelayChain() string

GetRelayChain implements PacketI interface

func (CleanPacket) GetSequence 

func (p CleanPacket) GetSequence() uint64

GetSequence implements PacketI interface

func (CleanPacket) GetSourceChain 

func (p CleanPacket) GetSourceChain() string

GetSourceChain implements PacketI interface

func (*CleanPacket) Marshal 

func (m *CleanPacket) Marshal() (dAtA []byte, err error)

func (*CleanPacket) MarshalTo 

func (m *CleanPacket) MarshalTo(dAtA []byte) (int, error)

func (*CleanPacket) MarshalToSizedBuffer 

func (m *CleanPacket) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CleanPacket) ProtoMessage 

func (*CleanPacket) ProtoMessage()

func (*CleanPacket) Reset 

func (m *CleanPacket) Reset()

func (*CleanPacket) Size 

func (m *CleanPacket) Size() (n int)

func (*CleanPacket) String 

func (m *CleanPacket) String() string

func (*CleanPacket) Unmarshal 

func (m *CleanPacket) Unmarshal(dAtA []byte) error

func (CleanPacket) ValidateBasic 

func (p CleanPacket) ValidateBasic() error

ValidateBasic implements PacketI interface

func (*CleanPacket) XXX_DiscardUnknown 

func (m *CleanPacket) XXX_DiscardUnknown()

func (*CleanPacket) XXX_Marshal 

func (m *CleanPacket) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CleanPacket) XXX_Merge 

func (m *CleanPacket) XXX_Merge(src proto.Message)

func (*CleanPacket) XXX_Size 

func (m *CleanPacket) XXX_Size() int

func (*CleanPacket) XXX_Unmarshal 

func (m *CleanPacket) XXX_Unmarshal(b []byte) error

type GenesisState 

type GenesisState struct {
	Acknowledgements []PacketState    `protobuf:"bytes,2,rep,name=acknowledgements,proto3" json:"acknowledgements"`
	Commitments      []PacketState    `protobuf:"bytes,3,rep,name=commitments,proto3" json:"commitments"`
	Receipts         []PacketState    `protobuf:"bytes,4,rep,name=receipts,proto3" json:"receipts"`
	SendSequences    []PacketSequence `protobuf:"bytes,5,rep,name=send_sequences,json=sendSequences,proto3" json:"send_sequences" yaml:"send_sequences"`
	RecvSequences    []PacketSequence `protobuf:"bytes,6,rep,name=recv_sequences,json=recvSequences,proto3" json:"recv_sequences" yaml:"recv_sequences"`
	AckSequences     []PacketSequence `protobuf:"bytes,7,rep,name=ack_sequences,json=ackSequences,proto3" json:"ack_sequences" yaml:"ack_sequences"`
	// the sequence for the next generated channel identifier
	NextChannelSequence uint64 `` /* 150-byte string literal not displayed */
}

GenesisState defines the ibc channel submodule's genesis state.

func (*GenesisState) Descriptor 

func (*GenesisState) Descriptor() ([]byte, []int)

func (*GenesisState) GetAckSequences 

func (m *GenesisState) GetAckSequences() []PacketSequence

func (*GenesisState) GetAcknowledgements 

func (m *GenesisState) GetAcknowledgements() []PacketState

func (*GenesisState) GetCommitments 

func (m *GenesisState) GetCommitments() []PacketState

func (*GenesisState) GetNextChannelSequence 

func (m *GenesisState) GetNextChannelSequence() uint64

func (*GenesisState) GetReceipts 

func (m *GenesisState) GetReceipts() []PacketState

func (*GenesisState) GetRecvSequences 

func (m *GenesisState) GetRecvSequences() []PacketSequence

func (*GenesisState) GetSendSequences 

func (m *GenesisState) GetSendSequences() []PacketSequence

func (*GenesisState) Marshal 

func (m *GenesisState) Marshal() (dAtA []byte, err error)

func (*GenesisState) MarshalTo 

func (m *GenesisState) MarshalTo(dAtA []byte) (int, error)

func (*GenesisState) MarshalToSizedBuffer 

func (m *GenesisState) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GenesisState) ProtoMessage 

func (*GenesisState) ProtoMessage()

func (*GenesisState) Reset 

func (m *GenesisState) Reset()

func (*GenesisState) Size 

func (m *GenesisState) Size() (n int)

func (*GenesisState) String 

func (m *GenesisState) String() string

func (*GenesisState) Unmarshal 

func (m *GenesisState) Unmarshal(dAtA []byte) error

func (*GenesisState) XXX_DiscardUnknown 

func (m *GenesisState) XXX_DiscardUnknown()

func (*GenesisState) XXX_Marshal 

func (m *GenesisState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GenesisState) XXX_Merge 

func (m *GenesisState) XXX_Merge(src proto.Message)

func (*GenesisState) XXX_Size 

func (m *GenesisState) XXX_Size() int

func (*GenesisState) XXX_Unmarshal 

func (m *GenesisState) XXX_Unmarshal(b []byte) error

type MsgAcknowledgement 

type MsgAcknowledgement struct {
	Packet          Packet        `protobuf:"bytes,1,opt,name=packet,proto3" json:"packet"`
	Acknowledgement []byte        `protobuf:"bytes,2,opt,name=acknowledgement,proto3" json:"acknowledgement,omitempty"`
	ProofAcked      []byte        `protobuf:"bytes,3,opt,name=proof_acked,json=proofAcked,proto3" json:"proof_acked,omitempty" yaml:"proof_acked"`
	ProofHeight     client.Height `protobuf:"bytes,4,opt,name=proof_height,json=proofHeight,proto3" json:"proof_height" yaml:"proof_height"`
	Signer          string        `protobuf:"bytes,5,opt,name=signer,proto3" json:"signer,omitempty"`
}

MsgAcknowledgement receives incoming IBC acknowledgement

func (*MsgAcknowledgement) Descriptor 

func (*MsgAcknowledgement) Descriptor() ([]byte, []int)

func (MsgAcknowledgement) GetSignBytes 

func (msg MsgAcknowledgement) GetSignBytes() []byte

GetSignBytes implements sdk.Msg. The function will panic since it is used for amino transaction verification which TIBC does not support.

func (MsgAcknowledgement) GetSigners 

func (msg MsgAcknowledgement) GetSigners() []sdk.AccAddress

GetSigners implements sdk.Msg

func (*MsgAcknowledgement) Marshal 

func (m *MsgAcknowledgement) Marshal() (dAtA []byte, err error)

func (*MsgAcknowledgement) MarshalTo 

func (m *MsgAcknowledgement) MarshalTo(dAtA []byte) (int, error)

func (*MsgAcknowledgement) MarshalToSizedBuffer 

func (m *MsgAcknowledgement) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgAcknowledgement) ProtoMessage 

func (*MsgAcknowledgement) ProtoMessage()

func (*MsgAcknowledgement) Reset 

func (m *MsgAcknowledgement) Reset()

func (MsgAcknowledgement) Route 

func (msg MsgAcknowledgement) Route() string

Route implements sdk.Msg

func (*MsgAcknowledgement) Size 

func (m *MsgAcknowledgement) Size() (n int)

func (*MsgAcknowledgement) String 

func (m *MsgAcknowledgement) String() string

func (MsgAcknowledgement) Type 

func (msg MsgAcknowledgement) Type() string

Type implements sdk.Msg

func (*MsgAcknowledgement) Unmarshal 

func (m *MsgAcknowledgement) Unmarshal(dAtA []byte) error

func (MsgAcknowledgement) ValidateBasic 

func (msg MsgAcknowledgement) ValidateBasic() error

ValidateBasic implements sdk.Msg

func (*MsgAcknowledgement) XXX_DiscardUnknown 

func (m *MsgAcknowledgement) XXX_DiscardUnknown()

func (*MsgAcknowledgement) XXX_Marshal 

func (m *MsgAcknowledgement) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgAcknowledgement) XXX_Merge 

func (m *MsgAcknowledgement) XXX_Merge(src proto.Message)

func (*MsgAcknowledgement) XXX_Size 

func (m *MsgAcknowledgement) XXX_Size() int

func (*MsgAcknowledgement) XXX_Unmarshal 

func (m *MsgAcknowledgement) XXX_Unmarshal(b []byte) error

type MsgAcknowledgementResponse 

type MsgAcknowledgementResponse struct {
}

MsgAcknowledgementResponse defines the Msg/Acknowledgement response type.

func (*MsgAcknowledgementResponse) Descriptor 

func (*MsgAcknowledgementResponse) Descriptor() ([]byte, []int)

func (*MsgAcknowledgementResponse) Marshal 

func (m *MsgAcknowledgementResponse) Marshal() (dAtA []byte, err error)

func (*MsgAcknowledgementResponse) MarshalTo 

func (m *MsgAcknowledgementResponse) MarshalTo(dAtA []byte) (int, error)

func (*MsgAcknowledgementResponse) MarshalToSizedBuffer 

func (m *MsgAcknowledgementResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgAcknowledgementResponse) ProtoMessage 

func (*MsgAcknowledgementResponse) ProtoMessage()

func (*MsgAcknowledgementResponse) Reset 

func (m *MsgAcknowledgementResponse) Reset()

func (*MsgAcknowledgementResponse) Size 

func (m *MsgAcknowledgementResponse) Size() (n int)

func (*MsgAcknowledgementResponse) String 

func (m *MsgAcknowledgementResponse) String() string

func (*MsgAcknowledgementResponse) Unmarshal 

func (m *MsgAcknowledgementResponse) Unmarshal(dAtA []byte) error

func (*MsgAcknowledgementResponse) XXX_DiscardUnknown 

func (m *MsgAcknowledgementResponse) XXX_DiscardUnknown()

func (*MsgAcknowledgementResponse) XXX_Marshal 

func (m *MsgAcknowledgementResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgAcknowledgementResponse) XXX_Merge 

func (m *MsgAcknowledgementResponse) XXX_Merge(src proto.Message)

func (*MsgAcknowledgementResponse) XXX_Size 

func (m *MsgAcknowledgementResponse) XXX_Size() int

func (*MsgAcknowledgementResponse) XXX_Unmarshal 

func (m *MsgAcknowledgementResponse) XXX_Unmarshal(b []byte) error

type MsgCleanPacket 

type MsgCleanPacket struct {
	CleanPacket CleanPacket `protobuf:"bytes,1,opt,name=clean_packet,json=cleanPacket,proto3" json:"clean_packet"`
	Signer      string      `protobuf:"bytes,2,opt,name=signer,proto3" json:"signer,omitempty"`
}

MsgRecvPacket receives incoming IBC packet

func (*MsgCleanPacket) Descriptor 

func (*MsgCleanPacket) Descriptor() ([]byte, []int)

func (MsgCleanPacket) GetSignBytes 

func (msg MsgCleanPacket) GetSignBytes() []byte

GetSignBytes implements sdk.Msg. The function will panic since it is used for amino transaction verification which TIBC does not support.

func (MsgCleanPacket) GetSigners 

func (msg MsgCleanPacket) GetSigners() []sdk.AccAddress

GetSigners implements sdk.Msg

func (*MsgCleanPacket) Marshal 

func (m *MsgCleanPacket) Marshal() (dAtA []byte, err error)

func (*MsgCleanPacket) MarshalTo 

func (m *MsgCleanPacket) MarshalTo(dAtA []byte) (int, error)

func (*MsgCleanPacket) MarshalToSizedBuffer 

func (m *MsgCleanPacket) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgCleanPacket) ProtoMessage 

func (*MsgCleanPacket) ProtoMessage()

func (*MsgCleanPacket) Reset 

func (m *MsgCleanPacket) Reset()

func (MsgCleanPacket) Route 

func (msg MsgCleanPacket) Route() string

Route implements sdk.Msg

func (*MsgCleanPacket) Size 

func (m *MsgCleanPacket) Size() (n int)

func (*MsgCleanPacket) String 

func (m *MsgCleanPacket) String() string

func (MsgCleanPacket) Type 

func (msg MsgCleanPacket) Type() string

Type implements sdk.Msg

func (*MsgCleanPacket) Unmarshal 

func (m *MsgCleanPacket) Unmarshal(dAtA []byte) error

func (MsgCleanPacket) ValidateBasic 

func (msg MsgCleanPacket) ValidateBasic() error

ValidateBasic implements sdk.Msg

func (*MsgCleanPacket) XXX_DiscardUnknown 

func (m *MsgCleanPacket) XXX_DiscardUnknown()

func (*MsgCleanPacket) XXX_Marshal 

func (m *MsgCleanPacket) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgCleanPacket) XXX_Merge 

func (m *MsgCleanPacket) XXX_Merge(src proto.Message)

func (*MsgCleanPacket) XXX_Size 

func (m *MsgCleanPacket) XXX_Size() int

func (*MsgCleanPacket) XXX_Unmarshal 

func (m *MsgCleanPacket) XXX_Unmarshal(b []byte) error

type MsgCleanPacketResponse 

type MsgCleanPacketResponse struct {
}

MsgRecvPacketResponse defines the Msg/RecvPacket response type.

func (*MsgCleanPacketResponse) Descriptor 

func (*MsgCleanPacketResponse) Descriptor() ([]byte, []int)

func (*MsgCleanPacketResponse) Marshal 

func (m *MsgCleanPacketResponse) Marshal() (dAtA []byte, err error)

func (*MsgCleanPacketResponse) MarshalTo 

func (m *MsgCleanPacketResponse) MarshalTo(dAtA []byte) (int, error)

func (*MsgCleanPacketResponse) MarshalToSizedBuffer 

func (m *MsgCleanPacketResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgCleanPacketResponse) ProtoMessage 

func (*MsgCleanPacketResponse) ProtoMessage()

func (*MsgCleanPacketResponse) Reset 

func (m *MsgCleanPacketResponse) Reset()

func (*MsgCleanPacketResponse) Size 

func (m *MsgCleanPacketResponse) Size() (n int)

func (*MsgCleanPacketResponse) String 

func (m *MsgCleanPacketResponse) String() string

func (*MsgCleanPacketResponse) Unmarshal 

func (m *MsgCleanPacketResponse) Unmarshal(dAtA []byte) error

func (*MsgCleanPacketResponse) XXX_DiscardUnknown 

func (m *MsgCleanPacketResponse) XXX_DiscardUnknown()

func (*MsgCleanPacketResponse) XXX_Marshal 

func (m *MsgCleanPacketResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgCleanPacketResponse) XXX_Merge 

func (m *MsgCleanPacketResponse) XXX_Merge(src proto.Message)

func (*MsgCleanPacketResponse) XXX_Size 

func (m *MsgCleanPacketResponse) XXX_Size() int

func (*MsgCleanPacketResponse) XXX_Unmarshal 

func (m *MsgCleanPacketResponse) XXX_Unmarshal(b []byte) error

type MsgClient 

type MsgClient interface {
	// RecvPacket defines a rpc handler method for MsgRecvPacket.
	RecvPacket(ctx context.Context, in *MsgRecvPacket, opts ...grpc.CallOption) (*MsgRecvPacketResponse, error)
	// Acknowledgement defines a rpc handler method for MsgAcknowledgement.
	Acknowledgement(ctx context.Context, in *MsgAcknowledgement, opts ...grpc.CallOption) (*MsgAcknowledgementResponse, error)
	// CleanPacket defines a rpc handler method for MsgCleanPacket.
	CleanPacket(ctx context.Context, in *MsgCleanPacket, opts ...grpc.CallOption) (*MsgCleanPacketResponse, error)
	// RecvCleanPacket defines a rpc handler method for MsgRecvCleanPacket.
	RecvCleanPacket(ctx context.Context, in *MsgRecvCleanPacket, opts ...grpc.CallOption) (*MsgRecvCleanPacketResponse, error)
}

MsgClient is the client API for Msg service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewMsgClient 

func NewMsgClient(cc grpc1.ClientConn) MsgClient

type MsgRecvCleanPacket 

type MsgRecvCleanPacket struct {
	CleanPacket     CleanPacket   `protobuf:"bytes,1,opt,name=clean_packet,json=cleanPacket,proto3" json:"clean_packet"`
	ProofCommitment []byte        `` /* 130-byte string literal not displayed */
	ProofHeight     client.Height `protobuf:"bytes,3,opt,name=proof_height,json=proofHeight,proto3" json:"proof_height" yaml:"proof_height"`
	Signer          string        `protobuf:"bytes,4,opt,name=signer,proto3" json:"signer,omitempty"`
}

MsgRecvPacket receives incoming IBC packet

func (*MsgRecvCleanPacket) Descriptor 

func (*MsgRecvCleanPacket) Descriptor() ([]byte, []int)

func (MsgRecvCleanPacket) GetSignBytes 

func (msg MsgRecvCleanPacket) GetSignBytes() []byte

GetSignBytes implements sdk.Msg. The function will panic since it is used for amino transaction verification which TIBC does not support.

func (MsgRecvCleanPacket) GetSigners 

func (msg MsgRecvCleanPacket) GetSigners() []sdk.AccAddress

GetSigners implements sdk.Msg

func (*MsgRecvCleanPacket) Marshal 

func (m *MsgRecvCleanPacket) Marshal() (dAtA []byte, err error)

func (*MsgRecvCleanPacket) MarshalTo 

func (m *MsgRecvCleanPacket) MarshalTo(dAtA []byte) (int, error)

func (*MsgRecvCleanPacket) MarshalToSizedBuffer 

func (m *MsgRecvCleanPacket) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgRecvCleanPacket) ProtoMessage 

func (*MsgRecvCleanPacket) ProtoMessage()

func (*MsgRecvCleanPacket) Reset 

func (m *MsgRecvCleanPacket) Reset()

func (MsgRecvCleanPacket) Route 

func (msg MsgRecvCleanPacket) Route() string

Route implements sdk.Msg

func (*MsgRecvCleanPacket) Size 

func (m *MsgRecvCleanPacket) Size() (n int)

func (*MsgRecvCleanPacket) String 

func (m *MsgRecvCleanPacket) String() string

func (MsgRecvCleanPacket) Type 

func (msg MsgRecvCleanPacket) Type() string

Type implements sdk.Msg

func (*MsgRecvCleanPacket) Unmarshal 

func (m *MsgRecvCleanPacket) Unmarshal(dAtA []byte) error

func (MsgRecvCleanPacket) ValidateBasic 

func (msg MsgRecvCleanPacket) ValidateBasic() error

ValidateBasic implements sdk.Msg

func (*MsgRecvCleanPacket) XXX_DiscardUnknown 

func (m *MsgRecvCleanPacket) XXX_DiscardUnknown()

func (*MsgRecvCleanPacket) XXX_Marshal 

func (m *MsgRecvCleanPacket) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgRecvCleanPacket) XXX_Merge 

func (m *MsgRecvCleanPacket) XXX_Merge(src proto.Message)

func (*MsgRecvCleanPacket) XXX_Size 

func (m *MsgRecvCleanPacket) XXX_Size() int

func (*MsgRecvCleanPacket) XXX_Unmarshal 

func (m *MsgRecvCleanPacket) XXX_Unmarshal(b []byte) error

type MsgRecvCleanPacketResponse 

type MsgRecvCleanPacketResponse struct {
}

MsgRecvPacketResponse defines the Msg/RecvPacket response type.

func (*MsgRecvCleanPacketResponse) Descriptor 

func (*MsgRecvCleanPacketResponse) Descriptor() ([]byte, []int)

func (*MsgRecvCleanPacketResponse) Marshal 

func (m *MsgRecvCleanPacketResponse) Marshal() (dAtA []byte, err error)

func (*MsgRecvCleanPacketResponse) MarshalTo 

func (m *MsgRecvCleanPacketResponse) MarshalTo(dAtA []byte) (int, error)

func (*MsgRecvCleanPacketResponse) MarshalToSizedBuffer 

func (m *MsgRecvCleanPacketResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgRecvCleanPacketResponse) ProtoMessage 

func (*MsgRecvCleanPacketResponse) ProtoMessage()

func (*MsgRecvCleanPacketResponse) Reset 

func (m *MsgRecvCleanPacketResponse) Reset()

func (*MsgRecvCleanPacketResponse) Size 

func (m *MsgRecvCleanPacketResponse) Size() (n int)

func (*MsgRecvCleanPacketResponse) String 

func (m *MsgRecvCleanPacketResponse) String() string

func (*MsgRecvCleanPacketResponse) Unmarshal 

func (m *MsgRecvCleanPacketResponse) Unmarshal(dAtA []byte) error

func (*MsgRecvCleanPacketResponse) XXX_DiscardUnknown 

func (m *MsgRecvCleanPacketResponse) XXX_DiscardUnknown()

func (*MsgRecvCleanPacketResponse) XXX_Marshal 

func (m *MsgRecvCleanPacketResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgRecvCleanPacketResponse) XXX_Merge 

func (m *MsgRecvCleanPacketResponse) XXX_Merge(src proto.Message)

func (*MsgRecvCleanPacketResponse) XXX_Size 

func (m *MsgRecvCleanPacketResponse) XXX_Size() int

func (*MsgRecvCleanPacketResponse) XXX_Unmarshal 

func (m *MsgRecvCleanPacketResponse) XXX_Unmarshal(b []byte) error

type MsgRecvPacket 

type MsgRecvPacket struct {
	Packet          Packet        `protobuf:"bytes,1,opt,name=packet,proto3" json:"packet"`
	ProofCommitment []byte        `` /* 130-byte string literal not displayed */
	ProofHeight     client.Height `protobuf:"bytes,3,opt,name=proof_height,json=proofHeight,proto3" json:"proof_height" yaml:"proof_height"`
	Signer          string        `protobuf:"bytes,4,opt,name=signer,proto3" json:"signer,omitempty"`
}

MsgRecvPacket receives incoming IBC packet

func (*MsgRecvPacket) Descriptor 

func (*MsgRecvPacket) Descriptor() ([]byte, []int)

func (MsgRecvPacket) GetSignBytes 

func (msg MsgRecvPacket) GetSignBytes() []byte

GetSignBytes implements sdk.Msg. The function will panic since it is used for amino transaction verification which TIBC does not support.

func (MsgRecvPacket) GetSigners 

func (msg MsgRecvPacket) GetSigners() []sdk.AccAddress

GetSigners implements sdk.Msg

func (*MsgRecvPacket) Marshal 

func (m *MsgRecvPacket) Marshal() (dAtA []byte, err error)

func (*MsgRecvPacket) MarshalTo 

func (m *MsgRecvPacket) MarshalTo(dAtA []byte) (int, error)

func (*MsgRecvPacket) MarshalToSizedBuffer 

func (m *MsgRecvPacket) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgRecvPacket) ProtoMessage 

func (*MsgRecvPacket) ProtoMessage()

func (*MsgRecvPacket) Reset 

func (m *MsgRecvPacket) Reset()

func (MsgRecvPacket) Route 

func (msg MsgRecvPacket) Route() string

Route implements sdk.Msg

func (*MsgRecvPacket) Size 

func (m *MsgRecvPacket) Size() (n int)

func (*MsgRecvPacket) String 

func (m *MsgRecvPacket) String() string

func (MsgRecvPacket) Type 

func (msg MsgRecvPacket) Type() string

Type implements sdk.Msg

func (*MsgRecvPacket) Unmarshal 

func (m *MsgRecvPacket) Unmarshal(dAtA []byte) error

func (MsgRecvPacket) ValidateBasic 

func (msg MsgRecvPacket) ValidateBasic() error

ValidateBasic implements sdk.Msg

func (*MsgRecvPacket) XXX_DiscardUnknown 

func (m *MsgRecvPacket) XXX_DiscardUnknown()

func (*MsgRecvPacket) XXX_Marshal 

func (m *MsgRecvPacket) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgRecvPacket) XXX_Merge 

func (m *MsgRecvPacket) XXX_Merge(src proto.Message)

func (*MsgRecvPacket) XXX_Size 

func (m *MsgRecvPacket) XXX_Size() int

func (*MsgRecvPacket) XXX_Unmarshal 

func (m *MsgRecvPacket) XXX_Unmarshal(b []byte) error

type MsgRecvPacketResponse 

type MsgRecvPacketResponse struct {
}

MsgRecvPacketResponse defines the Msg/RecvPacket response type.

func (*MsgRecvPacketResponse) Descriptor 

func (*MsgRecvPacketResponse) Descriptor() ([]byte, []int)

func (*MsgRecvPacketResponse) Marshal 

func (m *MsgRecvPacketResponse) Marshal() (dAtA []byte, err error)

func (*MsgRecvPacketResponse) MarshalTo 

func (m *MsgRecvPacketResponse) MarshalTo(dAtA []byte) (int, error)

func (*MsgRecvPacketResponse) MarshalToSizedBuffer 

func (m *MsgRecvPacketResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgRecvPacketResponse) ProtoMessage 

func (*MsgRecvPacketResponse) ProtoMessage()

func (*MsgRecvPacketResponse) Reset 

func (m *MsgRecvPacketResponse) Reset()

func (*MsgRecvPacketResponse) Size 

func (m *MsgRecvPacketResponse) Size() (n int)

func (*MsgRecvPacketResponse) String 

func (m *MsgRecvPacketResponse) String() string

func (*MsgRecvPacketResponse) Unmarshal 

func (m *MsgRecvPacketResponse) Unmarshal(dAtA []byte) error

func (*MsgRecvPacketResponse) XXX_DiscardUnknown 

func (m *MsgRecvPacketResponse) XXX_DiscardUnknown()

func (*MsgRecvPacketResponse) XXX_Marshal 

func (m *MsgRecvPacketResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgRecvPacketResponse) XXX_Merge 

func (m *MsgRecvPacketResponse) XXX_Merge(src proto.Message)

func (*MsgRecvPacketResponse) XXX_Size 

func (m *MsgRecvPacketResponse) XXX_Size() int

func (*MsgRecvPacketResponse) XXX_Unmarshal 

func (m *MsgRecvPacketResponse) XXX_Unmarshal(b []byte) error

type MsgServer 

type MsgServer interface {
	// RecvPacket defines a rpc handler method for MsgRecvPacket.
	RecvPacket(context.Context, *MsgRecvPacket) (*MsgRecvPacketResponse, error)
	// Acknowledgement defines a rpc handler method for MsgAcknowledgement.
	Acknowledgement(context.Context, *MsgAcknowledgement) (*MsgAcknowledgementResponse, error)
	// CleanPacket defines a rpc handler method for MsgCleanPacket.
	CleanPacket(context.Context, *MsgCleanPacket) (*MsgCleanPacketResponse, error)
	// RecvCleanPacket defines a rpc handler method for MsgRecvCleanPacket.
	RecvCleanPacket(context.Context, *MsgRecvCleanPacket) (*MsgRecvCleanPacketResponse, error)
}

MsgServer is the server API for Msg service.

type Packet 

type Packet struct {
	// number corresponds to the order of sends and receives, where a Packet
	// with an earlier sequence number must be sent and received before a Packet
	// with a later sequence number.
	Sequence uint64 `protobuf:"varint,1,opt,name=sequence,proto3" json:"sequence,omitempty"`
	// identifies the port on the sending chain and destination chain.
	Port string `protobuf:"bytes,2,opt,name=port,proto3" json:"port,omitempty"`
	// identifies the chain id of the sending chain.
	SourceChain string `protobuf:"bytes,3,opt,name=source_chain,json=sourceChain,proto3" json:"source_chain,omitempty" yaml:"source_chain"`
	// identifies the chain id of the receiving chain.
	DestinationChain string `` /* 133-byte string literal not displayed */
	// identifies the chain id of the relay chain.
	RelayChain string `protobuf:"bytes,5,opt,name=relay_chain,json=relayChain,proto3" json:"relay_chain,omitempty" yaml:"relay_chain"`
	// actual opaque bytes transferred directly to the application module
	Data []byte `protobuf:"bytes,6,opt,name=data,proto3" json:"data,omitempty"`
}

Packet defines a type that carries data across different chains through IBC

func NewPacket 

func NewPacket(
	data []byte,
	sequence uint64, sourceChain, destinationChain, relayChain,
	port string,
) Packet

NewPacket creates a new Packet instance. It panics if the provided packet data interface is not registered.

func (*Packet) Descriptor 

func (*Packet) Descriptor() ([]byte, []int)

func (Packet) GetData 

func (p Packet) GetData() []byte

GetData implements PacketI interface

func (Packet) GetDestChain 

func (p Packet) GetDestChain() string

GetDestinationChain implements PacketI interface

func (Packet) GetPort 

func (p Packet) GetPort() string

GetPort implements PacketI interface

func (Packet) GetRelayChain 

func (p Packet) GetRelayChain() string

GetRelayChain implements PacketI interface

func (Packet) GetSequence 

func (p Packet) GetSequence() uint64

GetSequence implements PacketI interface

func (Packet) GetSourceChain 

func (p Packet) GetSourceChain() string

GetSourceChain implements PacketI interface

func (*Packet) Marshal 

func (m *Packet) Marshal() (dAtA []byte, err error)

func (*Packet) MarshalTo 

func (m *Packet) MarshalTo(dAtA []byte) (int, error)

func (*Packet) MarshalToSizedBuffer 

func (m *Packet) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Packet) ProtoMessage 

func (*Packet) ProtoMessage()

func (*Packet) Reset 

func (m *Packet) Reset()

func (*Packet) Size 

func (m *Packet) Size() (n int)

func (*Packet) String 

func (m *Packet) String() string

func (*Packet) Unmarshal 

func (m *Packet) Unmarshal(dAtA []byte) error

func (Packet) ValidateBasic 

func (p Packet) ValidateBasic() error

ValidateBasic implements PacketI interface

func (*Packet) XXX_DiscardUnknown 

func (m *Packet) XXX_DiscardUnknown()

func (*Packet) XXX_Marshal 

func (m *Packet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Packet) XXX_Merge 

func (m *Packet) XXX_Merge(src proto.Message)

func (*Packet) XXX_Size 

func (m *Packet) XXX_Size() int

func (*Packet) XXX_Unmarshal 

func (m *Packet) XXX_Unmarshal(b []byte) error

type PacketSequence 

type PacketSequence struct {
	SourceChain      string `protobuf:"bytes,1,opt,name=source_chain,json=sourceChain,proto3" json:"source_chain,omitempty" yaml:"source_chain"`
	DestinationChain string `` /* 134-byte string literal not displayed */
	Sequence         uint64 `protobuf:"varint,3,opt,name=sequence,proto3" json:"sequence,omitempty"`
}

PacketSequence defines the genesis type necessary to retrieve and store next send and receive sequences.

func (*PacketSequence) Descriptor 

func (*PacketSequence) Descriptor() ([]byte, []int)

func (*PacketSequence) GetDestinationChain 

func (m *PacketSequence) GetDestinationChain() string

func (*PacketSequence) GetSequence 

func (m *PacketSequence) GetSequence() uint64

func (*PacketSequence) GetSourceChain 

func (m *PacketSequence) GetSourceChain() string

func (*PacketSequence) Marshal 

func (m *PacketSequence) Marshal() (dAtA []byte, err error)

func (*PacketSequence) MarshalTo 

func (m *PacketSequence) MarshalTo(dAtA []byte) (int, error)

func (*PacketSequence) MarshalToSizedBuffer 

func (m *PacketSequence) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PacketSequence) ProtoMessage 

func (*PacketSequence) ProtoMessage()

func (*PacketSequence) Reset 

func (m *PacketSequence) Reset()

func (*PacketSequence) Size 

func (m *PacketSequence) Size() (n int)

func (*PacketSequence) String 

func (m *PacketSequence) String() string

func (*PacketSequence) Unmarshal 

func (m *PacketSequence) Unmarshal(dAtA []byte) error

func (*PacketSequence) XXX_DiscardUnknown 

func (m *PacketSequence) XXX_DiscardUnknown()

func (*PacketSequence) XXX_Marshal 

func (m *PacketSequence) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PacketSequence) XXX_Merge 

func (m *PacketSequence) XXX_Merge(src proto.Message)

func (*PacketSequence) XXX_Size 

func (m *PacketSequence) XXX_Size() int

func (*PacketSequence) XXX_Unmarshal 

func (m *PacketSequence) XXX_Unmarshal(b []byte) error

type PacketState 

type PacketState struct {
	// the sending chain identifier.
	SourceChain string `protobuf:"bytes,1,opt,name=source_chain,json=sourceChain,proto3" json:"source_chain,omitempty" yaml:"source_chain"`
	// the receiving chain identifier.
	DestinationChain string `` /* 129-byte string literal not displayed */
	// packet sequence.
	Sequence uint64 `protobuf:"varint,3,opt,name=sequence,proto3" json:"sequence,omitempty"`
	// embedded data that represents packet state.
	Data []byte `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
}

PacketState defines the generic type necessary to retrieve and store packet commitments, acknowledgements, and receipts. Caller is responsible for knowing the context necessary to interpret this state as a commitment, acknowledgement, or a receipt.

func (*PacketState) Descriptor 

func (*PacketState) Descriptor() ([]byte, []int)

func (*PacketState) Marshal 

func (m *PacketState) Marshal() (dAtA []byte, err error)

func (*PacketState) MarshalTo 

func (m *PacketState) MarshalTo(dAtA []byte) (int, error)

func (*PacketState) MarshalToSizedBuffer 

func (m *PacketState) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PacketState) ProtoMessage 

func (*PacketState) ProtoMessage()

func (*PacketState) Reset 

func (m *PacketState) Reset()

func (*PacketState) Size 

func (m *PacketState) Size() (n int)

func (*PacketState) String 

func (m *PacketState) String() string

func (*PacketState) Unmarshal 

func (m *PacketState) Unmarshal(dAtA []byte) error

func (*PacketState) XXX_DiscardUnknown 

func (m *PacketState) XXX_DiscardUnknown()

func (*PacketState) XXX_Marshal 

func (m *PacketState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PacketState) XXX_Merge 

func (m *PacketState) XXX_Merge(src proto.Message)

func (*PacketState) XXX_Size 

func (m *PacketState) XXX_Size() int

func (*PacketState) XXX_Unmarshal 

func (m *PacketState) XXX_Unmarshal(b []byte) error

type QueryCleanPacketCommitmentRequest 

type QueryCleanPacketCommitmentRequest struct {
	// dest chain name
	DestChain string `protobuf:"bytes,1,opt,name=dest_chain,json=destChain,proto3" json:"dest_chain,omitempty"`
	// source chain name
	SourceChain string `protobuf:"bytes,2,opt,name=source_chain,json=sourceChain,proto3" json:"source_chain,omitempty"`
}

QueryCleanPacketCommitmentRequest is the request type for the QueryCleanPacketCommitment RPC method

func (*QueryCleanPacketCommitmentRequest) Descriptor 

func (*QueryCleanPacketCommitmentRequest) Descriptor() ([]byte, []int)

func (*QueryCleanPacketCommitmentRequest) GetDestChain 

func (m *QueryCleanPacketCommitmentRequest) GetDestChain() string

func (*QueryCleanPacketCommitmentRequest) GetSourceChain 

func (m *QueryCleanPacketCommitmentRequest) GetSourceChain() string

func (*QueryCleanPacketCommitmentRequest) Marshal 

func (m *QueryCleanPacketCommitmentRequest) Marshal() (dAtA []byte, err error)

func (*QueryCleanPacketCommitmentRequest) MarshalTo 

func (m *QueryCleanPacketCommitmentRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryCleanPacketCommitmentRequest) MarshalToSizedBuffer 

func (m *QueryCleanPacketCommitmentRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryCleanPacketCommitmentRequest) ProtoMessage 

func (*QueryCleanPacketCommitmentRequest) ProtoMessage()

func (*QueryCleanPacketCommitmentRequest) Reset 

func (m *QueryCleanPacketCommitmentRequest) Reset()

func (*QueryCleanPacketCommitmentRequest) Size 

func (m *QueryCleanPacketCommitmentRequest) Size() (n int)

func (*QueryCleanPacketCommitmentRequest) String 

func (m *QueryCleanPacketCommitmentRequest) String() string

func (*QueryCleanPacketCommitmentRequest) Unmarshal 

func (m *QueryCleanPacketCommitmentRequest) Unmarshal(dAtA []byte) error

func (*QueryCleanPacketCommitmentRequest) XXX_DiscardUnknown 

func (m *QueryCleanPacketCommitmentRequest) XXX_DiscardUnknown()

func (*QueryCleanPacketCommitmentRequest) XXX_Marshal 

func (m *QueryCleanPacketCommitmentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryCleanPacketCommitmentRequest) XXX_Merge 

func (m *QueryCleanPacketCommitmentRequest) XXX_Merge(src proto.Message)

func (*QueryCleanPacketCommitmentRequest) XXX_Size 

func (m *QueryCleanPacketCommitmentRequest) XXX_Size() int

func (*QueryCleanPacketCommitmentRequest) XXX_Unmarshal 

func (m *QueryCleanPacketCommitmentRequest) XXX_Unmarshal(b []byte) error

type QueryCleanPacketCommitmentResponse 

type QueryCleanPacketCommitmentResponse 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"`
	// height at which the proof was retrieved
	ProofHeight client.Height `protobuf:"bytes,3,opt,name=proof_height,json=proofHeight,proto3" json:"proof_height"`
}

QueryCleanPacketCommitmentResponse defines the client query response for a packet which also includes a proof and the height from which the proof was retrieved

func (*QueryCleanPacketCommitmentResponse) Descriptor 

func (*QueryCleanPacketCommitmentResponse) Descriptor() ([]byte, []int)

func (*QueryCleanPacketCommitmentResponse) GetCommitment 

func (m *QueryCleanPacketCommitmentResponse) GetCommitment() []byte

func (*QueryCleanPacketCommitmentResponse) GetProof 

func (m *QueryCleanPacketCommitmentResponse) GetProof() []byte

func (*QueryCleanPacketCommitmentResponse) GetProofHeight 

func (m *QueryCleanPacketCommitmentResponse) GetProofHeight() client.Height

func (*QueryCleanPacketCommitmentResponse) Marshal 

func (m *QueryCleanPacketCommitmentResponse) Marshal() (dAtA []byte, err error)

func (*QueryCleanPacketCommitmentResponse) MarshalTo 

func (m *QueryCleanPacketCommitmentResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryCleanPacketCommitmentResponse) MarshalToSizedBuffer 

func (m *QueryCleanPacketCommitmentResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryCleanPacketCommitmentResponse) ProtoMessage 

func (*QueryCleanPacketCommitmentResponse) ProtoMessage()

func (*QueryCleanPacketCommitmentResponse) Reset 

func (m *QueryCleanPacketCommitmentResponse) Reset()

func (*QueryCleanPacketCommitmentResponse) Size 

func (m *QueryCleanPacketCommitmentResponse) Size() (n int)

func (*QueryCleanPacketCommitmentResponse) String 

func (m *QueryCleanPacketCommitmentResponse) String() string

func (*QueryCleanPacketCommitmentResponse) Unmarshal 

func (m *QueryCleanPacketCommitmentResponse) Unmarshal(dAtA []byte) error

func (*QueryCleanPacketCommitmentResponse) XXX_DiscardUnknown 

func (m *QueryCleanPacketCommitmentResponse) XXX_DiscardUnknown()

func (*QueryCleanPacketCommitmentResponse) XXX_Marshal 

func (m *QueryCleanPacketCommitmentResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryCleanPacketCommitmentResponse) XXX_Merge 

func (m *QueryCleanPacketCommitmentResponse) XXX_Merge(src proto.Message)

func (*QueryCleanPacketCommitmentResponse) XXX_Size 

func (m *QueryCleanPacketCommitmentResponse) XXX_Size() int

func (*QueryCleanPacketCommitmentResponse) XXX_Unmarshal 

func (m *QueryCleanPacketCommitmentResponse) XXX_Unmarshal(b []byte) error

type QueryClient 

type QueryClient interface {
	// PacketCommitment queries a stored packet commitment hash.
	PacketCommitment(ctx context.Context, in *QueryPacketCommitmentRequest, opts ...grpc.CallOption) (*QueryPacketCommitmentResponse, error)
	// PacketCommitments returns all the packet commitments hashes associated
	PacketCommitments(ctx context.Context, in *QueryPacketCommitmentsRequest, opts ...grpc.CallOption) (*QueryPacketCommitmentsResponse, error)
	// PacketReceipt queries if a given packet sequence has been received on the queried chain
	PacketReceipt(ctx context.Context, in *QueryPacketReceiptRequest, opts ...grpc.CallOption) (*QueryPacketReceiptResponse, error)
	// PacketAcknowledgement queries a stored packet acknowledgement hash.
	PacketAcknowledgement(ctx context.Context, in *QueryPacketAcknowledgementRequest, opts ...grpc.CallOption) (*QueryPacketAcknowledgementResponse, error)
	// PacketAcknowledgements returns all the packet acknowledgements associated
	PacketAcknowledgements(ctx context.Context, in *QueryPacketAcknowledgementsRequest, opts ...grpc.CallOption) (*QueryPacketAcknowledgementsResponse, error)
	// UnreceivedPackets returns all the unreceived TIBC packets associated with sequences.
	UnreceivedPackets(ctx context.Context, in *QueryUnreceivedPacketsRequest, opts ...grpc.CallOption) (*QueryUnreceivedPacketsResponse, error)
	// UnreceivedAcks returns all the unreceived TIBC acknowledgements associated with sequences.
	UnreceivedAcks(ctx context.Context, in *QueryUnreceivedAcksRequest, opts ...grpc.CallOption) (*QueryUnreceivedAcksResponse, error)
	// CleanPacketCommitment queries a stored packet commitment hash.
	CleanPacketCommitment(ctx context.Context, in *QueryCleanPacketCommitmentRequest, opts ...grpc.CallOption) (*QueryCleanPacketCommitmentResponse, error)
}

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.

func NewQueryClient 

func NewQueryClient(cc grpc1.ClientConn) QueryClient

type QueryPacketAcknowledgementRequest 

type QueryPacketAcknowledgementRequest struct {
	// dest chain name
	DestChain string `protobuf:"bytes,1,opt,name=dest_chain,json=destChain,proto3" json:"dest_chain,omitempty"`
	// source chain name
	SourceChain string `protobuf:"bytes,2,opt,name=source_chain,json=sourceChain,proto3" json:"source_chain,omitempty"`
	// packet sequence
	Sequence uint64 `protobuf:"varint,3,opt,name=sequence,proto3" json:"sequence,omitempty"`
}

QueryPacketAcknowledgementRequest is the request type for the Query/PacketAcknowledgement RPC method

func (*QueryPacketAcknowledgementRequest) Descriptor 

func (*QueryPacketAcknowledgementRequest) Descriptor() ([]byte, []int)

func (*QueryPacketAcknowledgementRequest) GetDestChain 

func (m *QueryPacketAcknowledgementRequest) GetDestChain() string

func (*QueryPacketAcknowledgementRequest) GetSequence 

func (m *QueryPacketAcknowledgementRequest) GetSequence() uint64

func (*QueryPacketAcknowledgementRequest) GetSourceChain 

func (m *QueryPacketAcknowledgementRequest) GetSourceChain() string

func (*QueryPacketAcknowledgementRequest) Marshal 

func (m *QueryPacketAcknowledgementRequest) Marshal() (dAtA []byte, err error)

func (*QueryPacketAcknowledgementRequest) MarshalTo 

func (m *QueryPacketAcknowledgementRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryPacketAcknowledgementRequest) MarshalToSizedBuffer 

func (m *QueryPacketAcknowledgementRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryPacketAcknowledgementRequest) ProtoMessage 

func (*QueryPacketAcknowledgementRequest) ProtoMessage()

func (*QueryPacketAcknowledgementRequest) Reset 

func (m *QueryPacketAcknowledgementRequest) Reset()

func (*QueryPacketAcknowledgementRequest) Size 

func (m *QueryPacketAcknowledgementRequest) Size() (n int)

func (*QueryPacketAcknowledgementRequest) String 

func (m *QueryPacketAcknowledgementRequest) String() string

func (*QueryPacketAcknowledgementRequest) Unmarshal 

func (m *QueryPacketAcknowledgementRequest) Unmarshal(dAtA []byte) error

func (*QueryPacketAcknowledgementRequest) XXX_DiscardUnknown 

func (m *QueryPacketAcknowledgementRequest) XXX_DiscardUnknown()

func (*QueryPacketAcknowledgementRequest) XXX_Marshal 

func (m *QueryPacketAcknowledgementRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryPacketAcknowledgementRequest) XXX_Merge 

func (m *QueryPacketAcknowledgementRequest) XXX_Merge(src proto.Message)

func (*QueryPacketAcknowledgementRequest) XXX_Size 

func (m *QueryPacketAcknowledgementRequest) XXX_Size() int

func (*QueryPacketAcknowledgementRequest) XXX_Unmarshal 

func (m *QueryPacketAcknowledgementRequest) XXX_Unmarshal(b []byte) error

type QueryPacketAcknowledgementResponse 

type QueryPacketAcknowledgementResponse struct {
	// packet associated with the request fields
	Acknowledgement []byte `protobuf:"bytes,1,opt,name=acknowledgement,proto3" json:"acknowledgement,omitempty"`
	// merkle proof of existence
	Proof []byte `protobuf:"bytes,2,opt,name=proof,proto3" json:"proof,omitempty"`
	// height at which the proof was retrieved
	ProofHeight client.Height `protobuf:"bytes,3,opt,name=proof_height,json=proofHeight,proto3" json:"proof_height"`
}

QueryPacketAcknowledgementResponse defines the client query response for a packet which also includes a proof and the height from which the proof was retrieved

func (*QueryPacketAcknowledgementResponse) Descriptor 

func (*QueryPacketAcknowledgementResponse) Descriptor() ([]byte, []int)

func (*QueryPacketAcknowledgementResponse) GetAcknowledgement 

func (m *QueryPacketAcknowledgementResponse) GetAcknowledgement() []byte

func (*QueryPacketAcknowledgementResponse) GetProof 

func (m *QueryPacketAcknowledgementResponse) GetProof() []byte

func (*QueryPacketAcknowledgementResponse) GetProofHeight 

func (m *QueryPacketAcknowledgementResponse) GetProofHeight() client.Height

func (*QueryPacketAcknowledgementResponse) Marshal 

func (m *QueryPacketAcknowledgementResponse) Marshal() (dAtA []byte, err error)

func (*QueryPacketAcknowledgementResponse) MarshalTo 

func (m *QueryPacketAcknowledgementResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryPacketAcknowledgementResponse) MarshalToSizedBuffer 

func (m *QueryPacketAcknowledgementResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryPacketAcknowledgementResponse) ProtoMessage 

func (*QueryPacketAcknowledgementResponse) ProtoMessage()

func (*QueryPacketAcknowledgementResponse) Reset 

func (m *QueryPacketAcknowledgementResponse) Reset()

func (*QueryPacketAcknowledgementResponse) Size 

func (m *QueryPacketAcknowledgementResponse) Size() (n int)

func (*QueryPacketAcknowledgementResponse) String 

func (m *QueryPacketAcknowledgementResponse) String() string

func (*QueryPacketAcknowledgementResponse) Unmarshal 

func (m *QueryPacketAcknowledgementResponse) Unmarshal(dAtA []byte) error

func (*QueryPacketAcknowledgementResponse) XXX_DiscardUnknown 

func (m *QueryPacketAcknowledgementResponse) XXX_DiscardUnknown()

func (*QueryPacketAcknowledgementResponse) XXX_Marshal 

func (m *QueryPacketAcknowledgementResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryPacketAcknowledgementResponse) XXX_Merge 

func (m *QueryPacketAcknowledgementResponse) XXX_Merge(src proto.Message)

func (*QueryPacketAcknowledgementResponse) XXX_Size 

func (m *QueryPacketAcknowledgementResponse) XXX_Size() int

func (*QueryPacketAcknowledgementResponse) XXX_Unmarshal 

func (m *QueryPacketAcknowledgementResponse) XXX_Unmarshal(b []byte) error

type QueryPacketAcknowledgementsRequest 

type QueryPacketAcknowledgementsRequest struct {
	// dest chain name
	DestChain string `protobuf:"bytes,1,opt,name=dest_chain,json=destChain,proto3" json:"dest_chain,omitempty"`
	// source chain name
	SourceChain string `protobuf:"bytes,2,opt,name=source_chain,json=sourceChain,proto3" json:"source_chain,omitempty"`
	// pagination request
	Pagination *query.PageRequest `protobuf:"bytes,3,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryPacketAcknowledgementsRequest is the request type for the Query/QueryPacketCommitments RPC method

func (*QueryPacketAcknowledgementsRequest) Descriptor 

func (*QueryPacketAcknowledgementsRequest) Descriptor() ([]byte, []int)

func (*QueryPacketAcknowledgementsRequest) GetDestChain 

func (m *QueryPacketAcknowledgementsRequest) GetDestChain() string

func (*QueryPacketAcknowledgementsRequest) GetPagination 

func (m *QueryPacketAcknowledgementsRequest) GetPagination() *query.PageRequest

func (*QueryPacketAcknowledgementsRequest) GetSourceChain 

func (m *QueryPacketAcknowledgementsRequest) GetSourceChain() string

func (*QueryPacketAcknowledgementsRequest) Marshal 

func (m *QueryPacketAcknowledgementsRequest) Marshal() (dAtA []byte, err error)

func (*QueryPacketAcknowledgementsRequest) MarshalTo 

func (m *QueryPacketAcknowledgementsRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryPacketAcknowledgementsRequest) MarshalToSizedBuffer 

func (m *QueryPacketAcknowledgementsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryPacketAcknowledgementsRequest) ProtoMessage 

func (*QueryPacketAcknowledgementsRequest) ProtoMessage()

func (*QueryPacketAcknowledgementsRequest) Reset 

func (m *QueryPacketAcknowledgementsRequest) Reset()

func (*QueryPacketAcknowledgementsRequest) Size 

func (m *QueryPacketAcknowledgementsRequest) Size() (n int)

func (*QueryPacketAcknowledgementsRequest) String 

func (m *QueryPacketAcknowledgementsRequest) String() string

func (*QueryPacketAcknowledgementsRequest) Unmarshal 

func (m *QueryPacketAcknowledgementsRequest) Unmarshal(dAtA []byte) error

func (*QueryPacketAcknowledgementsRequest) XXX_DiscardUnknown 

func (m *QueryPacketAcknowledgementsRequest) XXX_DiscardUnknown()

func (*QueryPacketAcknowledgementsRequest) XXX_Marshal 

func (m *QueryPacketAcknowledgementsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryPacketAcknowledgementsRequest) XXX_Merge 

func (m *QueryPacketAcknowledgementsRequest) XXX_Merge(src proto.Message)

func (*QueryPacketAcknowledgementsRequest) XXX_Size 

func (m *QueryPacketAcknowledgementsRequest) XXX_Size() int

func (*QueryPacketAcknowledgementsRequest) XXX_Unmarshal 

func (m *QueryPacketAcknowledgementsRequest) XXX_Unmarshal(b []byte) error

type QueryPacketAcknowledgementsResponse 

type QueryPacketAcknowledgementsResponse struct {
	Acknowledgements []*PacketState `protobuf:"bytes,1,rep,name=acknowledgements,proto3" json:"acknowledgements,omitempty"`
	// pagination response
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// query block height
	Height client.Height `protobuf:"bytes,3,opt,name=height,proto3" json:"height"`
}

QueryPacketAcknowledgemetsResponse is the request type for the Query/QueryPacketAcknowledgements RPC method

func (*QueryPacketAcknowledgementsResponse) Descriptor 

func (*QueryPacketAcknowledgementsResponse) Descriptor() ([]byte, []int)

func (*QueryPacketAcknowledgementsResponse) GetAcknowledgements 

func (m *QueryPacketAcknowledgementsResponse) GetAcknowledgements() []*PacketState

func (*QueryPacketAcknowledgementsResponse) GetHeight 

func (m *QueryPacketAcknowledgementsResponse) GetHeight() client.Height

func (*QueryPacketAcknowledgementsResponse) GetPagination 

func (m *QueryPacketAcknowledgementsResponse) GetPagination() *query.PageResponse

func (*QueryPacketAcknowledgementsResponse) Marshal 

func (m *QueryPacketAcknowledgementsResponse) Marshal() (dAtA []byte, err error)

func (*QueryPacketAcknowledgementsResponse) MarshalTo 

func (m *QueryPacketAcknowledgementsResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryPacketAcknowledgementsResponse) MarshalToSizedBuffer 

func (m *QueryPacketAcknowledgementsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryPacketAcknowledgementsResponse) ProtoMessage 

func (*QueryPacketAcknowledgementsResponse) ProtoMessage()

func (*QueryPacketAcknowledgementsResponse) Reset 

func (m *QueryPacketAcknowledgementsResponse) Reset()

func (*QueryPacketAcknowledgementsResponse) Size 

func (m *QueryPacketAcknowledgementsResponse) Size() (n int)

func (*QueryPacketAcknowledgementsResponse) String 

func (m *QueryPacketAcknowledgementsResponse) String() string

func (*QueryPacketAcknowledgementsResponse) Unmarshal 

func (m *QueryPacketAcknowledgementsResponse) Unmarshal(dAtA []byte) error

func (*QueryPacketAcknowledgementsResponse) XXX_DiscardUnknown 

func (m *QueryPacketAcknowledgementsResponse) XXX_DiscardUnknown()

func (*QueryPacketAcknowledgementsResponse) XXX_Marshal 

func (m *QueryPacketAcknowledgementsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryPacketAcknowledgementsResponse) XXX_Merge 

func (m *QueryPacketAcknowledgementsResponse) XXX_Merge(src proto.Message)

func (*QueryPacketAcknowledgementsResponse) XXX_Size 

func (m *QueryPacketAcknowledgementsResponse) XXX_Size() int

func (*QueryPacketAcknowledgementsResponse) XXX_Unmarshal 

func (m *QueryPacketAcknowledgementsResponse) XXX_Unmarshal(b []byte) error

type QueryPacketCommitmentRequest 

type QueryPacketCommitmentRequest struct {
	// dest chain name
	DestChain string `protobuf:"bytes,1,opt,name=dest_chain,json=destChain,proto3" json:"dest_chain,omitempty"`
	// source chain name
	SourceChain string `protobuf:"bytes,2,opt,name=source_chain,json=sourceChain,proto3" json:"source_chain,omitempty"`
	// packet sequence
	Sequence uint64 `protobuf:"varint,3,opt,name=sequence,proto3" json:"sequence,omitempty"`
}

QueryPacketCommitmentRequest is the request type for the QueryPacketCommitment RPC method

func (*QueryPacketCommitmentRequest) Descriptor 

func (*QueryPacketCommitmentRequest) Descriptor() ([]byte, []int)

func (*QueryPacketCommitmentRequest) GetDestChain 

func (m *QueryPacketCommitmentRequest) GetDestChain() string

func (*QueryPacketCommitmentRequest) GetSequence 

func (m *QueryPacketCommitmentRequest) GetSequence() uint64

func (*QueryPacketCommitmentRequest) GetSourceChain 

func (m *QueryPacketCommitmentRequest) GetSourceChain() string

func (*QueryPacketCommitmentRequest) Marshal 

func (m *QueryPacketCommitmentRequest) Marshal() (dAtA []byte, err error)

func (*QueryPacketCommitmentRequest) MarshalTo 

func (m *QueryPacketCommitmentRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryPacketCommitmentRequest) MarshalToSizedBuffer 

func (m *QueryPacketCommitmentRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryPacketCommitmentRequest) ProtoMessage 

func (*QueryPacketCommitmentRequest) ProtoMessage()

func (*QueryPacketCommitmentRequest) Reset 

func (m *QueryPacketCommitmentRequest) Reset()

func (*QueryPacketCommitmentRequest) Size 

func (m *QueryPacketCommitmentRequest) Size() (n int)

func (*QueryPacketCommitmentRequest) String 

func (m *QueryPacketCommitmentRequest) String() string

func (*QueryPacketCommitmentRequest) Unmarshal 

func (m *QueryPacketCommitmentRequest) Unmarshal(dAtA []byte) error

func (*QueryPacketCommitmentRequest) XXX_DiscardUnknown 

func (m *QueryPacketCommitmentRequest) XXX_DiscardUnknown()

func (*QueryPacketCommitmentRequest) XXX_Marshal 

func (m *QueryPacketCommitmentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryPacketCommitmentRequest) XXX_Merge 

func (m *QueryPacketCommitmentRequest) XXX_Merge(src proto.Message)

func (*QueryPacketCommitmentRequest) XXX_Size 

func (m *QueryPacketCommitmentRequest) XXX_Size() int

func (*QueryPacketCommitmentRequest) XXX_Unmarshal 

func (m *QueryPacketCommitmentRequest) XXX_Unmarshal(b []byte) error

type QueryPacketCommitmentResponse 

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"`
	// height at which the proof was retrieved
	ProofHeight client.Height `protobuf:"bytes,3,opt,name=proof_height,json=proofHeight,proto3" json:"proof_height"`
}

QueryPacketCommitmentResponse defines the client query response for a packet which also includes a proof and the height from which the proof was retrieved

func (*QueryPacketCommitmentResponse) Descriptor 

func (*QueryPacketCommitmentResponse) Descriptor() ([]byte, []int)

func (*QueryPacketCommitmentResponse) GetCommitment 

func (m *QueryPacketCommitmentResponse) GetCommitment() []byte

func (*QueryPacketCommitmentResponse) GetProof 

func (m *QueryPacketCommitmentResponse) GetProof() []byte

func (*QueryPacketCommitmentResponse) GetProofHeight 

func (m *QueryPacketCommitmentResponse) GetProofHeight() client.Height

func (*QueryPacketCommitmentResponse) Marshal 

func (m *QueryPacketCommitmentResponse) Marshal() (dAtA []byte, err error)

func (*QueryPacketCommitmentResponse) MarshalTo 

func (m *QueryPacketCommitmentResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryPacketCommitmentResponse) MarshalToSizedBuffer 

func (m *QueryPacketCommitmentResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryPacketCommitmentResponse) ProtoMessage 

func (*QueryPacketCommitmentResponse) ProtoMessage()

func (*QueryPacketCommitmentResponse) Reset 

func (m *QueryPacketCommitmentResponse) Reset()

func (*QueryPacketCommitmentResponse) Size 

func (m *QueryPacketCommitmentResponse) Size() (n int)

func (*QueryPacketCommitmentResponse) String 

func (m *QueryPacketCommitmentResponse) String() string

func (*QueryPacketCommitmentResponse) Unmarshal 

func (m *QueryPacketCommitmentResponse) Unmarshal(dAtA []byte) error

func (*QueryPacketCommitmentResponse) XXX_DiscardUnknown 

func (m *QueryPacketCommitmentResponse) XXX_DiscardUnknown()

func (*QueryPacketCommitmentResponse) XXX_Marshal 

func (m *QueryPacketCommitmentResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryPacketCommitmentResponse) XXX_Merge 

func (m *QueryPacketCommitmentResponse) XXX_Merge(src proto.Message)

func (*QueryPacketCommitmentResponse) XXX_Size 

func (m *QueryPacketCommitmentResponse) XXX_Size() int

func (*QueryPacketCommitmentResponse) XXX_Unmarshal 

func (m *QueryPacketCommitmentResponse) XXX_Unmarshal(b []byte) error

type QueryPacketCommitmentsRequest 

type QueryPacketCommitmentsRequest struct {
	// dest chain name
	DestChain string `protobuf:"bytes,1,opt,name=dest_chain,json=destChain,proto3" json:"dest_chain,omitempty"`
	// source chain name
	SourceChain string `protobuf:"bytes,2,opt,name=source_chain,json=sourceChain,proto3" json:"source_chain,omitempty"`
	// pagination request
	Pagination *query.PageRequest `protobuf:"bytes,3,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryPacketCommitmentsRequest is the request type for the Query/QueryPacketCommitments RPC method

func (*QueryPacketCommitmentsRequest) Descriptor 

func (*QueryPacketCommitmentsRequest) Descriptor() ([]byte, []int)

func (*QueryPacketCommitmentsRequest) GetDestChain 

func (m *QueryPacketCommitmentsRequest) GetDestChain() string

func (*QueryPacketCommitmentsRequest) GetPagination 

func (m *QueryPacketCommitmentsRequest) GetPagination() *query.PageRequest

func (*QueryPacketCommitmentsRequest) GetSourceChain 

func (m *QueryPacketCommitmentsRequest) GetSourceChain() string

func (*QueryPacketCommitmentsRequest) Marshal 

func (m *QueryPacketCommitmentsRequest) Marshal() (dAtA []byte, err error)

func (*QueryPacketCommitmentsRequest) MarshalTo 

func (m *QueryPacketCommitmentsRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryPacketCommitmentsRequest) MarshalToSizedBuffer 

func (m *QueryPacketCommitmentsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryPacketCommitmentsRequest) ProtoMessage 

func (*QueryPacketCommitmentsRequest) ProtoMessage()

func (*QueryPacketCommitmentsRequest) Reset 

func (m *QueryPacketCommitmentsRequest) Reset()

func (*QueryPacketCommitmentsRequest) Size 

func (m *QueryPacketCommitmentsRequest) Size() (n int)

func (*QueryPacketCommitmentsRequest) String 

func (m *QueryPacketCommitmentsRequest) String() string

func (*QueryPacketCommitmentsRequest) Unmarshal 

func (m *QueryPacketCommitmentsRequest) Unmarshal(dAtA []byte) error

func (*QueryPacketCommitmentsRequest) XXX_DiscardUnknown 

func (m *QueryPacketCommitmentsRequest) XXX_DiscardUnknown()

func (*QueryPacketCommitmentsRequest) XXX_Marshal 

func (m *QueryPacketCommitmentsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryPacketCommitmentsRequest) XXX_Merge 

func (m *QueryPacketCommitmentsRequest) XXX_Merge(src proto.Message)

func (*QueryPacketCommitmentsRequest) XXX_Size 

func (m *QueryPacketCommitmentsRequest) XXX_Size() int

func (*QueryPacketCommitmentsRequest) XXX_Unmarshal 

func (m *QueryPacketCommitmentsRequest) XXX_Unmarshal(b []byte) error

type QueryPacketCommitmentsResponse 

type QueryPacketCommitmentsResponse struct {
	Commitments []*PacketState `protobuf:"bytes,1,rep,name=commitments,proto3" json:"commitments,omitempty"`
	// pagination response
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// query block height
	Height client.Height `protobuf:"bytes,3,opt,name=height,proto3" json:"height"`
}

QueryPacketCommitmentsResponse is the request type for the Query/QueryPacketCommitments RPC method

func (*QueryPacketCommitmentsResponse) Descriptor 

func (*QueryPacketCommitmentsResponse) Descriptor() ([]byte, []int)

func (*QueryPacketCommitmentsResponse) GetCommitments 

func (m *QueryPacketCommitmentsResponse) GetCommitments() []*PacketState

func (*QueryPacketCommitmentsResponse) GetHeight 

func (m *QueryPacketCommitmentsResponse) GetHeight() client.Height

func (*QueryPacketCommitmentsResponse) GetPagination 

func (m *QueryPacketCommitmentsResponse) GetPagination() *query.PageResponse

func (*QueryPacketCommitmentsResponse) Marshal 

func (m *QueryPacketCommitmentsResponse) Marshal() (dAtA []byte, err error)

func (*QueryPacketCommitmentsResponse) MarshalTo 

func (m *QueryPacketCommitmentsResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryPacketCommitmentsResponse) MarshalToSizedBuffer 

func (m *QueryPacketCommitmentsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryPacketCommitmentsResponse) ProtoMessage 

func (*QueryPacketCommitmentsResponse) ProtoMessage()

func (*QueryPacketCommitmentsResponse) Reset 

func (m *QueryPacketCommitmentsResponse) Reset()

func (*QueryPacketCommitmentsResponse) Size 

func (m *QueryPacketCommitmentsResponse) Size() (n int)

func (*QueryPacketCommitmentsResponse) String 

func (m *QueryPacketCommitmentsResponse) String() string

func (*QueryPacketCommitmentsResponse) Unmarshal 

func (m *QueryPacketCommitmentsResponse) Unmarshal(dAtA []byte) error

func (*QueryPacketCommitmentsResponse) XXX_DiscardUnknown 

func (m *QueryPacketCommitmentsResponse) XXX_DiscardUnknown()

func (*QueryPacketCommitmentsResponse) XXX_Marshal 

func (m *QueryPacketCommitmentsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryPacketCommitmentsResponse) XXX_Merge 

func (m *QueryPacketCommitmentsResponse) XXX_Merge(src proto.Message)

func (*QueryPacketCommitmentsResponse) XXX_Size 

func (m *QueryPacketCommitmentsResponse) XXX_Size() int

func (*QueryPacketCommitmentsResponse) XXX_Unmarshal 

func (m *QueryPacketCommitmentsResponse) XXX_Unmarshal(b []byte) error

type QueryPacketReceiptRequest 

type QueryPacketReceiptRequest struct {
	// dest chain name
	DestChain string `protobuf:"bytes,1,opt,name=dest_chain,json=destChain,proto3" json:"dest_chain,omitempty"`
	// source chain name
	SourceChain string `protobuf:"bytes,2,opt,name=source_chain,json=sourceChain,proto3" json:"source_chain,omitempty"`
	// packet sequence
	Sequence uint64 `protobuf:"varint,3,opt,name=sequence,proto3" json:"sequence,omitempty"`
}

QueryPacketReceiptRequest is the request type for the Query/PacketReceipt RPC method

func (*QueryPacketReceiptRequest) Descriptor 

func (*QueryPacketReceiptRequest) Descriptor() ([]byte, []int)

func (*QueryPacketReceiptRequest) GetDestChain 

func (m *QueryPacketReceiptRequest) GetDestChain() string

func (*QueryPacketReceiptRequest) GetSequence 

func (m *QueryPacketReceiptRequest) GetSequence() uint64

func (*QueryPacketReceiptRequest) GetSourceChain 

func (m *QueryPacketReceiptRequest) GetSourceChain() string

func (*QueryPacketReceiptRequest) Marshal 

func (m *QueryPacketReceiptRequest) Marshal() (dAtA []byte, err error)

func (*QueryPacketReceiptRequest) MarshalTo 

func (m *QueryPacketReceiptRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryPacketReceiptRequest) MarshalToSizedBuffer 

func (m *QueryPacketReceiptRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryPacketReceiptRequest) ProtoMessage 

func (*QueryPacketReceiptRequest) ProtoMessage()

func (*QueryPacketReceiptRequest) Reset 

func (m *QueryPacketReceiptRequest) Reset()

func (*QueryPacketReceiptRequest) Size 

func (m *QueryPacketReceiptRequest) Size() (n int)

func (*QueryPacketReceiptRequest) String 

func (m *QueryPacketReceiptRequest) String() string

func (*QueryPacketReceiptRequest) Unmarshal 

func (m *QueryPacketReceiptRequest) Unmarshal(dAtA []byte) error

func (*QueryPacketReceiptRequest) XXX_DiscardUnknown 

func (m *QueryPacketReceiptRequest) XXX_DiscardUnknown()

func (*QueryPacketReceiptRequest) XXX_Marshal 

func (m *QueryPacketReceiptRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryPacketReceiptRequest) XXX_Merge 

func (m *QueryPacketReceiptRequest) XXX_Merge(src proto.Message)

func (*QueryPacketReceiptRequest) XXX_Size 

func (m *QueryPacketReceiptRequest) XXX_Size() int

func (*QueryPacketReceiptRequest) XXX_Unmarshal 

func (m *QueryPacketReceiptRequest) XXX_Unmarshal(b []byte) error

type QueryPacketReceiptResponse 

type QueryPacketReceiptResponse struct {
	// success flag for if receipt exists
	Received bool `protobuf:"varint,2,opt,name=received,proto3" json:"received,omitempty"`
	// merkle proof of existence
	Proof []byte `protobuf:"bytes,3,opt,name=proof,proto3" json:"proof,omitempty"`
	// height at which the proof was retrieved
	ProofHeight client.Height `protobuf:"bytes,4,opt,name=proof_height,json=proofHeight,proto3" json:"proof_height"`
}

QueryPacketReceiptResponse defines the client query response for a packet receipt which also includes a proof, and the height from which the proof was retrieved

func (*QueryPacketReceiptResponse) Descriptor 

func (*QueryPacketReceiptResponse) Descriptor() ([]byte, []int)

func (*QueryPacketReceiptResponse) GetProof 

func (m *QueryPacketReceiptResponse) GetProof() []byte

func (*QueryPacketReceiptResponse) GetProofHeight 

func (m *QueryPacketReceiptResponse) GetProofHeight() client.Height

func (*QueryPacketReceiptResponse) GetReceived 

func (m *QueryPacketReceiptResponse) GetReceived() bool

func (*QueryPacketReceiptResponse) Marshal 

func (m *QueryPacketReceiptResponse) Marshal() (dAtA []byte, err error)

func (*QueryPacketReceiptResponse) MarshalTo 

func (m *QueryPacketReceiptResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryPacketReceiptResponse) MarshalToSizedBuffer 

func (m *QueryPacketReceiptResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryPacketReceiptResponse) ProtoMessage 

func (*QueryPacketReceiptResponse) ProtoMessage()

func (*QueryPacketReceiptResponse) Reset 

func (m *QueryPacketReceiptResponse) Reset()

func (*QueryPacketReceiptResponse) Size 

func (m *QueryPacketReceiptResponse) Size() (n int)

func (*QueryPacketReceiptResponse) String 

func (m *QueryPacketReceiptResponse) String() string

func (*QueryPacketReceiptResponse) Unmarshal 

func (m *QueryPacketReceiptResponse) Unmarshal(dAtA []byte) error

func (*QueryPacketReceiptResponse) XXX_DiscardUnknown 

func (m *QueryPacketReceiptResponse) XXX_DiscardUnknown()

func (*QueryPacketReceiptResponse) XXX_Marshal 

func (m *QueryPacketReceiptResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryPacketReceiptResponse) XXX_Merge 

func (m *QueryPacketReceiptResponse) XXX_Merge(src proto.Message)

func (*QueryPacketReceiptResponse) XXX_Size 

func (m *QueryPacketReceiptResponse) XXX_Size() int

func (*QueryPacketReceiptResponse) XXX_Unmarshal 

func (m *QueryPacketReceiptResponse) XXX_Unmarshal(b []byte) error

type QueryServer 

type QueryServer interface {
	// PacketCommitment queries a stored packet commitment hash.
	PacketCommitment(context.Context, *QueryPacketCommitmentRequest) (*QueryPacketCommitmentResponse, error)
	// PacketCommitments returns all the packet commitments hashes associated
	PacketCommitments(context.Context, *QueryPacketCommitmentsRequest) (*QueryPacketCommitmentsResponse, error)
	// PacketReceipt queries if a given packet sequence has been received on the queried chain
	PacketReceipt(context.Context, *QueryPacketReceiptRequest) (*QueryPacketReceiptResponse, error)
	// PacketAcknowledgement queries a stored packet acknowledgement hash.
	PacketAcknowledgement(context.Context, *QueryPacketAcknowledgementRequest) (*QueryPacketAcknowledgementResponse, error)
	// PacketAcknowledgements returns all the packet acknowledgements associated
	PacketAcknowledgements(context.Context, *QueryPacketAcknowledgementsRequest) (*QueryPacketAcknowledgementsResponse, error)
	// UnreceivedPackets returns all the unreceived TIBC packets associated with sequences.
	UnreceivedPackets(context.Context, *QueryUnreceivedPacketsRequest) (*QueryUnreceivedPacketsResponse, error)
	// UnreceivedAcks returns all the unreceived TIBC acknowledgements associated with sequences.
	UnreceivedAcks(context.Context, *QueryUnreceivedAcksRequest) (*QueryUnreceivedAcksResponse, error)
	// CleanPacketCommitment queries a stored packet commitment hash.
	CleanPacketCommitment(context.Context, *QueryCleanPacketCommitmentRequest) (*QueryCleanPacketCommitmentResponse, error)
}

QueryServer is the server API for Query service.

type QueryUnreceivedAcksRequest 

type QueryUnreceivedAcksRequest struct {
	// dest chain name
	DestChain string `protobuf:"bytes,1,opt,name=dest_chain,json=destChain,proto3" json:"dest_chain,omitempty"`
	// source chain name
	SourceChain string `protobuf:"bytes,2,opt,name=source_chain,json=sourceChain,proto3" json:"source_chain,omitempty"`
	// list of acknowledgement sequences
	PacketAckSequences []uint64 `protobuf:"varint,3,rep,packed,name=packet_ack_sequences,json=packetAckSequences,proto3" json:"packet_ack_sequences,omitempty"`
}

QueryUnreceivedAcks is the request type for the Query/UnreceivedAcks RPC method

func (*QueryUnreceivedAcksRequest) Descriptor 

func (*QueryUnreceivedAcksRequest) Descriptor() ([]byte, []int)

func (*QueryUnreceivedAcksRequest) GetDestChain 

func (m *QueryUnreceivedAcksRequest) GetDestChain() string

func (*QueryUnreceivedAcksRequest) GetPacketAckSequences 

func (m *QueryUnreceivedAcksRequest) GetPacketAckSequences() []uint64

func (*QueryUnreceivedAcksRequest) GetSourceChain 

func (m *QueryUnreceivedAcksRequest) GetSourceChain() string

func (*QueryUnreceivedAcksRequest) Marshal 

func (m *QueryUnreceivedAcksRequest) Marshal() (dAtA []byte, err error)

func (*QueryUnreceivedAcksRequest) MarshalTo 

func (m *QueryUnreceivedAcksRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryUnreceivedAcksRequest) MarshalToSizedBuffer 

func (m *QueryUnreceivedAcksRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryUnreceivedAcksRequest) ProtoMessage 

func (*QueryUnreceivedAcksRequest) ProtoMessage()

func (*QueryUnreceivedAcksRequest) Reset 

func (m *QueryUnreceivedAcksRequest) Reset()

func (*QueryUnreceivedAcksRequest) Size 

func (m *QueryUnreceivedAcksRequest) Size() (n int)

func (*QueryUnreceivedAcksRequest) String 

func (m *QueryUnreceivedAcksRequest) String() string

func (*QueryUnreceivedAcksRequest) Unmarshal 

func (m *QueryUnreceivedAcksRequest) Unmarshal(dAtA []byte) error

func (*QueryUnreceivedAcksRequest) XXX_DiscardUnknown 

func (m *QueryUnreceivedAcksRequest) XXX_DiscardUnknown()

func (*QueryUnreceivedAcksRequest) XXX_Marshal 

func (m *QueryUnreceivedAcksRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryUnreceivedAcksRequest) XXX_Merge 

func (m *QueryUnreceivedAcksRequest) XXX_Merge(src proto.Message)

func (*QueryUnreceivedAcksRequest) XXX_Size 

func (m *QueryUnreceivedAcksRequest) XXX_Size() int

func (*QueryUnreceivedAcksRequest) XXX_Unmarshal 

func (m *QueryUnreceivedAcksRequest) XXX_Unmarshal(b []byte) error

type QueryUnreceivedAcksResponse 

type QueryUnreceivedAcksResponse struct {
	// list of unreceived acknowledgement sequences
	Sequences []uint64 `protobuf:"varint,1,rep,packed,name=sequences,proto3" json:"sequences,omitempty"`
	// query block height
	Height client.Height `protobuf:"bytes,2,opt,name=height,proto3" json:"height"`
}

QueryUnreceivedAcksResponse is the response type for the Query/UnreceivedAcks RPC method

func (*QueryUnreceivedAcksResponse) Descriptor 

func (*QueryUnreceivedAcksResponse) Descriptor() ([]byte, []int)

func (*QueryUnreceivedAcksResponse) GetHeight 

func (m *QueryUnreceivedAcksResponse) GetHeight() client.Height

func (*QueryUnreceivedAcksResponse) GetSequences 

func (m *QueryUnreceivedAcksResponse) GetSequences() []uint64

func (*QueryUnreceivedAcksResponse) Marshal 

func (m *QueryUnreceivedAcksResponse) Marshal() (dAtA []byte, err error)

func (*QueryUnreceivedAcksResponse) MarshalTo 

func (m *QueryUnreceivedAcksResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryUnreceivedAcksResponse) MarshalToSizedBuffer 

func (m *QueryUnreceivedAcksResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryUnreceivedAcksResponse) ProtoMessage 

func (*QueryUnreceivedAcksResponse) ProtoMessage()

func (*QueryUnreceivedAcksResponse) Reset 

func (m *QueryUnreceivedAcksResponse) Reset()

func (*QueryUnreceivedAcksResponse) Size 

func (m *QueryUnreceivedAcksResponse) Size() (n int)

func (*QueryUnreceivedAcksResponse) String 

func (m *QueryUnreceivedAcksResponse) String() string

func (*QueryUnreceivedAcksResponse) Unmarshal 

func (m *QueryUnreceivedAcksResponse) Unmarshal(dAtA []byte) error

func (*QueryUnreceivedAcksResponse) XXX_DiscardUnknown 

func (m *QueryUnreceivedAcksResponse) XXX_DiscardUnknown()

func (*QueryUnreceivedAcksResponse) XXX_Marshal 

func (m *QueryUnreceivedAcksResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryUnreceivedAcksResponse) XXX_Merge 

func (m *QueryUnreceivedAcksResponse) XXX_Merge(src proto.Message)

func (*QueryUnreceivedAcksResponse) XXX_Size 

func (m *QueryUnreceivedAcksResponse) XXX_Size() int

func (*QueryUnreceivedAcksResponse) XXX_Unmarshal 

func (m *QueryUnreceivedAcksResponse) XXX_Unmarshal(b []byte) error

type QueryUnreceivedPacketsRequest 

type QueryUnreceivedPacketsRequest struct {
	// dest chain name
	DestChain string `protobuf:"bytes,1,opt,name=dest_chain,json=destChain,proto3" json:"dest_chain,omitempty"`
	// source chain name
	SourceChain string `protobuf:"bytes,2,opt,name=source_chain,json=sourceChain,proto3" json:"source_chain,omitempty"`
	// list of packet sequences
	PacketCommitmentSequences []uint64 `` /* 146-byte string literal not displayed */
}

QueryUnreceivedPacketsRequest is the request type for the Query/UnreceivedPackets RPC method

func (*QueryUnreceivedPacketsRequest) Descriptor 

func (*QueryUnreceivedPacketsRequest) Descriptor() ([]byte, []int)

func (*QueryUnreceivedPacketsRequest) GetDestChain 

func (m *QueryUnreceivedPacketsRequest) GetDestChain() string

func (*QueryUnreceivedPacketsRequest) GetPacketCommitmentSequences 

func (m *QueryUnreceivedPacketsRequest) GetPacketCommitmentSequences() []uint64

func (*QueryUnreceivedPacketsRequest) GetSourceChain 

func (m *QueryUnreceivedPacketsRequest) GetSourceChain() string

func (*QueryUnreceivedPacketsRequest) Marshal 

func (m *QueryUnreceivedPacketsRequest) Marshal() (dAtA []byte, err error)

func (*QueryUnreceivedPacketsRequest) MarshalTo 

func (m *QueryUnreceivedPacketsRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryUnreceivedPacketsRequest) MarshalToSizedBuffer 

func (m *QueryUnreceivedPacketsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryUnreceivedPacketsRequest) ProtoMessage 

func (*QueryUnreceivedPacketsRequest) ProtoMessage()

func (*QueryUnreceivedPacketsRequest) Reset 

func (m *QueryUnreceivedPacketsRequest) Reset()

func (*QueryUnreceivedPacketsRequest) Size 

func (m *QueryUnreceivedPacketsRequest) Size() (n int)

func (*QueryUnreceivedPacketsRequest) String 

func (m *QueryUnreceivedPacketsRequest) String() string

func (*QueryUnreceivedPacketsRequest) Unmarshal 

func (m *QueryUnreceivedPacketsRequest) Unmarshal(dAtA []byte) error

func (*QueryUnreceivedPacketsRequest) XXX_DiscardUnknown 

func (m *QueryUnreceivedPacketsRequest) XXX_DiscardUnknown()

func (*QueryUnreceivedPacketsRequest) XXX_Marshal 

func (m *QueryUnreceivedPacketsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryUnreceivedPacketsRequest) XXX_Merge 

func (m *QueryUnreceivedPacketsRequest) XXX_Merge(src proto.Message)

func (*QueryUnreceivedPacketsRequest) XXX_Size 

func (m *QueryUnreceivedPacketsRequest) XXX_Size() int

func (*QueryUnreceivedPacketsRequest) XXX_Unmarshal 

func (m *QueryUnreceivedPacketsRequest) XXX_Unmarshal(b []byte) error

type QueryUnreceivedPacketsResponse 

type QueryUnreceivedPacketsResponse struct {
	// list of unreceived packet sequences
	Sequences []uint64 `protobuf:"varint,1,rep,packed,name=sequences,proto3" json:"sequences,omitempty"`
	// query block height
	Height client.Height `protobuf:"bytes,2,opt,name=height,proto3" json:"height"`
}

QueryUnreceivedPacketsResponse is the response type for the Query/UnreceivedPacketCommitments RPC method

func (*QueryUnreceivedPacketsResponse) Descriptor 

func (*QueryUnreceivedPacketsResponse) Descriptor() ([]byte, []int)

func (*QueryUnreceivedPacketsResponse) GetHeight 

func (m *QueryUnreceivedPacketsResponse) GetHeight() client.Height

func (*QueryUnreceivedPacketsResponse) GetSequences 

func (m *QueryUnreceivedPacketsResponse) GetSequences() []uint64

func (*QueryUnreceivedPacketsResponse) Marshal 

func (m *QueryUnreceivedPacketsResponse) Marshal() (dAtA []byte, err error)

func (*QueryUnreceivedPacketsResponse) MarshalTo 

func (m *QueryUnreceivedPacketsResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryUnreceivedPacketsResponse) MarshalToSizedBuffer 

func (m *QueryUnreceivedPacketsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryUnreceivedPacketsResponse) ProtoMessage 

func (*QueryUnreceivedPacketsResponse) ProtoMessage()

func (*QueryUnreceivedPacketsResponse) Reset 

func (m *QueryUnreceivedPacketsResponse) Reset()

func (*QueryUnreceivedPacketsResponse) Size 

func (m *QueryUnreceivedPacketsResponse) Size() (n int)

func (*QueryUnreceivedPacketsResponse) String 

func (m *QueryUnreceivedPacketsResponse) String() string

func (*QueryUnreceivedPacketsResponse) Unmarshal 

func (m *QueryUnreceivedPacketsResponse) Unmarshal(dAtA []byte) error

func (*QueryUnreceivedPacketsResponse) XXX_DiscardUnknown 

func (m *QueryUnreceivedPacketsResponse) XXX_DiscardUnknown()

func (*QueryUnreceivedPacketsResponse) XXX_Marshal 

func (m *QueryUnreceivedPacketsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryUnreceivedPacketsResponse) XXX_Merge 

func (m *QueryUnreceivedPacketsResponse) XXX_Merge(src proto.Message)

func (*QueryUnreceivedPacketsResponse) XXX_Size 

func (m *QueryUnreceivedPacketsResponse) XXX_Size() int

func (*QueryUnreceivedPacketsResponse) XXX_Unmarshal 

func (m *QueryUnreceivedPacketsResponse) XXX_Unmarshal(b []byte) error

type UnimplementedMsgServer 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) Acknowledgement 

func (*UnimplementedMsgServer) Acknowledgement(ctx context.Context, req *MsgAcknowledgement) (*MsgAcknowledgementResponse, error)

func (*UnimplementedMsgServer) CleanPacket 

func (*UnimplementedMsgServer) CleanPacket(ctx context.Context, req *MsgCleanPacket) (*MsgCleanPacketResponse, error)

func (*UnimplementedMsgServer) RecvCleanPacket 

func (*UnimplementedMsgServer) RecvCleanPacket(ctx context.Context, req *MsgRecvCleanPacket) (*MsgRecvCleanPacketResponse, error)

func (*UnimplementedMsgServer) RecvPacket 

func (*UnimplementedMsgServer) RecvPacket(ctx context.Context, req *MsgRecvPacket) (*MsgRecvPacketResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) CleanPacketCommitment 

func (*UnimplementedQueryServer) CleanPacketCommitment(ctx context.Context, req *QueryCleanPacketCommitmentRequest) (*QueryCleanPacketCommitmentResponse, error)

func (*UnimplementedQueryServer) PacketAcknowledgement 

func (*UnimplementedQueryServer) PacketAcknowledgement(ctx context.Context, req *QueryPacketAcknowledgementRequest) (*QueryPacketAcknowledgementResponse, error)

func (*UnimplementedQueryServer) PacketAcknowledgements 

func (*UnimplementedQueryServer) PacketAcknowledgements(ctx context.Context, req *QueryPacketAcknowledgementsRequest) (*QueryPacketAcknowledgementsResponse, error)

func (*UnimplementedQueryServer) PacketCommitment 

func (*UnimplementedQueryServer) PacketCommitment(ctx context.Context, req *QueryPacketCommitmentRequest) (*QueryPacketCommitmentResponse, error)

func (*UnimplementedQueryServer) PacketCommitments 

func (*UnimplementedQueryServer) PacketCommitments(ctx context.Context, req *QueryPacketCommitmentsRequest) (*QueryPacketCommitmentsResponse, error)

func (*UnimplementedQueryServer) PacketReceipt 

func (*UnimplementedQueryServer) PacketReceipt(ctx context.Context, req *QueryPacketReceiptRequest) (*QueryPacketReceiptResponse, error)

func (*UnimplementedQueryServer) UnreceivedAcks 

func (*UnimplementedQueryServer) UnreceivedAcks(ctx context.Context, req *QueryUnreceivedAcksRequest) (*QueryUnreceivedAcksResponse, error)

func (*UnimplementedQueryServer) UnreceivedPackets 

func (*UnimplementedQueryServer) UnreceivedPackets(ctx context.Context, req *QueryUnreceivedPacketsRequest) (*QueryUnreceivedPacketsResponse, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.