types

package
v0.5.0 Latest Latest
Warning

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

 Go to latest Published: Dec 1, 2023 License: Apache-2.0 Imports: 32 Imported by: 4

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	EventTypeSendPacket        = "send_packet"
	EventTypeRecvPacket        = "recv_packet"
	EventTypeWriteAck          = "write_acknowledgement"
	EventTypeAcknowledgePacket = "acknowledge_packet"
	EventTypeSendCleanPacket   = "send_clean_packet"
	EventTypeRecvCleanPacket   = "recv_clean_packet"

	AttributeKeyData       = "packet_data"
	AttributeKeyAck        = "packet_ack"
	AttributeKeySequence   = "packet_sequence"
	AttributeKeyPort       = "packet_port"
	AttributeKeySrcChain   = "packet_src_chain"
	AttributeKeyDstChain   = "packet_dst_port"
	AttributeKeyRelayChain = "packet_relay_channel"
)

TIBC packet events

View Source 
const (
	// SubModuleName defines the TIBC packets name
	SubModuleName = "packet"

	// StoreKey is the store key string for TIBC packets
	StoreKey = SubModuleName

	// RouterKey is the message route for TIBC packets
	RouterKey = SubModuleName

	// QuerierRoute is the querier route for TIBC packets
	QuerierRoute = SubModuleName
)

Variables

