Documentation
¶
Overview ¶
Package types is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Index ¶
- Constants
- Variables
- func CommitAcknowledgement(data []byte) []byte
- func CommitPacket(cdc codec.BinaryMarshaler, packet exported.PacketI) []byte
- func FormatChannelIdentifier(sequence uint64) string
- func IsValidChannelID(channelID string) bool
- func ParseChannelSequence(channelID string) (uint64, error)
- func RegisterInterfaces(registry codectypes.InterfaceRegistry)
- func RegisterMsgServer(s grpc1.Server, srv MsgServer)
- func RegisterQueryHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterQueryHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryClient) error
- func RegisterQueryHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterQueryHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryServer) error
- func RegisterQueryServer(s grpc1.Server, srv QueryServer)
- type Acknowledgement
- func (*Acknowledgement) Descriptor() ([]byte, []int)
- func (ack Acknowledgement) GetBytes() []byte
- func (m *Acknowledgement) GetError() string
- func (m *Acknowledgement) GetResponse() isAcknowledgement_Response
- func (m *Acknowledgement) GetResult() []byte
- func (m *Acknowledgement) Marshal() (dAtA []byte, err error)
- func (m *Acknowledgement) MarshalTo(dAtA []byte) (int, error)
- func (m *Acknowledgement) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Acknowledgement) ProtoMessage()
- func (m *Acknowledgement) Reset()
- func (m *Acknowledgement) Size() (n int)
- func (m *Acknowledgement) String() string
- func (m *Acknowledgement) Unmarshal(dAtA []byte) error
- func (m *Acknowledgement) XXX_DiscardUnknown()
- func (m *Acknowledgement) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Acknowledgement) XXX_Merge(src proto.Message)
- func (*Acknowledgement) XXX_OneofWrappers() []interface{}
- func (m *Acknowledgement) XXX_Size() int
- func (m *Acknowledgement) XXX_Unmarshal(b []byte) error
- type Acknowledgement_Error
- type Acknowledgement_Result
- type ClientKeeper
- type GenesisState
- func (*GenesisState) Descriptor() ([]byte, []int)
- func (m *GenesisState) GetAckSequences() []PacketSequence
- func (m *GenesisState) GetAcknowledgements() []PacketState
- func (m *GenesisState) GetCommitments() []PacketState
- func (m *GenesisState) GetNextChannelSequence() uint64
- func (m *GenesisState) GetReceipts() []PacketState
- func (m *GenesisState) GetRecvSequences() []PacketSequence
- func (m *GenesisState) GetSendSequences() []PacketSequence
- func (m *GenesisState) Marshal() (dAtA []byte, err error)
- func (m *GenesisState) MarshalTo(dAtA []byte) (int, error)
- func (m *GenesisState) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GenesisState) ProtoMessage()
- func (m *GenesisState) Reset()
- func (m *GenesisState) Size() (n int)
- func (m *GenesisState) String() string
- func (m *GenesisState) Unmarshal(dAtA []byte) error
- func (gs GenesisState) Validate() error
- func (m *GenesisState) XXX_DiscardUnknown()
- func (m *GenesisState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GenesisState) XXX_Merge(src proto.Message)
- func (m *GenesisState) XXX_Size() int
- func (m *GenesisState) XXX_Unmarshal(b []byte) error
- type MsgAcknowledgement
- func (*MsgAcknowledgement) Descriptor() ([]byte, []int)
- func (msg MsgAcknowledgement) GetSignBytes() []byte
- func (msg MsgAcknowledgement) GetSigners() []sdk.AccAddress
- func (m *MsgAcknowledgement) Marshal() (dAtA []byte, err error)
- func (m *MsgAcknowledgement) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgAcknowledgement) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgAcknowledgement) ProtoMessage()
- func (m *MsgAcknowledgement) Reset()
- func (msg MsgAcknowledgement) Route() string
- func (m *MsgAcknowledgement) Size() (n int)
- func (m *MsgAcknowledgement) String() string
- func (msg MsgAcknowledgement) Type() string
- func (m *MsgAcknowledgement) Unmarshal(dAtA []byte) error
- func (msg MsgAcknowledgement) ValidateBasic() error
- func (m *MsgAcknowledgement) XXX_DiscardUnknown()
- func (m *MsgAcknowledgement) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgAcknowledgement) XXX_Merge(src proto.Message)
- func (m *MsgAcknowledgement) XXX_Size() int
- func (m *MsgAcknowledgement) XXX_Unmarshal(b []byte) error
- type MsgAcknowledgementResponse
- func (*MsgAcknowledgementResponse) Descriptor() ([]byte, []int)
- func (m *MsgAcknowledgementResponse) Marshal() (dAtA []byte, err error)
- func (m *MsgAcknowledgementResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgAcknowledgementResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgAcknowledgementResponse) ProtoMessage()
- func (m *MsgAcknowledgementResponse) Reset()
- func (m *MsgAcknowledgementResponse) Size() (n int)
- func (m *MsgAcknowledgementResponse) String() string
- func (m *MsgAcknowledgementResponse) Unmarshal(dAtA []byte) error
- func (m *MsgAcknowledgementResponse) XXX_DiscardUnknown()
- func (m *MsgAcknowledgementResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgAcknowledgementResponse) XXX_Merge(src proto.Message)
- func (m *MsgAcknowledgementResponse) XXX_Size() int
- func (m *MsgAcknowledgementResponse) XXX_Unmarshal(b []byte) error
- type MsgCleanPacket
- func (*MsgCleanPacket) Descriptor() ([]byte, []int)
- func (msg MsgCleanPacket) GetDataSignBytes() []byte
- func (msg MsgCleanPacket) GetSignBytes() []byte
- func (msg MsgCleanPacket) GetSigners() []sdk.AccAddress
- func (m *MsgCleanPacket) Marshal() (dAtA []byte, err error)
- func (m *MsgCleanPacket) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgCleanPacket) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgCleanPacket) ProtoMessage()
- func (m *MsgCleanPacket) Reset()
- func (msg MsgCleanPacket) Route() string
- func (m *MsgCleanPacket) Size() (n int)
- func (m *MsgCleanPacket) String() string
- func (msg MsgCleanPacket) Type() string
- func (m *MsgCleanPacket) Unmarshal(dAtA []byte) error
- func (msg MsgCleanPacket) ValidateBasic() error
- func (m *MsgCleanPacket) XXX_DiscardUnknown()
- func (m *MsgCleanPacket) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgCleanPacket) XXX_Merge(src proto.Message)
- func (m *MsgCleanPacket) XXX_Size() int
- func (m *MsgCleanPacket) XXX_Unmarshal(b []byte) error
- type MsgCleanPacketResponse
- func (*MsgCleanPacketResponse) Descriptor() ([]byte, []int)
- func (m *MsgCleanPacketResponse) Marshal() (dAtA []byte, err error)
- func (m *MsgCleanPacketResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgCleanPacketResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgCleanPacketResponse) ProtoMessage()
- func (m *MsgCleanPacketResponse) Reset()
- func (m *MsgCleanPacketResponse) Size() (n int)
- func (m *MsgCleanPacketResponse) String() string
- func (m *MsgCleanPacketResponse) Unmarshal(dAtA []byte) error
- func (m *MsgCleanPacketResponse) XXX_DiscardUnknown()
- func (m *MsgCleanPacketResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgCleanPacketResponse) XXX_Merge(src proto.Message)
- func (m *MsgCleanPacketResponse) XXX_Size() int
- func (m *MsgCleanPacketResponse) XXX_Unmarshal(b []byte) error
- type MsgClient
- type MsgRecvCleanPacket
- func (*MsgRecvCleanPacket) Descriptor() ([]byte, []int)
- func (msg MsgRecvCleanPacket) GetDataSignBytes() []byte
- func (msg MsgRecvCleanPacket) GetSignBytes() []byte
- func (msg MsgRecvCleanPacket) GetSigners() []sdk.AccAddress
- func (m *MsgRecvCleanPacket) Marshal() (dAtA []byte, err error)
- func (m *MsgRecvCleanPacket) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgRecvCleanPacket) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgRecvCleanPacket) ProtoMessage()
- func (m *MsgRecvCleanPacket) Reset()
- func (msg MsgRecvCleanPacket) Route() string
- func (m *MsgRecvCleanPacket) Size() (n int)
- func (m *MsgRecvCleanPacket) String() string
- func (msg MsgRecvCleanPacket) Type() string
- func (m *MsgRecvCleanPacket) Unmarshal(dAtA []byte) error
- func (msg MsgRecvCleanPacket) ValidateBasic() error
- func (m *MsgRecvCleanPacket) XXX_DiscardUnknown()
- func (m *MsgRecvCleanPacket) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgRecvCleanPacket) XXX_Merge(src proto.Message)
- func (m *MsgRecvCleanPacket) XXX_Size() int
- func (m *MsgRecvCleanPacket) XXX_Unmarshal(b []byte) error
- type MsgRecvCleanPacketResponse
- func (*MsgRecvCleanPacketResponse) Descriptor() ([]byte, []int)
- func (m *MsgRecvCleanPacketResponse) Marshal() (dAtA []byte, err error)
- func (m *MsgRecvCleanPacketResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgRecvCleanPacketResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgRecvCleanPacketResponse) ProtoMessage()
- func (m *MsgRecvCleanPacketResponse) Reset()
- func (m *MsgRecvCleanPacketResponse) Size() (n int)
- func (m *MsgRecvCleanPacketResponse) String() string
- func (m *MsgRecvCleanPacketResponse) Unmarshal(dAtA []byte) error
- func (m *MsgRecvCleanPacketResponse) XXX_DiscardUnknown()
- func (m *MsgRecvCleanPacketResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgRecvCleanPacketResponse) XXX_Merge(src proto.Message)
- func (m *MsgRecvCleanPacketResponse) XXX_Size() int
- func (m *MsgRecvCleanPacketResponse) XXX_Unmarshal(b []byte) error
- type MsgRecvPacket
- func (*MsgRecvPacket) Descriptor() ([]byte, []int)
- func (msg MsgRecvPacket) GetDataSignBytes() []byte
- func (msg MsgRecvPacket) GetSignBytes() []byte
- func (msg MsgRecvPacket) GetSigners() []sdk.AccAddress
- func (m *MsgRecvPacket) Marshal() (dAtA []byte, err error)
- func (m *MsgRecvPacket) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgRecvPacket) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgRecvPacket) ProtoMessage()
- func (m *MsgRecvPacket) Reset()
- func (msg MsgRecvPacket) Route() string
- func (m *MsgRecvPacket) Size() (n int)
- func (m *MsgRecvPacket) String() string
- func (msg MsgRecvPacket) Type() string
- func (m *MsgRecvPacket) Unmarshal(dAtA []byte) error
- func (msg MsgRecvPacket) ValidateBasic() error
- func (m *MsgRecvPacket) XXX_DiscardUnknown()
- func (m *MsgRecvPacket) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgRecvPacket) XXX_Merge(src proto.Message)
- func (m *MsgRecvPacket) XXX_Size() int
- func (m *MsgRecvPacket) XXX_Unmarshal(b []byte) error
- type MsgRecvPacketResponse
- func (*MsgRecvPacketResponse) Descriptor() ([]byte, []int)
- func (m *MsgRecvPacketResponse) Marshal() (dAtA []byte, err error)
- func (m *MsgRecvPacketResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgRecvPacketResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgRecvPacketResponse) ProtoMessage()
- func (m *MsgRecvPacketResponse) Reset()
- func (m *MsgRecvPacketResponse) Size() (n int)
- func (m *MsgRecvPacketResponse) String() string
- func (m *MsgRecvPacketResponse) Unmarshal(dAtA []byte) error
- func (m *MsgRecvPacketResponse) XXX_DiscardUnknown()
- func (m *MsgRecvPacketResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgRecvPacketResponse) XXX_Merge(src proto.Message)
- func (m *MsgRecvPacketResponse) XXX_Size() int
- func (m *MsgRecvPacketResponse) XXX_Unmarshal(b []byte) error
- type MsgServer
- type Packet
- func (*Packet) Descriptor() ([]byte, []int)
- func (p Packet) GetData() []byte
- func (p Packet) GetDestChain() string
- func (p Packet) GetPort() string
- func (p Packet) GetRelayChain() string
- func (p Packet) GetSequence() uint64
- func (p Packet) GetSourceChain() string
- func (m *Packet) Marshal() (dAtA []byte, err error)
- func (m *Packet) MarshalTo(dAtA []byte) (int, error)
- func (m *Packet) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Packet) ProtoMessage()
- func (m *Packet) Reset()
- func (m *Packet) Size() (n int)
- func (m *Packet) String() string
- func (m *Packet) Unmarshal(dAtA []byte) error
- func (p Packet) ValidateBasic() error
- func (m *Packet) XXX_DiscardUnknown()
- func (m *Packet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Packet) XXX_Merge(src proto.Message)
- func (m *Packet) XXX_Size() int
- func (m *Packet) XXX_Unmarshal(b []byte) error
- type PacketSequence
- func (*PacketSequence) Descriptor() ([]byte, []int)
- func (m *PacketSequence) GetDestinationChain() string
- func (m *PacketSequence) GetSequence() uint64
- func (m *PacketSequence) GetSourceChain() string
- func (m *PacketSequence) Marshal() (dAtA []byte, err error)
- func (m *PacketSequence) MarshalTo(dAtA []byte) (int, error)
- func (m *PacketSequence) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PacketSequence) ProtoMessage()
- func (m *PacketSequence) Reset()
- func (m *PacketSequence) Size() (n int)
- func (m *PacketSequence) String() string
- func (m *PacketSequence) Unmarshal(dAtA []byte) error
- func (ps PacketSequence) Validate() error
- func (m *PacketSequence) XXX_DiscardUnknown()
- func (m *PacketSequence) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PacketSequence) XXX_Merge(src proto.Message)
- func (m *PacketSequence) XXX_Size() int
- func (m *PacketSequence) XXX_Unmarshal(b []byte) error
- type PacketState
- func (*PacketState) Descriptor() ([]byte, []int)
- func (m *PacketState) Marshal() (dAtA []byte, err error)
- func (m *PacketState) MarshalTo(dAtA []byte) (int, error)
- func (m *PacketState) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PacketState) ProtoMessage()
- func (m *PacketState) Reset()
- func (m *PacketState) Size() (n int)
- func (m *PacketState) String() string
- func (m *PacketState) Unmarshal(dAtA []byte) error
- func (pa PacketState) Validate() error
- func (m *PacketState) XXX_DiscardUnknown()
- func (m *PacketState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PacketState) XXX_Merge(src proto.Message)
- func (m *PacketState) XXX_Size() int
- func (m *PacketState) XXX_Unmarshal(b []byte) error
- type QueryClient
- type QueryNextSequenceReceiveRequest
- func (*QueryNextSequenceReceiveRequest) Descriptor() ([]byte, []int)
- func (m *QueryNextSequenceReceiveRequest) GetDestChain() string
- func (m *QueryNextSequenceReceiveRequest) GetSourceChain() string
- func (m *QueryNextSequenceReceiveRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryNextSequenceReceiveRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryNextSequenceReceiveRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryNextSequenceReceiveRequest) ProtoMessage()
- func (m *QueryNextSequenceReceiveRequest) Reset()
- func (m *QueryNextSequenceReceiveRequest) Size() (n int)
- func (m *QueryNextSequenceReceiveRequest) String() string
- func (m *QueryNextSequenceReceiveRequest) Unmarshal(dAtA []byte) error
- func (m *QueryNextSequenceReceiveRequest) XXX_DiscardUnknown()
- func (m *QueryNextSequenceReceiveRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryNextSequenceReceiveRequest) XXX_Merge(src proto.Message)
- func (m *QueryNextSequenceReceiveRequest) XXX_Size() int
- func (m *QueryNextSequenceReceiveRequest) XXX_Unmarshal(b []byte) error
- type QueryNextSequenceReceiveResponse
- func (*QueryNextSequenceReceiveResponse) Descriptor() ([]byte, []int)
- func (m *QueryNextSequenceReceiveResponse) GetNextSequenceReceive() uint64
- func (m *QueryNextSequenceReceiveResponse) GetProof() []byte
- func (m *QueryNextSequenceReceiveResponse) GetProofHeight() types.Height
- func (m *QueryNextSequenceReceiveResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryNextSequenceReceiveResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryNextSequenceReceiveResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryNextSequenceReceiveResponse) ProtoMessage()
- func (m *QueryNextSequenceReceiveResponse) Reset()
- func (m *QueryNextSequenceReceiveResponse) Size() (n int)
- func (m *QueryNextSequenceReceiveResponse) String() string
- func (m *QueryNextSequenceReceiveResponse) Unmarshal(dAtA []byte) error
- func (m *QueryNextSequenceReceiveResponse) XXX_DiscardUnknown()
- func (m *QueryNextSequenceReceiveResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryNextSequenceReceiveResponse) XXX_Merge(src proto.Message)
- func (m *QueryNextSequenceReceiveResponse) XXX_Size() int
- func (m *QueryNextSequenceReceiveResponse) XXX_Unmarshal(b []byte) error
- type QueryPacketAcknowledgementRequest
- func (*QueryPacketAcknowledgementRequest) Descriptor() ([]byte, []int)
- func (m *QueryPacketAcknowledgementRequest) GetDestChain() string
- func (m *QueryPacketAcknowledgementRequest) GetSequence() uint64
- func (m *QueryPacketAcknowledgementRequest) GetSourceChain() string
- func (m *QueryPacketAcknowledgementRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryPacketAcknowledgementRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryPacketAcknowledgementRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryPacketAcknowledgementRequest) ProtoMessage()
- func (m *QueryPacketAcknowledgementRequest) Reset()
- func (m *QueryPacketAcknowledgementRequest) Size() (n int)
- func (m *QueryPacketAcknowledgementRequest) String() string
- func (m *QueryPacketAcknowledgementRequest) Unmarshal(dAtA []byte) error
- func (m *QueryPacketAcknowledgementRequest) XXX_DiscardUnknown()
- func (m *QueryPacketAcknowledgementRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryPacketAcknowledgementRequest) XXX_Merge(src proto.Message)
- func (m *QueryPacketAcknowledgementRequest) XXX_Size() int
- func (m *QueryPacketAcknowledgementRequest) XXX_Unmarshal(b []byte) error
- type QueryPacketAcknowledgementResponse
- func (*QueryPacketAcknowledgementResponse) Descriptor() ([]byte, []int)
- func (m *QueryPacketAcknowledgementResponse) GetAcknowledgement() []byte
- func (m *QueryPacketAcknowledgementResponse) GetProof() []byte
- func (m *QueryPacketAcknowledgementResponse) GetProofHeight() types.Height
- func (m *QueryPacketAcknowledgementResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryPacketAcknowledgementResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryPacketAcknowledgementResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryPacketAcknowledgementResponse) ProtoMessage()
- func (m *QueryPacketAcknowledgementResponse) Reset()
- func (m *QueryPacketAcknowledgementResponse) Size() (n int)
- func (m *QueryPacketAcknowledgementResponse) String() string
- func (m *QueryPacketAcknowledgementResponse) Unmarshal(dAtA []byte) error
- func (m *QueryPacketAcknowledgementResponse) XXX_DiscardUnknown()
- func (m *QueryPacketAcknowledgementResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryPacketAcknowledgementResponse) XXX_Merge(src proto.Message)
- func (m *QueryPacketAcknowledgementResponse) XXX_Size() int
- func (m *QueryPacketAcknowledgementResponse) XXX_Unmarshal(b []byte) error
- type QueryPacketAcknowledgementsRequest
- func (*QueryPacketAcknowledgementsRequest) Descriptor() ([]byte, []int)
- func (m *QueryPacketAcknowledgementsRequest) GetDestChain() string
- func (m *QueryPacketAcknowledgementsRequest) GetPagination() *query.PageRequest
- func (m *QueryPacketAcknowledgementsRequest) GetSourceChain() string
- func (m *QueryPacketAcknowledgementsRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryPacketAcknowledgementsRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryPacketAcknowledgementsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryPacketAcknowledgementsRequest) ProtoMessage()
- func (m *QueryPacketAcknowledgementsRequest) Reset()
- func (m *QueryPacketAcknowledgementsRequest) Size() (n int)
- func (m *QueryPacketAcknowledgementsRequest) String() string
- func (m *QueryPacketAcknowledgementsRequest) Unmarshal(dAtA []byte) error
- func (m *QueryPacketAcknowledgementsRequest) XXX_DiscardUnknown()
- func (m *QueryPacketAcknowledgementsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryPacketAcknowledgementsRequest) XXX_Merge(src proto.Message)
- func (m *QueryPacketAcknowledgementsRequest) XXX_Size() int
- func (m *QueryPacketAcknowledgementsRequest) XXX_Unmarshal(b []byte) error
- type QueryPacketAcknowledgementsResponse
- func (*QueryPacketAcknowledgementsResponse) Descriptor() ([]byte, []int)
- func (m *QueryPacketAcknowledgementsResponse) GetAcknowledgements() []*PacketState
- func (m *QueryPacketAcknowledgementsResponse) GetHeight() types.Height
- func (m *QueryPacketAcknowledgementsResponse) GetPagination() *query.PageResponse
- func (m *QueryPacketAcknowledgementsResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryPacketAcknowledgementsResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryPacketAcknowledgementsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryPacketAcknowledgementsResponse) ProtoMessage()
- func (m *QueryPacketAcknowledgementsResponse) Reset()
- func (m *QueryPacketAcknowledgementsResponse) Size() (n int)
- func (m *QueryPacketAcknowledgementsResponse) String() string
- func (m *QueryPacketAcknowledgementsResponse) Unmarshal(dAtA []byte) error
- func (m *QueryPacketAcknowledgementsResponse) XXX_DiscardUnknown()
- func (m *QueryPacketAcknowledgementsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryPacketAcknowledgementsResponse) XXX_Merge(src proto.Message)
- func (m *QueryPacketAcknowledgementsResponse) XXX_Size() int
- func (m *QueryPacketAcknowledgementsResponse) XXX_Unmarshal(b []byte) error
- type QueryPacketCommitmentRequest
- func (*QueryPacketCommitmentRequest) Descriptor() ([]byte, []int)
- func (m *QueryPacketCommitmentRequest) GetDestChain() string
- func (m *QueryPacketCommitmentRequest) GetSequence() uint64
- func (m *QueryPacketCommitmentRequest) GetSourceChain() string
- func (m *QueryPacketCommitmentRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryPacketCommitmentRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryPacketCommitmentRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryPacketCommitmentRequest) ProtoMessage()
- func (m *QueryPacketCommitmentRequest) Reset()
- func (m *QueryPacketCommitmentRequest) Size() (n int)
- func (m *QueryPacketCommitmentRequest) String() string
- func (m *QueryPacketCommitmentRequest) Unmarshal(dAtA []byte) error
- func (m *QueryPacketCommitmentRequest) XXX_DiscardUnknown()
- func (m *QueryPacketCommitmentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryPacketCommitmentRequest) XXX_Merge(src proto.Message)
- func (m *QueryPacketCommitmentRequest) XXX_Size() int
- func (m *QueryPacketCommitmentRequest) XXX_Unmarshal(b []byte) error
- type QueryPacketCommitmentResponse
- func (*QueryPacketCommitmentResponse) Descriptor() ([]byte, []int)
- func (m *QueryPacketCommitmentResponse) GetCommitment() []byte
- func (m *QueryPacketCommitmentResponse) GetProof() []byte
- func (m *QueryPacketCommitmentResponse) GetProofHeight() types.Height
- func (m *QueryPacketCommitmentResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryPacketCommitmentResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryPacketCommitmentResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryPacketCommitmentResponse) ProtoMessage()
- func (m *QueryPacketCommitmentResponse) Reset()
- func (m *QueryPacketCommitmentResponse) Size() (n int)
- func (m *QueryPacketCommitmentResponse) String() string
- func (m *QueryPacketCommitmentResponse) Unmarshal(dAtA []byte) error
- func (m *QueryPacketCommitmentResponse) XXX_DiscardUnknown()
- func (m *QueryPacketCommitmentResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryPacketCommitmentResponse) XXX_Merge(src proto.Message)
- func (m *QueryPacketCommitmentResponse) XXX_Size() int
- func (m *QueryPacketCommitmentResponse) XXX_Unmarshal(b []byte) error
- type QueryPacketCommitmentsRequest
- func (*QueryPacketCommitmentsRequest) Descriptor() ([]byte, []int)
- func (m *QueryPacketCommitmentsRequest) GetDestChain() string
- func (m *QueryPacketCommitmentsRequest) GetPagination() *query.PageRequest
- func (m *QueryPacketCommitmentsRequest) GetSourceChain() string
- func (m *QueryPacketCommitmentsRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryPacketCommitmentsRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryPacketCommitmentsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryPacketCommitmentsRequest) ProtoMessage()
- func (m *QueryPacketCommitmentsRequest) Reset()
- func (m *QueryPacketCommitmentsRequest) Size() (n int)
- func (m *QueryPacketCommitmentsRequest) String() string
- func (m *QueryPacketCommitmentsRequest) Unmarshal(dAtA []byte) error
- func (m *QueryPacketCommitmentsRequest) XXX_DiscardUnknown()
- func (m *QueryPacketCommitmentsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryPacketCommitmentsRequest) XXX_Merge(src proto.Message)
- func (m *QueryPacketCommitmentsRequest) XXX_Size() int
- func (m *QueryPacketCommitmentsRequest) XXX_Unmarshal(b []byte) error
- type QueryPacketCommitmentsResponse
- func (*QueryPacketCommitmentsResponse) Descriptor() ([]byte, []int)
- func (m *QueryPacketCommitmentsResponse) GetCommitments() []*PacketState
- func (m *QueryPacketCommitmentsResponse) GetHeight() types.Height
- func (m *QueryPacketCommitmentsResponse) GetPagination() *query.PageResponse
- func (m *QueryPacketCommitmentsResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryPacketCommitmentsResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryPacketCommitmentsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryPacketCommitmentsResponse) ProtoMessage()
- func (m *QueryPacketCommitmentsResponse) Reset()
- func (m *QueryPacketCommitmentsResponse) Size() (n int)
- func (m *QueryPacketCommitmentsResponse) String() string
- func (m *QueryPacketCommitmentsResponse) Unmarshal(dAtA []byte) error
- func (m *QueryPacketCommitmentsResponse) XXX_DiscardUnknown()
- func (m *QueryPacketCommitmentsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryPacketCommitmentsResponse) XXX_Merge(src proto.Message)
- func (m *QueryPacketCommitmentsResponse) XXX_Size() int
- func (m *QueryPacketCommitmentsResponse) XXX_Unmarshal(b []byte) error
- type QueryPacketReceiptRequest
- func (*QueryPacketReceiptRequest) Descriptor() ([]byte, []int)
- func (m *QueryPacketReceiptRequest) GetDestChain() string
- func (m *QueryPacketReceiptRequest) GetSequence() uint64
- func (m *QueryPacketReceiptRequest) GetSourceChain() string
- func (m *QueryPacketReceiptRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryPacketReceiptRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryPacketReceiptRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryPacketReceiptRequest) ProtoMessage()
- func (m *QueryPacketReceiptRequest) Reset()
- func (m *QueryPacketReceiptRequest) Size() (n int)
- func (m *QueryPacketReceiptRequest) String() string
- func (m *QueryPacketReceiptRequest) Unmarshal(dAtA []byte) error
- func (m *QueryPacketReceiptRequest) XXX_DiscardUnknown()
- func (m *QueryPacketReceiptRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryPacketReceiptRequest) XXX_Merge(src proto.Message)
- func (m *QueryPacketReceiptRequest) XXX_Size() int
- func (m *QueryPacketReceiptRequest) XXX_Unmarshal(b []byte) error
- type QueryPacketReceiptResponse
- func (*QueryPacketReceiptResponse) Descriptor() ([]byte, []int)
- func (m *QueryPacketReceiptResponse) GetProof() []byte
- func (m *QueryPacketReceiptResponse) GetProofHeight() types.Height
- func (m *QueryPacketReceiptResponse) GetReceived() bool
- func (m *QueryPacketReceiptResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryPacketReceiptResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryPacketReceiptResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryPacketReceiptResponse) ProtoMessage()
- func (m *QueryPacketReceiptResponse) Reset()
- func (m *QueryPacketReceiptResponse) Size() (n int)
- func (m *QueryPacketReceiptResponse) String() string
- func (m *QueryPacketReceiptResponse) Unmarshal(dAtA []byte) error
- func (m *QueryPacketReceiptResponse) XXX_DiscardUnknown()
- func (m *QueryPacketReceiptResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryPacketReceiptResponse) XXX_Merge(src proto.Message)
- func (m *QueryPacketReceiptResponse) XXX_Size() int
- func (m *QueryPacketReceiptResponse) XXX_Unmarshal(b []byte) error
- type QueryServer
- type QueryUnreceivedAcksRequest
- func (*QueryUnreceivedAcksRequest) Descriptor() ([]byte, []int)
- func (m *QueryUnreceivedAcksRequest) GetDestChain() string
- func (m *QueryUnreceivedAcksRequest) GetPacketAckSequences() []uint64
- func (m *QueryUnreceivedAcksRequest) GetSourceChain() string
- func (m *QueryUnreceivedAcksRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryUnreceivedAcksRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryUnreceivedAcksRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryUnreceivedAcksRequest) ProtoMessage()
- func (m *QueryUnreceivedAcksRequest) Reset()
- func (m *QueryUnreceivedAcksRequest) Size() (n int)
- func (m *QueryUnreceivedAcksRequest) String() string
- func (m *QueryUnreceivedAcksRequest) Unmarshal(dAtA []byte) error
- func (m *QueryUnreceivedAcksRequest) XXX_DiscardUnknown()
- func (m *QueryUnreceivedAcksRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryUnreceivedAcksRequest) XXX_Merge(src proto.Message)
- func (m *QueryUnreceivedAcksRequest) XXX_Size() int
- func (m *QueryUnreceivedAcksRequest) XXX_Unmarshal(b []byte) error
- type QueryUnreceivedAcksResponse
- func (*QueryUnreceivedAcksResponse) Descriptor() ([]byte, []int)
- func (m *QueryUnreceivedAcksResponse) GetHeight() types.Height
- func (m *QueryUnreceivedAcksResponse) GetSequences() []uint64
- func (m *QueryUnreceivedAcksResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryUnreceivedAcksResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryUnreceivedAcksResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryUnreceivedAcksResponse) ProtoMessage()
- func (m *QueryUnreceivedAcksResponse) Reset()
- func (m *QueryUnreceivedAcksResponse) Size() (n int)
- func (m *QueryUnreceivedAcksResponse) String() string
- func (m *QueryUnreceivedAcksResponse) Unmarshal(dAtA []byte) error
- func (m *QueryUnreceivedAcksResponse) XXX_DiscardUnknown()
- func (m *QueryUnreceivedAcksResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryUnreceivedAcksResponse) XXX_Merge(src proto.Message)
- func (m *QueryUnreceivedAcksResponse) XXX_Size() int
- func (m *QueryUnreceivedAcksResponse) XXX_Unmarshal(b []byte) error
- type QueryUnreceivedPacketsRequest
- func (*QueryUnreceivedPacketsRequest) Descriptor() ([]byte, []int)
- func (m *QueryUnreceivedPacketsRequest) GetDestChain() string
- func (m *QueryUnreceivedPacketsRequest) GetPacketCommitmentSequences() []uint64
- func (m *QueryUnreceivedPacketsRequest) GetSourceChain() string
- func (m *QueryUnreceivedPacketsRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryUnreceivedPacketsRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryUnreceivedPacketsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryUnreceivedPacketsRequest) ProtoMessage()
- func (m *QueryUnreceivedPacketsRequest) Reset()
- func (m *QueryUnreceivedPacketsRequest) Size() (n int)
- func (m *QueryUnreceivedPacketsRequest) String() string
- func (m *QueryUnreceivedPacketsRequest) Unmarshal(dAtA []byte) error
- func (m *QueryUnreceivedPacketsRequest) XXX_DiscardUnknown()
- func (m *QueryUnreceivedPacketsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryUnreceivedPacketsRequest) XXX_Merge(src proto.Message)
- func (m *QueryUnreceivedPacketsRequest) XXX_Size() int
- func (m *QueryUnreceivedPacketsRequest) XXX_Unmarshal(b []byte) error
- type QueryUnreceivedPacketsResponse
- func (*QueryUnreceivedPacketsResponse) Descriptor() ([]byte, []int)
- func (m *QueryUnreceivedPacketsResponse) GetHeight() types.Height
- func (m *QueryUnreceivedPacketsResponse) GetSequences() []uint64
- func (m *QueryUnreceivedPacketsResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryUnreceivedPacketsResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryUnreceivedPacketsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryUnreceivedPacketsResponse) ProtoMessage()
- func (m *QueryUnreceivedPacketsResponse) Reset()
- func (m *QueryUnreceivedPacketsResponse) Size() (n int)
- func (m *QueryUnreceivedPacketsResponse) String() string
- func (m *QueryUnreceivedPacketsResponse) Unmarshal(dAtA []byte) error
- func (m *QueryUnreceivedPacketsResponse) XXX_DiscardUnknown()
- func (m *QueryUnreceivedPacketsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryUnreceivedPacketsResponse) XXX_Merge(src proto.Message)
- func (m *QueryUnreceivedPacketsResponse) XXX_Size() int
- func (m *QueryUnreceivedPacketsResponse) XXX_Unmarshal(b []byte) error
- type RoutingKeeper
- type UnimplementedMsgServer
- func (*UnimplementedMsgServer) Acknowledgement(ctx context.Context, req *MsgAcknowledgement) (*MsgAcknowledgementResponse, error)
- func (*UnimplementedMsgServer) CleanPacket(ctx context.Context, req *MsgCleanPacket) (*MsgCleanPacketResponse, error)
- func (*UnimplementedMsgServer) RecvCleanPacket(ctx context.Context, req *MsgRecvCleanPacket) (*MsgRecvCleanPacketResponse, error)
- func (*UnimplementedMsgServer) RecvPacket(ctx context.Context, req *MsgRecvPacket) (*MsgRecvPacketResponse, error)
- type UnimplementedQueryServer
- func (*UnimplementedQueryServer) NextSequenceReceive(ctx context.Context, req *QueryNextSequenceReceiveRequest) (*QueryNextSequenceReceiveResponse, error)
- func (*UnimplementedQueryServer) PacketAcknowledgement(ctx context.Context, req *QueryPacketAcknowledgementRequest) (*QueryPacketAcknowledgementResponse, error)
- func (*UnimplementedQueryServer) PacketAcknowledgements(ctx context.Context, req *QueryPacketAcknowledgementsRequest) (*QueryPacketAcknowledgementsResponse, error)
- func (*UnimplementedQueryServer) PacketCommitment(ctx context.Context, req *QueryPacketCommitmentRequest) (*QueryPacketCommitmentResponse, error)
- func (*UnimplementedQueryServer) PacketCommitments(ctx context.Context, req *QueryPacketCommitmentsRequest) (*QueryPacketCommitmentsResponse, error)
- func (*UnimplementedQueryServer) PacketReceipt(ctx context.Context, req *QueryPacketReceiptRequest) (*QueryPacketReceiptResponse, error)
- func (*UnimplementedQueryServer) UnreceivedAcks(ctx context.Context, req *QueryUnreceivedAcksRequest) (*QueryUnreceivedAcksResponse, error)
- func (*UnimplementedQueryServer) UnreceivedPackets(ctx context.Context, req *QueryUnreceivedPacketsRequest) (*QueryUnreceivedPacketsResponse, error)
Constants ¶
const ( AttributeKeyConnectionID = "connection_id" AttributeKeyPortID = "port_id" AttributeKeyChannelID = "channel_id" AttributeCounterpartyPortID = "counterparty_port_id" AttributeCounterpartyChannelID = "counterparty_channel_id" EventTypeSendPacket = "send_packet" EventTypeRecvPacket = "recv_packet" EventTypeWriteAck = "write_acknowledgement" EventTypeAcknowledgePacket = "acknowledge_packet" EventTypeTimeoutPacket = "timeout_packet" EventTypeSendCleanPacket = "send_clean_packet" EventTypeRecvCleanPacket = "recv_clean_packet" AttributeKeyData = "packet_data" AttributeKeyAck = "packet_ack" AttributeKeyTimeoutHeight = "packet_timeout_height" AttributeKeyTimeoutTimestamp = "packet_timeout_timestamp" AttributeKeySequence = "packet_sequence" AttributeKeyPort = "packet_port" AttributeKeySrcChain = "packet_src_chain" AttributeKeyDstChain = "packet_dst_port" AttributeKeyRelayChain = "packet_relay_channel" AttributeKeyConnection = "packet_connection" )
TIBC packet events
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 // KeyNextChannelSequence is the key used to store the next channel sequence in // the keeper. KeyNextChannelSequence = "nextChannelSequence" // ChannelPrefix is the prefix used when creating a channel identifier ChannelPrefix = "channel-" )
Variables ¶
var ( ErrChannelExists = sdkerrors.Register(moduleName, 2, "channel already exists") ErrChannelNotFound = sdkerrors.Register(moduleName, 3, "channel not found") ErrInvalidChannel = sdkerrors.Register(moduleName, 4, "invalid channel") ErrInvalidChannelState = sdkerrors.Register(moduleName, 5, "invalid channel state") ErrInvalidChannelOrdering = sdkerrors.Register(moduleName, 6, "invalid channel ordering") ErrInvalidCounterparty = sdkerrors.Register(moduleName, 7, "invalid counterparty channel") ErrInvalidChannelCapability = sdkerrors.Register(moduleName, 8, "invalid channel capability") ErrChannelCapabilityNotFound = sdkerrors.Register(moduleName, 9, "channel capability not found") ErrSequenceSendNotFound = sdkerrors.Register(moduleName, 10, "sequence send not found") ErrSequenceReceiveNotFound = sdkerrors.Register(moduleName, 11, "sequence receive not found") ErrSequenceAckNotFound = sdkerrors.Register(moduleName, 12, "sequence acknowledgement not found") ErrInvalidPacket = sdkerrors.Register(moduleName, 13, "invalid packet") ErrPacketTimeout = sdkerrors.Register(moduleName, 14, "packet timeout") ErrTooManyConnectionHops = sdkerrors.Register(moduleName, 15, "too many connection hops") ErrInvalidAcknowledgement = sdkerrors.Register(moduleName, 16, "invalid acknowledgement") ErrPacketCommitmentNotFound = sdkerrors.Register(moduleName, 17, "packet commitment not found") ErrPacketReceived = sdkerrors.Register(moduleName, 18, "packet already received") ErrAcknowledgementExists = sdkerrors.Register(moduleName, 19, "acknowledgement for packet already exists") ErrInvalidChannelIdentifier = sdkerrors.Register(moduleName, 20, "invalid channel identifier") ErrInvalidCleanPacket = sdkerrors.Register(moduleName, 21, "invalid clean packet") )
TIBC packet sentinel errors
var ( ErrInvalidLengthGenesis = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowGenesis = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupGenesis = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthPacket = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowPacket = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupPacket = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthQuery = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowQuery = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthTx = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowTx = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupTx = fmt.Errorf("proto: unexpected end of group") )
var (
AttributeValueCategory = fmt.Sprintf("%s_%s", host.ModuleName, SubModuleName)
)
tibc packet events vars
var IsChannelIDFormat = regexp.MustCompile(`^channel-[0-9]{1,20}$`).MatchString
IsChannelIDFormat checks if a channelID is in the format required on the SDK for parsing channel identifiers. The channel identifier must be in the form: `channel-{N}
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 ¶
CommitAcknowledgement returns the hash of commitment bytes
func CommitPacket ¶
func CommitPacket(cdc codec.BinaryMarshaler, 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 FormatChannelIdentifier ¶
FormatChannelIdentifier returns the channel identifier with the sequence appended. This is a SDK specific format not enforced by TIBC protocol.
func IsValidChannelID ¶
IsValidChannelID checks if a channelID is valid and can be parsed to the channel identifier format.
func ParseChannelSequence ¶
ParseChannelSequence parses the channel sequence from the channel identifier.
func RegisterInterfaces ¶
func RegisterInterfaces(registry codectypes.InterfaceRegistry)
RegisterInterfaces register the tibc packet submodule interfaces to protobuf Any.
func RegisterMsgServer ¶
func RegisterQueryHandler ¶
RegisterQueryHandler registers the http handlers for service Query to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterQueryHandlerClient ¶
func RegisterQueryHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryClient) error
RegisterQueryHandlerClient registers the http handlers for service Query to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "QueryClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "QueryClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "QueryClient" to call the correct interceptors.
func RegisterQueryHandlerFromEndpoint ¶
func RegisterQueryHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterQueryHandlerFromEndpoint is same as RegisterQueryHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterQueryHandlerServer ¶
func RegisterQueryHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryServer) error
RegisterQueryHandlerServer registers the http handlers for service Query to "mux". UnaryRPC :call QueryServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features (such as grpc.SendHeader, etc) to stop working. Consider using RegisterQueryHandlerFromEndpoint instead.
func RegisterQueryServer ¶
func RegisterQueryServer(s grpc1.Server, srv QueryServer)
Types ¶
type Acknowledgement ¶
type Acknowledgement struct { // response contains either a result or an error and must be non-empty // // Types that are valid to be assigned to Response: // *Acknowledgement_Result // *Acknowledgement_Error Response isAcknowledgement_Response `protobuf_oneof:"response"` }
Acknowledgement is the recommended acknowledgement format to be used by app-specific protocols. NOTE: The field numbers 21 and 22 were explicitly chosen to avoid accidental conflicts with other protobuf message formats used for acknowledgements. The first byte of any message with this format will be the non-ASCII values `0xaa` (result) or `0xb2` (error). Implemented as defined by ICS: https://github.com/cosmos/ics/tree/master/spec/ics-004-channel-and-packet-semantics#acknowledgement-envelope
func 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) 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 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"` // the sequence for the next generated channel identifier NextChannelSequence uint64 `` /* 150-byte string literal not displayed */ }
GenesisState defines the ibc channel submodule's genesis state.
func DefaultGenesisState ¶
func DefaultGenesisState() GenesisState
DefaultGenesisState returns the tibc packet submodule's default genesis state.
func NewGenesisState ¶
func NewGenesisState( acks, receipts, commitments []PacketState, sendSeqs, recvSeqs, ackSeqs []PacketSequence, nextChannelSequence uint64, ) 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) GetNextChannelSequence ¶
func (m *GenesisState) GetNextChannelSequence() uint64
func (*GenesisState) GetReceipts ¶
func (m *GenesisState) GetReceipts() []PacketState
func (*GenesisState) GetRecvSequences ¶
func (m *GenesisState) GetRecvSequences() []PacketSequence
func (*GenesisState) GetSendSequences ¶
func (m *GenesisState) GetSendSequences() []PacketSequence
func (*GenesisState) Marshal ¶
func (m *GenesisState) Marshal() (dAtA []byte, err error)
func (*GenesisState) 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 IBC 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) GetSignBytes ¶
func (msg MsgAcknowledgement) GetSignBytes() []byte
GetSignBytes implements sdk.Msg. The function will panic since it is used for amino transaction verification which TIBC does not support.
func (MsgAcknowledgement) GetSigners ¶
func (msg MsgAcknowledgement) GetSigners() []sdk.AccAddress
GetSigners implements sdk.Msg
func (*MsgAcknowledgement) Marshal ¶
func (m *MsgAcknowledgement) Marshal() (dAtA []byte, err error)
func (*MsgAcknowledgement) MarshalTo ¶
func (m *MsgAcknowledgement) MarshalTo(dAtA []byte) (int, error)
func (*MsgAcknowledgement) MarshalToSizedBuffer ¶
func (m *MsgAcknowledgement) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgAcknowledgement) ProtoMessage ¶
func (*MsgAcknowledgement) ProtoMessage()
func (*MsgAcknowledgement) Reset ¶
func (m *MsgAcknowledgement) Reset()
func (MsgAcknowledgement) Route ¶
func (msg MsgAcknowledgement) Route() string
Route implements sdk.Msg
func (*MsgAcknowledgement) Size ¶
func (m *MsgAcknowledgement) Size() (n int)
func (*MsgAcknowledgement) String ¶
func (m *MsgAcknowledgement) String() string
func (MsgAcknowledgement) Type ¶
func (msg MsgAcknowledgement) Type() string
Type implements sdk.Msg
func (*MsgAcknowledgement) Unmarshal ¶
func (m *MsgAcknowledgement) Unmarshal(dAtA []byte) error
func (MsgAcknowledgement) ValidateBasic ¶
func (msg MsgAcknowledgement) ValidateBasic() error
ValidateBasic implements sdk.Msg
func (*MsgAcknowledgement) XXX_DiscardUnknown ¶
func (m *MsgAcknowledgement) XXX_DiscardUnknown()
func (*MsgAcknowledgement) XXX_Marshal ¶
func (m *MsgAcknowledgement) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgAcknowledgement) XXX_Merge ¶
func (m *MsgAcknowledgement) XXX_Merge(src proto.Message)
func (*MsgAcknowledgement) XXX_Size ¶
func (m *MsgAcknowledgement) XXX_Size() int
func (*MsgAcknowledgement) XXX_Unmarshal ¶
func (m *MsgAcknowledgement) XXX_Unmarshal(b []byte) error
type MsgAcknowledgementResponse ¶
type MsgAcknowledgementResponse struct { }
MsgAcknowledgementResponse defines the Msg/Acknowledgement response type.
func (*MsgAcknowledgementResponse) Descriptor ¶
func (*MsgAcknowledgementResponse) Descriptor() ([]byte, []int)
func (*MsgAcknowledgementResponse) Marshal ¶
func (m *MsgAcknowledgementResponse) Marshal() (dAtA []byte, err error)
func (*MsgAcknowledgementResponse) MarshalTo ¶
func (m *MsgAcknowledgementResponse) MarshalTo(dAtA []byte) (int, error)
func (*MsgAcknowledgementResponse) MarshalToSizedBuffer ¶
func (m *MsgAcknowledgementResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgAcknowledgementResponse) ProtoMessage ¶
func (*MsgAcknowledgementResponse) ProtoMessage()
func (*MsgAcknowledgementResponse) Reset ¶
func (m *MsgAcknowledgementResponse) Reset()
func (*MsgAcknowledgementResponse) Size ¶
func (m *MsgAcknowledgementResponse) Size() (n int)
func (*MsgAcknowledgementResponse) String ¶
func (m *MsgAcknowledgementResponse) String() string
func (*MsgAcknowledgementResponse) Unmarshal ¶
func (m *MsgAcknowledgementResponse) Unmarshal(dAtA []byte) error
func (*MsgAcknowledgementResponse) XXX_DiscardUnknown ¶
func (m *MsgAcknowledgementResponse) XXX_DiscardUnknown()
func (*MsgAcknowledgementResponse) XXX_Marshal ¶
func (m *MsgAcknowledgementResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgAcknowledgementResponse) XXX_Merge ¶
func (m *MsgAcknowledgementResponse) XXX_Merge(src proto.Message)
func (*MsgAcknowledgementResponse) XXX_Size ¶
func (m *MsgAcknowledgementResponse) XXX_Size() int
func (*MsgAcknowledgementResponse) XXX_Unmarshal ¶
func (m *MsgAcknowledgementResponse) XXX_Unmarshal(b []byte) error
type MsgCleanPacket ¶
type MsgCleanPacket struct { Packet Packet `protobuf:"bytes,1,opt,name=packet,proto3" json:"packet"` Signer string `protobuf:"bytes,2,opt,name=signer,proto3" json:"signer,omitempty"` }
MsgRecvPacket receives incoming IBC packet
func NewMsgCleanPacket ¶
func NewMsgCleanPacket( packet Packet, signer sdk.AccAddress, ) *MsgCleanPacket
NewMsgCleanPacket constructs new MsgCleanPacket nolint:interfacer
func (*MsgCleanPacket) Descriptor ¶
func (*MsgCleanPacket) Descriptor() ([]byte, []int)
func (MsgCleanPacket) GetDataSignBytes ¶
func (msg MsgCleanPacket) GetDataSignBytes() []byte
GetDataSignBytes returns the base64-encoded bytes used for the data field when signing the packet.
func (MsgCleanPacket) GetSignBytes ¶
func (msg MsgCleanPacket) GetSignBytes() []byte
GetSignBytes implements sdk.Msg. The function will panic since it is used for amino transaction verification which TIBC does not support.
func (MsgCleanPacket) GetSigners ¶
func (msg MsgCleanPacket) GetSigners() []sdk.AccAddress
GetSigners implements sdk.Msg
func (*MsgCleanPacket) Marshal ¶
func (m *MsgCleanPacket) Marshal() (dAtA []byte, err error)
func (*MsgCleanPacket) 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 { 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 IBC packet
func NewMsgRecvCleanPacket ¶
func NewMsgRecvCleanPacket( packet Packet, 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) GetDataSignBytes ¶
func (msg MsgRecvCleanPacket) GetDataSignBytes() []byte
GetDataSignBytes returns the base64-encoded bytes used for the data field when signing the packet.
func (MsgRecvCleanPacket) GetSignBytes ¶
func (msg MsgRecvCleanPacket) GetSignBytes() []byte
GetSignBytes implements sdk.Msg. The function will panic since it is used for amino transaction verification which TIBC does not support.
func (MsgRecvCleanPacket) GetSigners ¶
func (msg MsgRecvCleanPacket) GetSigners() []sdk.AccAddress
GetSigners implements sdk.Msg
func (*MsgRecvCleanPacket) Marshal ¶
func (m *MsgRecvCleanPacket) Marshal() (dAtA []byte, err error)
func (*MsgRecvCleanPacket) MarshalTo ¶
func (m *MsgRecvCleanPacket) MarshalTo(dAtA []byte) (int, error)
func (*MsgRecvCleanPacket) MarshalToSizedBuffer ¶
func (m *MsgRecvCleanPacket) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgRecvCleanPacket) ProtoMessage ¶
func (*MsgRecvCleanPacket) ProtoMessage()
func (*MsgRecvCleanPacket) Reset ¶
func (m *MsgRecvCleanPacket) Reset()
func (MsgRecvCleanPacket) Route ¶
func (msg MsgRecvCleanPacket) Route() string
Route implements sdk.Msg
func (*MsgRecvCleanPacket) Size ¶
func (m *MsgRecvCleanPacket) Size() (n int)
func (*MsgRecvCleanPacket) String ¶
func (m *MsgRecvCleanPacket) String() string
func (MsgRecvCleanPacket) Type ¶
func (msg MsgRecvCleanPacket) Type() string
Type implements sdk.Msg
func (*MsgRecvCleanPacket) Unmarshal ¶
func (m *MsgRecvCleanPacket) Unmarshal(dAtA []byte) error
func (MsgRecvCleanPacket) ValidateBasic ¶
func (msg MsgRecvCleanPacket) ValidateBasic() error
ValidateBasic implements sdk.Msg
func (*MsgRecvCleanPacket) XXX_DiscardUnknown ¶
func (m *MsgRecvCleanPacket) XXX_DiscardUnknown()
func (*MsgRecvCleanPacket) XXX_Marshal ¶
func (m *MsgRecvCleanPacket) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgRecvCleanPacket) XXX_Merge ¶
func (m *MsgRecvCleanPacket) XXX_Merge(src proto.Message)
func (*MsgRecvCleanPacket) XXX_Size ¶
func (m *MsgRecvCleanPacket) XXX_Size() int
func (*MsgRecvCleanPacket) XXX_Unmarshal ¶
func (m *MsgRecvCleanPacket) XXX_Unmarshal(b []byte) error
type MsgRecvCleanPacketResponse ¶
type MsgRecvCleanPacketResponse struct { }
MsgRecvPacketResponse defines the Msg/RecvPacket response type.
func (*MsgRecvCleanPacketResponse) Descriptor ¶
func (*MsgRecvCleanPacketResponse) Descriptor() ([]byte, []int)
func (*MsgRecvCleanPacketResponse) Marshal ¶
func (m *MsgRecvCleanPacketResponse) Marshal() (dAtA []byte, err error)
func (*MsgRecvCleanPacketResponse) MarshalTo ¶
func (m *MsgRecvCleanPacketResponse) MarshalTo(dAtA []byte) (int, error)
func (*MsgRecvCleanPacketResponse) MarshalToSizedBuffer ¶
func (m *MsgRecvCleanPacketResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgRecvCleanPacketResponse) ProtoMessage ¶
func (*MsgRecvCleanPacketResponse) ProtoMessage()
func (*MsgRecvCleanPacketResponse) Reset ¶
func (m *MsgRecvCleanPacketResponse) Reset()
func (*MsgRecvCleanPacketResponse) Size ¶
func (m *MsgRecvCleanPacketResponse) Size() (n int)
func (*MsgRecvCleanPacketResponse) String ¶
func (m *MsgRecvCleanPacketResponse) String() string
func (*MsgRecvCleanPacketResponse) Unmarshal ¶
func (m *MsgRecvCleanPacketResponse) Unmarshal(dAtA []byte) error
func (*MsgRecvCleanPacketResponse) XXX_DiscardUnknown ¶
func (m *MsgRecvCleanPacketResponse) XXX_DiscardUnknown()
func (*MsgRecvCleanPacketResponse) XXX_Marshal ¶
func (m *MsgRecvCleanPacketResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgRecvCleanPacketResponse) XXX_Merge ¶
func (m *MsgRecvCleanPacketResponse) XXX_Merge(src proto.Message)
func (*MsgRecvCleanPacketResponse) XXX_Size ¶
func (m *MsgRecvCleanPacketResponse) XXX_Size() int
func (*MsgRecvCleanPacketResponse) XXX_Unmarshal ¶
func (m *MsgRecvCleanPacketResponse) XXX_Unmarshal(b []byte) error
type MsgRecvPacket ¶
type MsgRecvPacket struct { Packet Packet `protobuf:"bytes,1,opt,name=packet,proto3" json:"packet"` ProofCommitment []byte `` /* 130-byte string literal not displayed */ ProofHeight 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 IBC 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) GetSignBytes ¶
func (msg MsgRecvPacket) GetSignBytes() []byte
GetSignBytes implements sdk.Msg. The function will panic since it is used for amino transaction verification which TIBC does not support.
func (MsgRecvPacket) GetSigners ¶
func (msg MsgRecvPacket) GetSigners() []sdk.AccAddress
GetSigners implements sdk.Msg
func (*MsgRecvPacket) Marshal ¶
func (m *MsgRecvPacket) Marshal() (dAtA []byte, err error)
func (*MsgRecvPacket) 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 IBC
func NewPacket ¶
func NewPacket( data []byte, sequence uint64, sourceChain, destinationChain, relayChain, port string, ) Packet
NewPacket creates a new Packet instance. It panics if the provided packet data interface is not registered.
func (*Packet) Descriptor ¶
func (Packet) GetDestChain ¶
GetDestinationChain implements PacketI interface
func (Packet) GetRelayChain ¶
GetRelayChain implements PacketI interface
func (Packet) GetSequence ¶
GetSequence implements PacketI interface
func (Packet) GetSourceChain ¶
GetSourceChain implements PacketI interface
func (*Packet) MarshalToSizedBuffer ¶
func (*Packet) ProtoMessage ¶
func (*Packet) ProtoMessage()
func (Packet) ValidateBasic ¶
ValidateBasic implements PacketI interface
func (*Packet) XXX_DiscardUnknown ¶
func (m *Packet) XXX_DiscardUnknown()
func (*Packet) XXX_Marshal ¶
func (*Packet) XXX_Unmarshal ¶
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) 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) 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 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) // NextSequenceReceive returns the next receive sequence. NextSequenceReceive(ctx context.Context, in *QueryNextSequenceReceiveRequest, opts ...grpc.CallOption) (*QueryNextSequenceReceiveResponse, 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 QueryNextSequenceReceiveRequest ¶
type QueryNextSequenceReceiveRequest 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"` }
QueryNextSequenceReceiveRequest is the request type for the Query/QueryNextSequenceReceiveRequest RPC method
func (*QueryNextSequenceReceiveRequest) Descriptor ¶
func (*QueryNextSequenceReceiveRequest) Descriptor() ([]byte, []int)
func (*QueryNextSequenceReceiveRequest) GetDestChain ¶
func (m *QueryNextSequenceReceiveRequest) GetDestChain() string
func (*QueryNextSequenceReceiveRequest) GetSourceChain ¶
func (m *QueryNextSequenceReceiveRequest) GetSourceChain() string
func (*QueryNextSequenceReceiveRequest) Marshal ¶
func (m *QueryNextSequenceReceiveRequest) Marshal() (dAtA []byte, err error)
func (*QueryNextSequenceReceiveRequest) MarshalTo ¶
func (m *QueryNextSequenceReceiveRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryNextSequenceReceiveRequest) MarshalToSizedBuffer ¶
func (m *QueryNextSequenceReceiveRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryNextSequenceReceiveRequest) ProtoMessage ¶
func (*QueryNextSequenceReceiveRequest) ProtoMessage()
func (*QueryNextSequenceReceiveRequest) Reset ¶
func (m *QueryNextSequenceReceiveRequest) Reset()
func (*QueryNextSequenceReceiveRequest) Size ¶
func (m *QueryNextSequenceReceiveRequest) Size() (n int)
func (*QueryNextSequenceReceiveRequest) String ¶
func (m *QueryNextSequenceReceiveRequest) String() string
func (*QueryNextSequenceReceiveRequest) Unmarshal ¶
func (m *QueryNextSequenceReceiveRequest) Unmarshal(dAtA []byte) error
func (*QueryNextSequenceReceiveRequest) XXX_DiscardUnknown ¶
func (m *QueryNextSequenceReceiveRequest) XXX_DiscardUnknown()
func (*QueryNextSequenceReceiveRequest) XXX_Marshal ¶
func (m *QueryNextSequenceReceiveRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryNextSequenceReceiveRequest) XXX_Merge ¶
func (m *QueryNextSequenceReceiveRequest) XXX_Merge(src proto.Message)
func (*QueryNextSequenceReceiveRequest) XXX_Size ¶
func (m *QueryNextSequenceReceiveRequest) XXX_Size() int
func (*QueryNextSequenceReceiveRequest) XXX_Unmarshal ¶
func (m *QueryNextSequenceReceiveRequest) XXX_Unmarshal(b []byte) error
type QueryNextSequenceReceiveResponse ¶
type QueryNextSequenceReceiveResponse struct { // next sequence receive number NextSequenceReceive uint64 `protobuf:"varint,1,opt,name=next_sequence_receive,json=nextSequenceReceive,proto3" json:"next_sequence_receive,omitempty"` // merkle proof of existence Proof []byte `protobuf:"bytes,2,opt,name=proof,proto3" json:"proof,omitempty"` // height at which the proof was retrieved ProofHeight types.Height `protobuf:"bytes,3,opt,name=proof_height,json=proofHeight,proto3" json:"proof_height"` }
QuerySequenceResponse is the request type for the Query/QueryNextSequenceReceiveResponse RPC method
func NewQueryNextSequenceReceiveResponse ¶
func NewQueryNextSequenceReceiveResponse( sequence uint64, proof []byte, height clienttypes.Height, ) *QueryNextSequenceReceiveResponse
NewQueryNextSequenceReceiveResponse creates a new QueryNextSequenceReceiveResponse instance
func (*QueryNextSequenceReceiveResponse) Descriptor ¶
func (*QueryNextSequenceReceiveResponse) Descriptor() ([]byte, []int)
func (*QueryNextSequenceReceiveResponse) GetNextSequenceReceive ¶
func (m *QueryNextSequenceReceiveResponse) GetNextSequenceReceive() uint64
func (*QueryNextSequenceReceiveResponse) GetProof ¶
func (m *QueryNextSequenceReceiveResponse) GetProof() []byte
func (*QueryNextSequenceReceiveResponse) GetProofHeight ¶
func (m *QueryNextSequenceReceiveResponse) GetProofHeight() types.Height
func (*QueryNextSequenceReceiveResponse) Marshal ¶
func (m *QueryNextSequenceReceiveResponse) Marshal() (dAtA []byte, err error)
func (*QueryNextSequenceReceiveResponse) MarshalTo ¶
func (m *QueryNextSequenceReceiveResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryNextSequenceReceiveResponse) MarshalToSizedBuffer ¶
func (m *QueryNextSequenceReceiveResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryNextSequenceReceiveResponse) ProtoMessage ¶
func (*QueryNextSequenceReceiveResponse) ProtoMessage()
func (*QueryNextSequenceReceiveResponse) Reset ¶
func (m *QueryNextSequenceReceiveResponse) Reset()
func (*QueryNextSequenceReceiveResponse) Size ¶
func (m *QueryNextSequenceReceiveResponse) Size() (n int)
func (*QueryNextSequenceReceiveResponse) String ¶
func (m *QueryNextSequenceReceiveResponse) String() string
func (*QueryNextSequenceReceiveResponse) Unmarshal ¶
func (m *QueryNextSequenceReceiveResponse) Unmarshal(dAtA []byte) error
func (*QueryNextSequenceReceiveResponse) XXX_DiscardUnknown ¶
func (m *QueryNextSequenceReceiveResponse) XXX_DiscardUnknown()
func (*QueryNextSequenceReceiveResponse) XXX_Marshal ¶
func (m *QueryNextSequenceReceiveResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryNextSequenceReceiveResponse) XXX_Merge ¶
func (m *QueryNextSequenceReceiveResponse) XXX_Merge(src proto.Message)
func (*QueryNextSequenceReceiveResponse) XXX_Size ¶
func (m *QueryNextSequenceReceiveResponse) XXX_Size() int
func (*QueryNextSequenceReceiveResponse) XXX_Unmarshal ¶
func (m *QueryNextSequenceReceiveResponse) XXX_Unmarshal(b []byte) error
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 Query/PacketCommitment 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) // NextSequenceReceive returns the next receive sequence. NextSequenceReceive(context.Context, *QueryNextSequenceReceiveRequest) (*QueryNextSequenceReceiveResponse, 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) NextSequenceReceive ¶
func (*UnimplementedQueryServer) NextSequenceReceive(ctx context.Context, req *QueryNextSequenceReceiveRequest) (*QueryNextSequenceReceiveResponse, 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)