View Source 
var (
	ErrSequenceSendNotFound     = sdkerrors.Register(moduleName, 2, "sequence send not found")
	ErrSequenceReceiveNotFound  = sdkerrors.Register(moduleName, 3, "sequence receive not found")
	ErrSequenceAckNotFound      = sdkerrors.Register(moduleName, 4, "sequence acknowledgement not found")
	ErrInvalidPacket            = sdkerrors.Register(moduleName, 5, "invalid packet")
	ErrInvalidAcknowledgement   = sdkerrors.Register(moduleName, 6, "invalid acknowledgement")
	ErrPacketCommitmentNotFound = sdkerrors.Register(moduleName, 7, "packet commitment not found")
	ErrPacketReceived           = sdkerrors.Register(moduleName, 8, "packet already received")
	ErrAcknowledgementExists    = sdkerrors.Register(moduleName, 9, "acknowledgement for packet already exists")
	ErrInvalidCleanPacket       = sdkerrors.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 (
	AttributeValueCategory = fmt.Sprintf("%s_%s", host.ModuleName, SubModuleName)
)

tibc packet events vars

View Source 
var (
	ModuleCdc = codec.NewProtoCodec(codectypes.NewInterfaceRegistry())
)
View Source 
var SubModuleCdc = codec.NewProtoCodec(codectypes.NewInterfaceRegistry())

SubModuleCdc references the global x/ibc/core/04-channel module codec. Note, the codec should ONLY be used in certain instances of tests and for JSON encoding.

The actual codec used for serialization should be provided to x/ibc/core/04-channel and defined at the application level.

Functions

func CommitAcknowledgement 

func CommitAcknowledgement(data []byte) []byte

CommitAcknowledgement returns the hash of commitment bytes

func CommitPacket 

func CommitPacket(packet exported.PacketI) []byte

CommitPacket returns the packet commitment bytes. The commitment consists of: sha256_hash(timeout_timestamp + timeout_height.RevisionNumber + timeout_height.RevisionHeight + sha256_hash(data)) from a given packet. This results in a fixed length preimage. NOTE: sdk.Uint64ToBigEndian sets the uint64 to a slice of length 8.

func RegisterInterfaces 

func RegisterInterfaces(registry codectypes.InterfaceRegistry)

RegisterInterfaces register the tibc packet submodule interfaces to protobuf Any.

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 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 TICS: https://github.com/bianjieai/tics/tree/master/spec/tics-004-channel-and-packet-semantics#acknowledgement-envelope

func NewErrorAcknowledgement 

func NewErrorAcknowledgement(err string) Acknowledgement

NewErrorAcknowledgement returns a new instance of Acknowledgement using an Acknowledgement_Error type in the Response field.

func NewResultAcknowledgement 

func NewResultAcknowledgement(result []byte) Acknowledgement

NewResultAcknowledgement returns a new instance of Acknowledgement using an Acknowledgement_Result type in the Response field.

func (*Acknowledgement) Descriptor 

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

func (Acknowledgement) GetBytes 

func (ack Acknowledgement) GetBytes() []byte

GetBytes is a helper for serialising acknowledgements

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 added in v0.2.0 

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 TIBC

func NewCleanPacket added in v0.2.0 

func NewCleanPacket(
	sequence uint64, sourceChain, destinationChain, relayChain string,
) CleanPacket

NewCleanPacket creates a new CleanPacket instance.

func (*CleanPacket) Descriptor added in v0.2.0 

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

func (CleanPacket) GetDestChain added in v0.2.0 

func (p CleanPacket) GetDestChain() string

GetDestinationChain implements PacketI interface

func (CleanPacket) GetRelayChain added in v0.2.0 

func (p CleanPacket) GetRelayChain() string

GetRelayChain implements PacketI interface

func (CleanPacket) GetSequence added in v0.2.0 

func (p CleanPacket) GetSequence() uint64

GetSequence implements PacketI interface

func (CleanPacket) GetSourceChain added in v0.2.0 

func (p CleanPacket) GetSourceChain() string

GetSourceChain implements PacketI interface

func (*CleanPacket) Marshal added in v0.2.0 

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

func (*CleanPacket) MarshalTo added in v0.2.0 

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

func (*CleanPacket) MarshalToSizedBuffer added in v0.2.0 

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

func (*CleanPacket) ProtoMessage added in v0.2.0 

func (*CleanPacket) ProtoMessage()

func (*CleanPacket) Reset added in v0.2.0 

func (m *CleanPacket) Reset()

func (*CleanPacket) Size added in v0.2.0 

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

func (*CleanPacket) String added in v0.2.0 

func (m *CleanPacket) String() string

func (*CleanPacket) Unmarshal added in v0.2.0 

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

func (CleanPacket) ValidateBasic added in v0.2.0 

func (p CleanPacket) ValidateBasic() error

ValidateBasic implements PacketI interface

func (*CleanPacket) XXX_DiscardUnknown added in v0.2.0 

func (m *CleanPacket) XXX_DiscardUnknown()

func (*CleanPacket) XXX_Marshal added in v0.2.0 

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

func (*CleanPacket) XXX_Merge added in v0.2.0 

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

func (*CleanPacket) XXX_Size added in v0.2.0 

func (m *CleanPacket) XXX_Size() int

func (*CleanPacket) XXX_Unmarshal added in v0.2.0 

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

type ClientKeeper 

type ClientKeeper interface {
	GetClientState(ctx sdk.Context, chainName string) (exported.ClientState, bool)
	GetClientConsensusState(ctx sdk.Context, chainName string, height exported.Height) (exported.ConsensusState, bool)
	ClientStore(ctx sdk.Context, chainName string) sdk.KVStore
	GetChainName(ctx sdk.Context) string
}

ClientKeeper expected account TIBC client keeper

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"`
}

GenesisState defines the tibc channel submodule's genesis state.

func DefaultGenesisState 

func DefaultGenesisState() GenesisState

DefaultGenesisState returns the tibc packet submodule's default genesis state.

func NewGenesisState 

func NewGenesisState(
	acks, commitments, receipts []PacketState,
	sendSeqs, recvSeqs, ackSeqs []PacketSequence,
) GenesisState

NewGenesisState creates a GenesisState instance.

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) 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) Validate 

func (gs GenesisState) Validate() error

Validate performs basic genesis state validation returning an error upon any failure.

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     types.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 TIBC acknowledgement

func NewMsgAcknowledgement 

func NewMsgAcknowledgement(
	packet Packet,
	ack, proofAcked []byte,
	proofHeight clienttypes.Height,
	signer sdk.AccAddress,
) *MsgAcknowledgement

NewMsgAcknowledgement constructs a new MsgAcknowledgement nolint:interfacer

func (*MsgAcknowledgement) Descriptor 

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

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) Size 

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

func (*MsgAcknowledgement) String 

func (m *MsgAcknowledgement) String() string

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 TIBC packet

func NewMsgCleanPacket 

func NewMsgCleanPacket(packet CleanPacket, signer sdk.AccAddress) *MsgCleanPacket

NewMsgCleanPacket constructs new MsgCleanPacket nolint:interfacer

func (*MsgCleanPacket) Descriptor 

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

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) Size 

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

func (*MsgCleanPacket) String 

func (m *MsgCleanPacket) String() string

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     types.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 TIBC packet

func NewMsgRecvCleanPacket 

func NewMsgRecvCleanPacket(
	cleanPacket CleanPacket,
	proofCommitment []byte,
	proofHeight clienttypes.Height,
	signer sdk.AccAddress,
) *MsgRecvCleanPacket

NewMsgCleanPacket constructs new MsgCleanPacket nolint:interfacer

func (*MsgRecvCleanPacket) Descriptor 

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

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) Size 

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

func (*MsgRecvCleanPacket) String 

func (m *MsgRecvCleanPacket) String() string

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     types.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 TIBC packet

func NewMsgRecvPacket 

func NewMsgRecvPacket(
	packet Packet, proofCommitment []byte, proofHeight clienttypes.Height, signer sdk.AccAddress,
) *MsgRecvPacket

NewMsgRecvPacket constructs new MsgRecvPacket nolint:interfacer

func (*MsgRecvPacket) Descriptor 

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

func (MsgRecvPacket) GetDataSignBytes 

func (msg MsgRecvPacket) GetDataSignBytes() []byte

GetDataSignBytes returns the base64-encoded bytes used for the data field when signing the packet.

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) Size 

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

func (*MsgRecvPacket) String 

func (m *MsgRecvPacket) String() string

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 TIBC

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 NewPacketSequence 

func NewPacketSequence(sourceChain, destinationChain string, seq uint64) PacketSequence

NewPacketSequence creates a new PacketSequences instance.

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) Validate 

func (ps PacketSequence) Validate() error

Validate performs basic validation of fields returning an error upon any failure.

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 NewPacketState 

func NewPacketState(sourceChain, destinationChain string, seq uint64, data []byte) PacketState

NewPacketState creates a new PacketState instance.

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) Validate 

func (pa PacketState) Validate() error

Validate performs basic validation of fields returning an error upon any failure.

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 added in v0.2.0 

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 added in v0.2.0 

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

func (*QueryCleanPacketCommitmentRequest) GetDestChain added in v0.2.0 

func (m *QueryCleanPacketCommitmentRequest) GetDestChain() string

func (*QueryCleanPacketCommitmentRequest) GetSourceChain added in v0.2.0 

func (m *QueryCleanPacketCommitmentRequest) GetSourceChain() string

func (*QueryCleanPacketCommitmentRequest) Marshal added in v0.2.0 

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

func (*QueryCleanPacketCommitmentRequest) MarshalTo added in v0.2.0 

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

func (*QueryCleanPacketCommitmentRequest) MarshalToSizedBuffer added in v0.2.0 

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

func (*QueryCleanPacketCommitmentRequest) ProtoMessage added in v0.2.0 

func (*QueryCleanPacketCommitmentRequest) ProtoMessage()

func (*QueryCleanPacketCommitmentRequest) Reset added in v0.2.0 

func (m *QueryCleanPacketCommitmentRequest) Reset()

func (*QueryCleanPacketCommitmentRequest) Size added in v0.2.0 

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

func (*QueryCleanPacketCommitmentRequest) String added in v0.2.0 

func (m *QueryCleanPacketCommitmentRequest) String() string

func (*QueryCleanPacketCommitmentRequest) Unmarshal added in v0.2.0 

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

func (*QueryCleanPacketCommitmentRequest) XXX_DiscardUnknown added in v0.2.0 

func (m *QueryCleanPacketCommitmentRequest) XXX_DiscardUnknown()

func (*QueryCleanPacketCommitmentRequest) XXX_Marshal added in v0.2.0 

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

func (*QueryCleanPacketCommitmentRequest) XXX_Merge added in v0.2.0 

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

func (*QueryCleanPacketCommitmentRequest) XXX_Size added in v0.2.0 

func (m *QueryCleanPacketCommitmentRequest) XXX_Size() int

func (*QueryCleanPacketCommitmentRequest) XXX_Unmarshal added in v0.2.0 

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

type QueryCleanPacketCommitmentResponse added in v0.2.0 

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 types.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 NewQueryCleanPacketCommitmentResponse added in v0.2.0 

func NewQueryCleanPacketCommitmentResponse(
	commitment []byte, proof []byte, height clienttypes.Height,
) *QueryCleanPacketCommitmentResponse

NewQueryCleanPacketCommitmentResponse creates a new NewQueryCleanPacketCommitmentResponse instance

func (*QueryCleanPacketCommitmentResponse) Descriptor added in v0.2.0 

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

func (*QueryCleanPacketCommitmentResponse) GetCommitment added in v0.2.0 

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

func (*QueryCleanPacketCommitmentResponse) GetProof added in v0.2.0 

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

func (*QueryCleanPacketCommitmentResponse) GetProofHeight added in v0.2.0 

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

func (*QueryCleanPacketCommitmentResponse) Marshal added in v0.2.0 

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

func (*QueryCleanPacketCommitmentResponse) MarshalTo added in v0.2.0 

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

func (*QueryCleanPacketCommitmentResponse) MarshalToSizedBuffer added in v0.2.0 

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

func (*QueryCleanPacketCommitmentResponse) ProtoMessage added in v0.2.0 

func (*QueryCleanPacketCommitmentResponse) ProtoMessage()

func (*QueryCleanPacketCommitmentResponse) Reset added in v0.2.0 

func (m *QueryCleanPacketCommitmentResponse) Reset()

func (*QueryCleanPacketCommitmentResponse) Size added in v0.2.0 

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

func (*QueryCleanPacketCommitmentResponse) String added in v0.2.0 

func (m *QueryCleanPacketCommitmentResponse) String() string

func (*QueryCleanPacketCommitmentResponse) Unmarshal added in v0.2.0 

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

func (*QueryCleanPacketCommitmentResponse) XXX_DiscardUnknown added in v0.2.0 

func (m *QueryCleanPacketCommitmentResponse) XXX_DiscardUnknown()

func (*QueryCleanPacketCommitmentResponse) XXX_Marshal added in v0.2.0 

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

func (*QueryCleanPacketCommitmentResponse) XXX_Merge added in v0.2.0 

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

func (*QueryCleanPacketCommitmentResponse) XXX_Size added in v0.2.0 

func (m *QueryCleanPacketCommitmentResponse) XXX_Size() int

func (*QueryCleanPacketCommitmentResponse) XXX_Unmarshal added in v0.2.0 

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 types.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 NewQueryPacketAcknowledgementResponse 

func NewQueryPacketAcknowledgementResponse(
	acknowledgement []byte, proof []byte, height clienttypes.Height,
) *QueryPacketAcknowledgementResponse

NewQueryPacketAcknowledgementResponse creates a new QueryPacketAcknowledgementResponse instance

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() types.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 types.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() types.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 types.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 NewQueryPacketCommitmentResponse 

func NewQueryPacketCommitmentResponse(
	commitment []byte, proof []byte, height clienttypes.Height,
) *QueryPacketCommitmentResponse

NewQueryPacketCommitmentResponse creates a new QueryPacketCommitmentResponse instance

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() types.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 types.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() types.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 types.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 NewQueryPacketReceiptResponse 

func NewQueryPacketReceiptResponse(
	recvd bool, proof []byte, height clienttypes.Height,
) *QueryPacketReceiptResponse

NewQueryPacketReceiptResponse creates a new QueryPacketReceiptResponse instance

func (*QueryPacketReceiptResponse) Descriptor 

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

func (*QueryPacketReceiptResponse) GetProof 

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

func (*QueryPacketReceiptResponse) GetProofHeight 

func (m *QueryPacketReceiptResponse) GetProofHeight() types.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 types.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() types.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 types.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() types.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 RoutingKeeper 

type RoutingKeeper interface {
	Authenticate(ctx sdk.Context, sourceChain, destinationChain, port string) bool
}

PortKeeper expected account TIBC port keeper

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 added in v0.2.0 

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.