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(packet exported.PacketI) []byte
- 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 CleanPacket
- func (*CleanPacket) Descriptor() ([]byte, []int)
- func (p CleanPacket) GetDestChain() string
- func (p CleanPacket) GetRelayChain() string
- func (p CleanPacket) GetSequence() uint64
- func (p CleanPacket) GetSourceChain() string
- func (m *CleanPacket) Marshal() (dAtA []byte, err error)
- func (m *CleanPacket) MarshalTo(dAtA []byte) (int, error)
- func (m *CleanPacket) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CleanPacket) ProtoMessage()
- func (m *CleanPacket) Reset()
- func (m *CleanPacket) Size() (n int)
- func (m *CleanPacket) String() string
- func (m *CleanPacket) Unmarshal(dAtA []byte) error
- func (p CleanPacket) ValidateBasic() error
- func (m *CleanPacket) XXX_DiscardUnknown()
- func (m *CleanPacket) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CleanPacket) XXX_Merge(src proto.Message)
- func (m *CleanPacket) XXX_Size() int
- func (m *CleanPacket) XXX_Unmarshal(b []byte) error
- 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) 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) 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 (m *MsgAcknowledgement) Size() (n int)
- func (m *MsgAcknowledgement) String() 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) 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 (m *MsgCleanPacket) Size() (n int)
- func (m *MsgCleanPacket) String() 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) 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 (m *MsgRecvCleanPacket) Size() (n int)
- func (m *MsgRecvCleanPacket) String() 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) 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 (m *MsgRecvPacket) Size() (n int)
- func (m *MsgRecvPacket) String() 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 QueryCleanPacketCommitmentRequest
- func (*QueryCleanPacketCommitmentRequest) Descriptor() ([]byte, []int)
- func (m *QueryCleanPacketCommitmentRequest) GetDestChain() string
- func (m *QueryCleanPacketCommitmentRequest) GetSourceChain() string
- func (m *QueryCleanPacketCommitmentRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryCleanPacketCommitmentRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryCleanPacketCommitmentRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryCleanPacketCommitmentRequest) ProtoMessage()
- func (m *QueryCleanPacketCommitmentRequest) Reset()
- func (m *QueryCleanPacketCommitmentRequest) Size() (n int)
- func (m *QueryCleanPacketCommitmentRequest) String() string
- func (m *QueryCleanPacketCommitmentRequest) Unmarshal(dAtA []byte) error
- func (m *QueryCleanPacketCommitmentRequest) XXX_DiscardUnknown()
- func (m *QueryCleanPacketCommitmentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryCleanPacketCommitmentRequest) XXX_Merge(src proto.Message)
- func (m *QueryCleanPacketCommitmentRequest) XXX_Size() int
- func (m *QueryCleanPacketCommitmentRequest) XXX_Unmarshal(b []byte) error
- type QueryCleanPacketCommitmentResponse
- func (*QueryCleanPacketCommitmentResponse) Descriptor() ([]byte, []int)
- func (m *QueryCleanPacketCommitmentResponse) GetCommitment() []byte
- func (m *QueryCleanPacketCommitmentResponse) GetProof() []byte
- func (m *QueryCleanPacketCommitmentResponse) GetProofHeight() types.Height
- func (m *QueryCleanPacketCommitmentResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryCleanPacketCommitmentResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryCleanPacketCommitmentResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryCleanPacketCommitmentResponse) ProtoMessage()
- func (m *QueryCleanPacketCommitmentResponse) Reset()
- func (m *QueryCleanPacketCommitmentResponse) Size() (n int)
- func (m *QueryCleanPacketCommitmentResponse) String() string
- func (m *QueryCleanPacketCommitmentResponse) Unmarshal(dAtA []byte) error
- func (m *QueryCleanPacketCommitmentResponse) XXX_DiscardUnknown()
- func (m *QueryCleanPacketCommitmentResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryCleanPacketCommitmentResponse) XXX_Merge(src proto.Message)
- func (m *QueryCleanPacketCommitmentResponse) XXX_Size() int
- func (m *QueryCleanPacketCommitmentResponse) XXX_Unmarshal(b []byte) error
- type QueryClient
- 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) CleanPacketCommitment(ctx context.Context, req *QueryCleanPacketCommitmentRequest) (*QueryCleanPacketCommitmentResponse, 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 ( EventTypeSendPacket = "send_packet" EventTypeRecvPacket = "recv_packet" EventTypeWriteAck = "write_acknowledgement" EventTypeAcknowledgePacket = "acknowledge_packet" EventTypeSendCleanPacket = "send_clean_packet" EventTypeRecvCleanPacket = "recv_clean_packet" AttributeKeyData = "packet_data" AttributeKeyAck = "packet_ack" AttributeKeySequence = "packet_sequence" AttributeKeyPort = "packet_port" AttributeKeySrcChain = "packet_src_chain" AttributeKeyDstChain = "packet_dst_port" AttributeKeyRelayChain = "packet_relay_channel" )
TIBC packet events
const ( // SubModuleName defines the TIBC packets name SubModuleName = "packet" // StoreKey is the store key string for TIBC packets StoreKey = SubModuleName // RouterKey is the message route for TIBC packets RouterKey = SubModuleName // QuerierRoute is the querier route for TIBC packets QuerierRoute = SubModuleName )
Variables ¶
var ( ErrSequenceSendNotFound = sdkerrors.Register(moduleName, 2, "sequence send not found") ErrSequenceReceiveNotFound = sdkerrors.Register(moduleName, 3, "sequence receive not found") ErrSequenceAckNotFound = sdkerrors.Register(moduleName, 4, "sequence acknowledgement not found") ErrInvalidPacket = sdkerrors.Register(moduleName, 5, "invalid packet") ErrInvalidAcknowledgement = sdkerrors.Register(moduleName, 6, "invalid acknowledgement") ErrPacketCommitmentNotFound = sdkerrors.Register(moduleName, 7, "packet commitment not found") ErrPacketReceived = sdkerrors.Register(moduleName, 8, "packet already received") ErrAcknowledgementExists = sdkerrors.Register(moduleName, 9, "acknowledgement for packet already exists") ErrInvalidCleanPacket = sdkerrors.Register(moduleName, 10, "invalid clean packet") )
TIBC packet sentinel errors
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 (
ModuleCdc = codec.NewProtoCodec(codectypes.NewInterfaceRegistry())
)
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 ¶
CommitPacket returns the packet commitment bytes. The commitment consists of: sha256_hash(timeout_timestamp + timeout_height.RevisionNumber + timeout_height.RevisionHeight + sha256_hash(data)) from a given packet. This results in a fixed length preimage. NOTE: sdk.Uint64ToBigEndian sets the uint64 to a slice of length 8.
func RegisterInterfaces ¶
func RegisterInterfaces(registry codectypes.InterfaceRegistry)
RegisterInterfaces register the tibc packet submodule interfaces to protobuf Any.
func RegisterMsgServer ¶
func 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 TICS: https://github.com/bianjieai/tics/tree/master/spec/tics-004-channel-and-packet-semantics#acknowledgement-envelope
func NewErrorAcknowledgement ¶
func NewErrorAcknowledgement(err string) Acknowledgement
NewErrorAcknowledgement returns a new instance of Acknowledgement using an Acknowledgement_Error type in the Response field.
func NewResultAcknowledgement ¶
func NewResultAcknowledgement(result []byte) Acknowledgement
NewResultAcknowledgement returns a new instance of Acknowledgement using an Acknowledgement_Result type in the Response field.
func (*Acknowledgement) Descriptor ¶
func (*Acknowledgement) Descriptor() ([]byte, []int)
func (Acknowledgement) GetBytes ¶
func (ack Acknowledgement) GetBytes() []byte
GetBytes is a helper for serialising acknowledgements
func (*Acknowledgement) GetError ¶
func (m *Acknowledgement) GetError() string
func (*Acknowledgement) GetResponse ¶
func (m *Acknowledgement) GetResponse() isAcknowledgement_Response
func (*Acknowledgement) GetResult ¶
func (m *Acknowledgement) GetResult() []byte
func (*Acknowledgement) Marshal ¶
func (m *Acknowledgement) Marshal() (dAtA []byte, err error)
func (*Acknowledgement) MarshalToSizedBuffer ¶
func (m *Acknowledgement) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Acknowledgement) ProtoMessage ¶
func (*Acknowledgement) ProtoMessage()
func (*Acknowledgement) Reset ¶
func (m *Acknowledgement) Reset()
func (*Acknowledgement) Size ¶
func (m *Acknowledgement) Size() (n int)
func (*Acknowledgement) String ¶
func (m *Acknowledgement) String() string
func (*Acknowledgement) Unmarshal ¶
func (m *Acknowledgement) Unmarshal(dAtA []byte) error
func (*Acknowledgement) XXX_DiscardUnknown ¶
func (m *Acknowledgement) XXX_DiscardUnknown()
func (*Acknowledgement) XXX_Marshal ¶
func (m *Acknowledgement) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Acknowledgement) XXX_Merge ¶
func (m *Acknowledgement) XXX_Merge(src proto.Message)
func (*Acknowledgement) XXX_OneofWrappers ¶
func (*Acknowledgement) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*Acknowledgement) XXX_Size ¶
func (m *Acknowledgement) XXX_Size() int
func (*Acknowledgement) XXX_Unmarshal ¶
func (m *Acknowledgement) XXX_Unmarshal(b []byte) error
type Acknowledgement_Error ¶
type Acknowledgement_Error struct {
Error string `protobuf:"bytes,22,opt,name=error,proto3,oneof" json:"error,omitempty"`
}
func (*Acknowledgement_Error) MarshalTo ¶
func (m *Acknowledgement_Error) MarshalTo(dAtA []byte) (int, error)
func (*Acknowledgement_Error) MarshalToSizedBuffer ¶
func (m *Acknowledgement_Error) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Acknowledgement_Error) Size ¶
func (m *Acknowledgement_Error) Size() (n int)
type Acknowledgement_Result ¶
type Acknowledgement_Result struct {
Result []byte `protobuf:"bytes,21,opt,name=result,proto3,oneof" json:"result,omitempty"`
}
func (*Acknowledgement_Result) MarshalTo ¶
func (m *Acknowledgement_Result) MarshalTo(dAtA []byte) (int, error)
func (*Acknowledgement_Result) MarshalToSizedBuffer ¶
func (m *Acknowledgement_Result) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Acknowledgement_Result) Size ¶
func (m *Acknowledgement_Result) Size() (n int)
type CleanPacket ¶ added in v0.2.0
type CleanPacket struct { // number corresponds to the order of sends and receives, where a Packet // with an earlier sequence number must be sent and received before a Packet // with a later sequence number. Sequence uint64 `protobuf:"varint,1,opt,name=sequence,proto3" json:"sequence,omitempty"` // identifies the chain id of the sending chain. SourceChain string `protobuf:"bytes,3,opt,name=source_chain,json=sourceChain,proto3" json:"source_chain,omitempty" yaml:"source_chain"` // identifies the chain id of the receiving chain. DestinationChain string `` /* 133-byte string literal not displayed */ // identifies the chain id of the relay chain. RelayChain string `protobuf:"bytes,5,opt,name=relay_chain,json=relayChain,proto3" json:"relay_chain,omitempty" yaml:"relay_chain"` }
CleanPacket defines a type that carries data across different chains through TIBC
func NewCleanPacket ¶ added in v0.2.0
func NewCleanPacket( sequence uint64, sourceChain, destinationChain, relayChain string, ) CleanPacket
NewCleanPacket creates a new CleanPacket instance.
func (*CleanPacket) Descriptor ¶ added in v0.2.0
func (*CleanPacket) Descriptor() ([]byte, []int)
func (CleanPacket) GetDestChain ¶ added in v0.2.0
func (p CleanPacket) GetDestChain() string
GetDestinationChain implements PacketI interface
func (CleanPacket) GetRelayChain ¶ added in v0.2.0
func (p CleanPacket) GetRelayChain() string
GetRelayChain implements PacketI interface
func (CleanPacket) GetSequence ¶ added in v0.2.0
func (p CleanPacket) GetSequence() uint64
GetSequence implements PacketI interface
func (CleanPacket) GetSourceChain ¶ added in v0.2.0
func (p CleanPacket) GetSourceChain() string
GetSourceChain implements PacketI interface
func (*CleanPacket) Marshal ¶ added in v0.2.0
func (m *CleanPacket) Marshal() (dAtA []byte, err error)
func (*CleanPacket) MarshalTo ¶ added in v0.2.0
func (m *CleanPacket) MarshalTo(dAtA []byte) (int, error)
func (*CleanPacket) MarshalToSizedBuffer ¶ added in v0.2.0
func (m *CleanPacket) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CleanPacket) ProtoMessage ¶ added in v0.2.0
func (*CleanPacket) ProtoMessage()
func (*CleanPacket) Reset ¶ added in v0.2.0
func (m *CleanPacket) Reset()
func (*CleanPacket) Size ¶ added in v0.2.0
func (m *CleanPacket) Size() (n int)
func (*CleanPacket) String ¶ added in v0.2.0
func (m *CleanPacket) String() string
func (*CleanPacket) Unmarshal ¶ added in v0.2.0
func (m *CleanPacket) Unmarshal(dAtA []byte) error
func (CleanPacket) ValidateBasic ¶ added in v0.2.0
func (p CleanPacket) ValidateBasic() error
ValidateBasic implements PacketI interface
func (*CleanPacket) XXX_DiscardUnknown ¶ added in v0.2.0
func (m *CleanPacket) XXX_DiscardUnknown()
func (*CleanPacket) XXX_Marshal ¶ added in v0.2.0
func (m *CleanPacket) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CleanPacket) XXX_Merge ¶ added in v0.2.0
func (m *CleanPacket) XXX_Merge(src proto.Message)
func (*CleanPacket) XXX_Size ¶ added in v0.2.0
func (m *CleanPacket) XXX_Size() int
func (*CleanPacket) XXX_Unmarshal ¶ added in v0.2.0
func (m *CleanPacket) XXX_Unmarshal(b []byte) error
type ClientKeeper ¶
type ClientKeeper interface { GetClientState(ctx sdk.Context, chainName string) (exported.ClientState, bool) GetClientConsensusState(ctx sdk.Context, chainName string, height exported.Height) (exported.ConsensusState, bool) ClientStore(ctx sdk.Context, chainName string) sdk.KVStore GetChainName(ctx sdk.Context) string }
ClientKeeper expected account TIBC client keeper
type GenesisState ¶
type GenesisState struct { Acknowledgements []PacketState `protobuf:"bytes,2,rep,name=acknowledgements,proto3" json:"acknowledgements"` Commitments []PacketState `protobuf:"bytes,3,rep,name=commitments,proto3" json:"commitments"` Receipts []PacketState `protobuf:"bytes,4,rep,name=receipts,proto3" json:"receipts"` SendSequences []PacketSequence `protobuf:"bytes,5,rep,name=send_sequences,json=sendSequences,proto3" json:"send_sequences" yaml:"send_sequences"` RecvSequences []PacketSequence `protobuf:"bytes,6,rep,name=recv_sequences,json=recvSequences,proto3" json:"recv_sequences" yaml:"recv_sequences"` AckSequences []PacketSequence `protobuf:"bytes,7,rep,name=ack_sequences,json=ackSequences,proto3" json:"ack_sequences" yaml:"ack_sequences"` }
GenesisState defines the tibc channel submodule's genesis state.
func DefaultGenesisState ¶
func DefaultGenesisState() GenesisState
DefaultGenesisState returns the tibc packet submodule's default genesis state.
func NewGenesisState ¶
func NewGenesisState( acks, commitments, receipts []PacketState, sendSeqs, recvSeqs, ackSeqs []PacketSequence, ) GenesisState
NewGenesisState creates a GenesisState instance.
func (*GenesisState) Descriptor ¶
func (*GenesisState) Descriptor() ([]byte, []int)
func (*GenesisState) GetAckSequences ¶
func (m *GenesisState) GetAckSequences() []PacketSequence
func (*GenesisState) GetAcknowledgements ¶
func (m *GenesisState) GetAcknowledgements() []PacketState
func (*GenesisState) GetCommitments ¶
func (m *GenesisState) GetCommitments() []PacketState
func (*GenesisState) GetReceipts ¶
func (m *GenesisState) GetReceipts() []PacketState
func (*GenesisState) GetRecvSequences ¶
func (m *GenesisState) GetRecvSequences() []PacketSequence
func (*GenesisState) GetSendSequences ¶
func (m *GenesisState) GetSendSequences() []PacketSequence
func (*GenesisState) Marshal ¶
func (m *GenesisState) Marshal() (dAtA []byte, err error)
func (*GenesisState) MarshalToSizedBuffer ¶
func (m *GenesisState) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GenesisState) ProtoMessage ¶
func (*GenesisState) ProtoMessage()
func (*GenesisState) Reset ¶
func (m *GenesisState) Reset()
func (*GenesisState) Size ¶
func (m *GenesisState) Size() (n int)
func (*GenesisState) String ¶
func (m *GenesisState) String() string
func (*GenesisState) Unmarshal ¶
func (m *GenesisState) Unmarshal(dAtA []byte) error
func (GenesisState) Validate ¶
func (gs GenesisState) Validate() error
Validate performs basic genesis state validation returning an error upon any failure.
func (*GenesisState) XXX_DiscardUnknown ¶
func (m *GenesisState) XXX_DiscardUnknown()
func (*GenesisState) XXX_Marshal ¶
func (m *GenesisState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GenesisState) XXX_Merge ¶
func (m *GenesisState) XXX_Merge(src proto.Message)
func (*GenesisState) XXX_Size ¶
func (m *GenesisState) XXX_Size() int
func (*GenesisState) XXX_Unmarshal ¶
func (m *GenesisState) XXX_Unmarshal(b []byte) error
type MsgAcknowledgement ¶
type MsgAcknowledgement struct { Packet Packet `protobuf:"bytes,1,opt,name=packet,proto3" json:"packet"` Acknowledgement []byte `protobuf:"bytes,2,opt,name=acknowledgement,proto3" json:"acknowledgement,omitempty"` ProofAcked []byte `protobuf:"bytes,3,opt,name=proof_acked,json=proofAcked,proto3" json:"proof_acked,omitempty" yaml:"proof_acked"` ProofHeight types.Height `protobuf:"bytes,4,opt,name=proof_height,json=proofHeight,proto3" json:"proof_height" yaml:"proof_height"` Signer string `protobuf:"bytes,5,opt,name=signer,proto3" json:"signer,omitempty"` }
MsgAcknowledgement receives incoming TIBC acknowledgement
func NewMsgAcknowledgement ¶
func NewMsgAcknowledgement( packet Packet, ack, proofAcked []byte, proofHeight clienttypes.Height, signer sdk.AccAddress, ) *MsgAcknowledgement
NewMsgAcknowledgement constructs a new MsgAcknowledgement nolint:interfacer
func (*MsgAcknowledgement) Descriptor ¶
func (*MsgAcknowledgement) Descriptor() ([]byte, []int)
func (MsgAcknowledgement) GetSigners ¶
func (msg MsgAcknowledgement) GetSigners() []sdk.AccAddress
GetSigners implements sdk.Msg
func (*MsgAcknowledgement) Marshal ¶
func (m *MsgAcknowledgement) Marshal() (dAtA []byte, err error)
func (*MsgAcknowledgement) MarshalTo ¶
func (m *MsgAcknowledgement) MarshalTo(dAtA []byte) (int, error)
func (*MsgAcknowledgement) MarshalToSizedBuffer ¶
func (m *MsgAcknowledgement) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgAcknowledgement) ProtoMessage ¶
func (*MsgAcknowledgement) ProtoMessage()
func (*MsgAcknowledgement) Reset ¶
func (m *MsgAcknowledgement) Reset()
func (*MsgAcknowledgement) Size ¶
func (m *MsgAcknowledgement) Size() (n int)
func (*MsgAcknowledgement) String ¶
func (m *MsgAcknowledgement) String() string
func (*MsgAcknowledgement) Unmarshal ¶
func (m *MsgAcknowledgement) Unmarshal(dAtA []byte) error
func (MsgAcknowledgement) ValidateBasic ¶
func (msg MsgAcknowledgement) ValidateBasic() error
ValidateBasic implements sdk.Msg
func (*MsgAcknowledgement) XXX_DiscardUnknown ¶
func (m *MsgAcknowledgement) XXX_DiscardUnknown()
func (*MsgAcknowledgement) XXX_Marshal ¶
func (m *MsgAcknowledgement) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgAcknowledgement) XXX_Merge ¶
func (m *MsgAcknowledgement) XXX_Merge(src proto.Message)
func (*MsgAcknowledgement) XXX_Size ¶
func (m *MsgAcknowledgement) XXX_Size() int
func (*MsgAcknowledgement) XXX_Unmarshal ¶
func (m *MsgAcknowledgement) XXX_Unmarshal(b []byte) error
type MsgAcknowledgementResponse ¶
type MsgAcknowledgementResponse struct { }
MsgAcknowledgementResponse defines the Msg/Acknowledgement response type.
func (*MsgAcknowledgementResponse) Descriptor ¶
func (*MsgAcknowledgementResponse) Descriptor() ([]byte, []int)
func (*MsgAcknowledgementResponse) Marshal ¶
func (m *MsgAcknowledgementResponse) Marshal() (dAtA []byte, err error)
func (*MsgAcknowledgementResponse) MarshalTo ¶
func (m *MsgAcknowledgementResponse) MarshalTo(dAtA []byte) (int, error)
func (*MsgAcknowledgementResponse) MarshalToSizedBuffer ¶
func (m *MsgAcknowledgementResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgAcknowledgementResponse) ProtoMessage ¶
func (*MsgAcknowledgementResponse) ProtoMessage()
func (*MsgAcknowledgementResponse) Reset ¶
func (m *MsgAcknowledgementResponse) Reset()
func (*MsgAcknowledgementResponse) Size ¶
func (m *MsgAcknowledgementResponse) Size() (n int)
func (*MsgAcknowledgementResponse) String ¶
func (m *MsgAcknowledgementResponse) String() string
func (*MsgAcknowledgementResponse) Unmarshal ¶
func (m *MsgAcknowledgementResponse) Unmarshal(dAtA []byte) error
func (*MsgAcknowledgementResponse) XXX_DiscardUnknown ¶
func (m *MsgAcknowledgementResponse) XXX_DiscardUnknown()
func (*MsgAcknowledgementResponse) XXX_Marshal ¶
func (m *MsgAcknowledgementResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgAcknowledgementResponse) XXX_Merge ¶
func (m *MsgAcknowledgementResponse) XXX_Merge(src proto.Message)
func (*MsgAcknowledgementResponse) XXX_Size ¶
func (m *MsgAcknowledgementResponse) XXX_Size() int
func (*MsgAcknowledgementResponse) XXX_Unmarshal ¶
func (m *MsgAcknowledgementResponse) XXX_Unmarshal(b []byte) error
type MsgCleanPacket ¶
type MsgCleanPacket struct { CleanPacket CleanPacket `protobuf:"bytes,1,opt,name=clean_packet,json=cleanPacket,proto3" json:"clean_packet"` Signer string `protobuf:"bytes,2,opt,name=signer,proto3" json:"signer,omitempty"` }
MsgRecvPacket receives incoming TIBC packet
func NewMsgCleanPacket ¶
func NewMsgCleanPacket(packet CleanPacket, signer sdk.AccAddress) *MsgCleanPacket
NewMsgCleanPacket constructs new MsgCleanPacket nolint:interfacer
func (*MsgCleanPacket) Descriptor ¶
func (*MsgCleanPacket) Descriptor() ([]byte, []int)
func (MsgCleanPacket) GetSigners ¶
func (msg MsgCleanPacket) GetSigners() []sdk.AccAddress
GetSigners implements sdk.Msg
func (*MsgCleanPacket) Marshal ¶
func (m *MsgCleanPacket) Marshal() (dAtA []byte, err error)
func (*MsgCleanPacket) MarshalToSizedBuffer ¶
func (m *MsgCleanPacket) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgCleanPacket) ProtoMessage ¶
func (*MsgCleanPacket) ProtoMessage()
func (*MsgCleanPacket) Reset ¶
func (m *MsgCleanPacket) Reset()
func (*MsgCleanPacket) Size ¶
func (m *MsgCleanPacket) Size() (n int)
func (*MsgCleanPacket) String ¶
func (m *MsgCleanPacket) String() string
func (*MsgCleanPacket) Unmarshal ¶
func (m *MsgCleanPacket) Unmarshal(dAtA []byte) error
func (MsgCleanPacket) ValidateBasic ¶
func (msg MsgCleanPacket) ValidateBasic() error
ValidateBasic implements sdk.Msg
func (*MsgCleanPacket) XXX_DiscardUnknown ¶
func (m *MsgCleanPacket) XXX_DiscardUnknown()
func (*MsgCleanPacket) XXX_Marshal ¶
func (m *MsgCleanPacket) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgCleanPacket) XXX_Merge ¶
func (m *MsgCleanPacket) XXX_Merge(src proto.Message)
func (*MsgCleanPacket) XXX_Size ¶
func (m *MsgCleanPacket) XXX_Size() int
func (*MsgCleanPacket) XXX_Unmarshal ¶
func (m *MsgCleanPacket) XXX_Unmarshal(b []byte) error
type MsgCleanPacketResponse ¶
type MsgCleanPacketResponse struct { }
MsgRecvPacketResponse defines the Msg/RecvPacket response type.
func (*MsgCleanPacketResponse) Descriptor ¶
func (*MsgCleanPacketResponse) Descriptor() ([]byte, []int)
func (*MsgCleanPacketResponse) Marshal ¶
func (m *MsgCleanPacketResponse) Marshal() (dAtA []byte, err error)
func (*MsgCleanPacketResponse) MarshalTo ¶
func (m *MsgCleanPacketResponse) MarshalTo(dAtA []byte) (int, error)
func (*MsgCleanPacketResponse) MarshalToSizedBuffer ¶
func (m *MsgCleanPacketResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgCleanPacketResponse) ProtoMessage ¶
func (*MsgCleanPacketResponse) ProtoMessage()
func (*MsgCleanPacketResponse) Reset ¶
func (m *MsgCleanPacketResponse) Reset()
func (*MsgCleanPacketResponse) Size ¶
func (m *MsgCleanPacketResponse) Size() (n int)
func (*MsgCleanPacketResponse) String ¶
func (m *MsgCleanPacketResponse) String() string
func (*MsgCleanPacketResponse) Unmarshal ¶
func (m *MsgCleanPacketResponse) Unmarshal(dAtA []byte) error
func (*MsgCleanPacketResponse) XXX_DiscardUnknown ¶
func (m *MsgCleanPacketResponse) XXX_DiscardUnknown()
func (*MsgCleanPacketResponse) XXX_Marshal ¶
func (m *MsgCleanPacketResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgCleanPacketResponse) XXX_Merge ¶
func (m *MsgCleanPacketResponse) XXX_Merge(src proto.Message)
func (*MsgCleanPacketResponse) XXX_Size ¶
func (m *MsgCleanPacketResponse) XXX_Size() int
func (*MsgCleanPacketResponse) XXX_Unmarshal ¶
func (m *MsgCleanPacketResponse) XXX_Unmarshal(b []byte) error
type MsgClient ¶
type MsgClient interface { // RecvPacket defines a rpc handler method for MsgRecvPacket. RecvPacket(ctx context.Context, in *MsgRecvPacket, opts ...grpc.CallOption) (*MsgRecvPacketResponse, error) // Acknowledgement defines a rpc handler method for MsgAcknowledgement. Acknowledgement(ctx context.Context, in *MsgAcknowledgement, opts ...grpc.CallOption) (*MsgAcknowledgementResponse, error) // CleanPacket defines a rpc handler method for MsgCleanPacket. CleanPacket(ctx context.Context, in *MsgCleanPacket, opts ...grpc.CallOption) (*MsgCleanPacketResponse, error) // RecvCleanPacket defines a rpc handler method for MsgRecvCleanPacket. RecvCleanPacket(ctx context.Context, in *MsgRecvCleanPacket, opts ...grpc.CallOption) (*MsgRecvCleanPacketResponse, error) }
MsgClient is the client API for Msg service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewMsgClient ¶
func NewMsgClient(cc grpc1.ClientConn) MsgClient
type MsgRecvCleanPacket ¶
type MsgRecvCleanPacket struct { CleanPacket CleanPacket `protobuf:"bytes,1,opt,name=clean_packet,json=cleanPacket,proto3" json:"clean_packet"` ProofCommitment []byte `` /* 130-byte string literal not displayed */ ProofHeight types.Height `protobuf:"bytes,3,opt,name=proof_height,json=proofHeight,proto3" json:"proof_height" yaml:"proof_height"` Signer string `protobuf:"bytes,4,opt,name=signer,proto3" json:"signer,omitempty"` }
MsgRecvPacket receives incoming TIBC packet
func NewMsgRecvCleanPacket ¶
func NewMsgRecvCleanPacket( cleanPacket CleanPacket, proofCommitment []byte, proofHeight clienttypes.Height, signer sdk.AccAddress, ) *MsgRecvCleanPacket
NewMsgCleanPacket constructs new MsgCleanPacket nolint:interfacer
func (*MsgRecvCleanPacket) Descriptor ¶
func (*MsgRecvCleanPacket) Descriptor() ([]byte, []int)
func (MsgRecvCleanPacket) GetSigners ¶
func (msg MsgRecvCleanPacket) GetSigners() []sdk.AccAddress
GetSigners implements sdk.Msg
func (*MsgRecvCleanPacket) Marshal ¶
func (m *MsgRecvCleanPacket) Marshal() (dAtA []byte, err error)
func (*MsgRecvCleanPacket) MarshalTo ¶
func (m *MsgRecvCleanPacket) MarshalTo(dAtA []byte) (int, error)
func (*MsgRecvCleanPacket) MarshalToSizedBuffer ¶
func (m *MsgRecvCleanPacket) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgRecvCleanPacket) ProtoMessage ¶
func (*MsgRecvCleanPacket) ProtoMessage()
func (*MsgRecvCleanPacket) Reset ¶
func (m *MsgRecvCleanPacket) Reset()
func (*MsgRecvCleanPacket) Size ¶
func (m *MsgRecvCleanPacket) Size() (n int)
func (*MsgRecvCleanPacket) String ¶
func (m *MsgRecvCleanPacket) String() string
func (*MsgRecvCleanPacket) Unmarshal ¶
func (m *MsgRecvCleanPacket) Unmarshal(dAtA []byte) error
func (MsgRecvCleanPacket) ValidateBasic ¶
func (msg MsgRecvCleanPacket) ValidateBasic() error
ValidateBasic implements sdk.Msg
func (*MsgRecvCleanPacket) XXX_DiscardUnknown ¶
func (m *MsgRecvCleanPacket) XXX_DiscardUnknown()
func (*MsgRecvCleanPacket) XXX_Marshal ¶
func (m *MsgRecvCleanPacket) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgRecvCleanPacket) XXX_Merge ¶
func (m *MsgRecvCleanPacket) XXX_Merge(src proto.Message)
func (*MsgRecvCleanPacket) XXX_Size ¶
func (m *MsgRecvCleanPacket) XXX_Size() int
func (*MsgRecvCleanPacket) XXX_Unmarshal ¶
func (m *MsgRecvCleanPacket) XXX_Unmarshal(b []byte) error
type MsgRecvCleanPacketResponse ¶
type MsgRecvCleanPacketResponse struct { }
MsgRecvPacketResponse defines the Msg/RecvPacket response type.
func (*MsgRecvCleanPacketResponse) Descriptor ¶
func (*MsgRecvCleanPacketResponse) Descriptor() ([]byte, []int)
func (*MsgRecvCleanPacketResponse) Marshal ¶
func (m *MsgRecvCleanPacketResponse) Marshal() (dAtA []byte, err error)
func (*MsgRecvCleanPacketResponse) MarshalTo ¶
func (m *MsgRecvCleanPacketResponse) MarshalTo(dAtA []byte) (int, error)
func (*MsgRecvCleanPacketResponse) MarshalToSizedBuffer ¶
func (m *MsgRecvCleanPacketResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgRecvCleanPacketResponse) ProtoMessage ¶
func (*MsgRecvCleanPacketResponse) ProtoMessage()
func (*MsgRecvCleanPacketResponse) Reset ¶
func (m *MsgRecvCleanPacketResponse) Reset()
func (*MsgRecvCleanPacketResponse) Size ¶
func (m *MsgRecvCleanPacketResponse) Size() (n int)
func (*MsgRecvCleanPacketResponse) String ¶
func (m *MsgRecvCleanPacketResponse) String() string
func (*MsgRecvCleanPacketResponse) Unmarshal ¶
func (m *MsgRecvCleanPacketResponse) Unmarshal(dAtA []byte) error
func (*MsgRecvCleanPacketResponse) XXX_DiscardUnknown ¶
func (m *MsgRecvCleanPacketResponse) XXX_DiscardUnknown()
func (*MsgRecvCleanPacketResponse) XXX_Marshal ¶
func (m *MsgRecvCleanPacketResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgRecvCleanPacketResponse) XXX_Merge ¶
func (m *MsgRecvCleanPacketResponse) XXX_Merge(src proto.Message)
func (*MsgRecvCleanPacketResponse) XXX_Size ¶
func (m *MsgRecvCleanPacketResponse) XXX_Size() int
func (*MsgRecvCleanPacketResponse) XXX_Unmarshal ¶
func (m *MsgRecvCleanPacketResponse) XXX_Unmarshal(b []byte) error
type MsgRecvPacket ¶
type MsgRecvPacket struct { Packet Packet `protobuf:"bytes,1,opt,name=packet,proto3" json:"packet"` ProofCommitment []byte `` /* 130-byte string literal not displayed */ ProofHeight types.Height `protobuf:"bytes,3,opt,name=proof_height,json=proofHeight,proto3" json:"proof_height" yaml:"proof_height"` Signer string `protobuf:"bytes,4,opt,name=signer,proto3" json:"signer,omitempty"` }
MsgRecvPacket receives incoming TIBC packet
func NewMsgRecvPacket ¶
func NewMsgRecvPacket( packet Packet, proofCommitment []byte, proofHeight clienttypes.Height, signer sdk.AccAddress, ) *MsgRecvPacket
NewMsgRecvPacket constructs new MsgRecvPacket nolint:interfacer
func (*MsgRecvPacket) Descriptor ¶
func (*MsgRecvPacket) Descriptor() ([]byte, []int)
func (MsgRecvPacket) GetDataSignBytes ¶
func (msg MsgRecvPacket) GetDataSignBytes() []byte
GetDataSignBytes returns the base64-encoded bytes used for the data field when signing the packet.
func (MsgRecvPacket) GetSigners ¶
func (msg MsgRecvPacket) GetSigners() []sdk.AccAddress
GetSigners implements sdk.Msg
func (*MsgRecvPacket) Marshal ¶
func (m *MsgRecvPacket) Marshal() (dAtA []byte, err error)
func (*MsgRecvPacket) MarshalToSizedBuffer ¶
func (m *MsgRecvPacket) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgRecvPacket) ProtoMessage ¶
func (*MsgRecvPacket) ProtoMessage()
func (*MsgRecvPacket) Reset ¶
func (m *MsgRecvPacket) Reset()
func (*MsgRecvPacket) Size ¶
func (m *MsgRecvPacket) Size() (n int)
func (*MsgRecvPacket) String ¶
func (m *MsgRecvPacket) String() string
func (*MsgRecvPacket) Unmarshal ¶
func (m *MsgRecvPacket) Unmarshal(dAtA []byte) error
func (MsgRecvPacket) ValidateBasic ¶
func (msg MsgRecvPacket) ValidateBasic() error
ValidateBasic implements sdk.Msg
func (*MsgRecvPacket) XXX_DiscardUnknown ¶
func (m *MsgRecvPacket) XXX_DiscardUnknown()
func (*MsgRecvPacket) XXX_Marshal ¶
func (m *MsgRecvPacket) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgRecvPacket) XXX_Merge ¶
func (m *MsgRecvPacket) XXX_Merge(src proto.Message)
func (*MsgRecvPacket) XXX_Size ¶
func (m *MsgRecvPacket) XXX_Size() int
func (*MsgRecvPacket) XXX_Unmarshal ¶
func (m *MsgRecvPacket) XXX_Unmarshal(b []byte) error
type MsgRecvPacketResponse ¶
type MsgRecvPacketResponse struct { }
MsgRecvPacketResponse defines the Msg/RecvPacket response type.
func (*MsgRecvPacketResponse) Descriptor ¶
func (*MsgRecvPacketResponse) Descriptor() ([]byte, []int)
func (*MsgRecvPacketResponse) Marshal ¶
func (m *MsgRecvPacketResponse) Marshal() (dAtA []byte, err error)
func (*MsgRecvPacketResponse) MarshalTo ¶
func (m *MsgRecvPacketResponse) MarshalTo(dAtA []byte) (int, error)
func (*MsgRecvPacketResponse) MarshalToSizedBuffer ¶
func (m *MsgRecvPacketResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgRecvPacketResponse) ProtoMessage ¶
func (*MsgRecvPacketResponse) ProtoMessage()
func (*MsgRecvPacketResponse) Reset ¶
func (m *MsgRecvPacketResponse) Reset()
func (*MsgRecvPacketResponse) Size ¶
func (m *MsgRecvPacketResponse) Size() (n int)
func (*MsgRecvPacketResponse) String ¶
func (m *MsgRecvPacketResponse) String() string
func (*MsgRecvPacketResponse) Unmarshal ¶
func (m *MsgRecvPacketResponse) Unmarshal(dAtA []byte) error
func (*MsgRecvPacketResponse) XXX_DiscardUnknown ¶
func (m *MsgRecvPacketResponse) XXX_DiscardUnknown()
func (*MsgRecvPacketResponse) XXX_Marshal ¶
func (m *MsgRecvPacketResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgRecvPacketResponse) XXX_Merge ¶
func (m *MsgRecvPacketResponse) XXX_Merge(src proto.Message)
func (*MsgRecvPacketResponse) XXX_Size ¶
func (m *MsgRecvPacketResponse) XXX_Size() int
func (*MsgRecvPacketResponse) XXX_Unmarshal ¶
func (m *MsgRecvPacketResponse) XXX_Unmarshal(b []byte) error
type MsgServer ¶
type MsgServer interface { // RecvPacket defines a rpc handler method for MsgRecvPacket. RecvPacket(context.Context, *MsgRecvPacket) (*MsgRecvPacketResponse, error) // Acknowledgement defines a rpc handler method for MsgAcknowledgement. Acknowledgement(context.Context, *MsgAcknowledgement) (*MsgAcknowledgementResponse, error) // CleanPacket defines a rpc handler method for MsgCleanPacket. CleanPacket(context.Context, *MsgCleanPacket) (*MsgCleanPacketResponse, error) // RecvCleanPacket defines a rpc handler method for MsgRecvCleanPacket. RecvCleanPacket(context.Context, *MsgRecvCleanPacket) (*MsgRecvCleanPacketResponse, error) }
MsgServer is the server API for Msg service.
type Packet ¶
type Packet struct { // number corresponds to the order of sends and receives, where a Packet // with an earlier sequence number must be sent and received before a Packet // with a later sequence number. Sequence uint64 `protobuf:"varint,1,opt,name=sequence,proto3" json:"sequence,omitempty"` // identifies the port on the sending chain and destination chain. Port string `protobuf:"bytes,2,opt,name=port,proto3" json:"port,omitempty"` // identifies the chain id of the sending chain. SourceChain string `protobuf:"bytes,3,opt,name=source_chain,json=sourceChain,proto3" json:"source_chain,omitempty" yaml:"source_chain"` // identifies the chain id of the receiving chain. DestinationChain string `` /* 133-byte string literal not displayed */ // identifies the chain id of the relay chain. RelayChain string `protobuf:"bytes,5,opt,name=relay_chain,json=relayChain,proto3" json:"relay_chain,omitempty" yaml:"relay_chain"` // actual opaque bytes transferred directly to the application module Data []byte `protobuf:"bytes,6,opt,name=data,proto3" json:"data,omitempty"` }
Packet defines a type that carries data across different chains through TIBC
func NewPacket ¶
func NewPacket( data []byte, sequence uint64, sourceChain, destinationChain, relayChain, port string, ) Packet
NewPacket creates a new Packet instance. It panics if the provided packet data interface is not registered.
func (*Packet) Descriptor ¶
func (Packet) 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 QueryCleanPacketCommitmentRequest ¶ added in v0.2.0
type QueryCleanPacketCommitmentRequest struct { // dest chain name DestChain string `protobuf:"bytes,1,opt,name=dest_chain,json=destChain,proto3" json:"dest_chain,omitempty"` // source chain name SourceChain string `protobuf:"bytes,2,opt,name=source_chain,json=sourceChain,proto3" json:"source_chain,omitempty"` }
QueryCleanPacketCommitmentRequest is the request type for the QueryCleanPacketCommitment RPC method
func (*QueryCleanPacketCommitmentRequest) Descriptor ¶ added in v0.2.0
func (*QueryCleanPacketCommitmentRequest) Descriptor() ([]byte, []int)
func (*QueryCleanPacketCommitmentRequest) GetDestChain ¶ added in v0.2.0
func (m *QueryCleanPacketCommitmentRequest) GetDestChain() string
func (*QueryCleanPacketCommitmentRequest) GetSourceChain ¶ added in v0.2.0
func (m *QueryCleanPacketCommitmentRequest) GetSourceChain() string
func (*QueryCleanPacketCommitmentRequest) Marshal ¶ added in v0.2.0
func (m *QueryCleanPacketCommitmentRequest) Marshal() (dAtA []byte, err error)
func (*QueryCleanPacketCommitmentRequest) MarshalTo ¶ added in v0.2.0
func (m *QueryCleanPacketCommitmentRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryCleanPacketCommitmentRequest) MarshalToSizedBuffer ¶ added in v0.2.0
func (m *QueryCleanPacketCommitmentRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryCleanPacketCommitmentRequest) ProtoMessage ¶ added in v0.2.0
func (*QueryCleanPacketCommitmentRequest) ProtoMessage()
func (*QueryCleanPacketCommitmentRequest) Reset ¶ added in v0.2.0
func (m *QueryCleanPacketCommitmentRequest) Reset()
func (*QueryCleanPacketCommitmentRequest) Size ¶ added in v0.2.0
func (m *QueryCleanPacketCommitmentRequest) Size() (n int)
func (*QueryCleanPacketCommitmentRequest) String ¶ added in v0.2.0
func (m *QueryCleanPacketCommitmentRequest) String() string
func (*QueryCleanPacketCommitmentRequest) Unmarshal ¶ added in v0.2.0
func (m *QueryCleanPacketCommitmentRequest) Unmarshal(dAtA []byte) error
func (*QueryCleanPacketCommitmentRequest) XXX_DiscardUnknown ¶ added in v0.2.0
func (m *QueryCleanPacketCommitmentRequest) XXX_DiscardUnknown()
func (*QueryCleanPacketCommitmentRequest) XXX_Marshal ¶ added in v0.2.0
func (m *QueryCleanPacketCommitmentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryCleanPacketCommitmentRequest) XXX_Merge ¶ added in v0.2.0
func (m *QueryCleanPacketCommitmentRequest) XXX_Merge(src proto.Message)
func (*QueryCleanPacketCommitmentRequest) XXX_Size ¶ added in v0.2.0
func (m *QueryCleanPacketCommitmentRequest) XXX_Size() int
func (*QueryCleanPacketCommitmentRequest) XXX_Unmarshal ¶ added in v0.2.0
func (m *QueryCleanPacketCommitmentRequest) XXX_Unmarshal(b []byte) error
type QueryCleanPacketCommitmentResponse ¶ added in v0.2.0
type QueryCleanPacketCommitmentResponse struct { // packet associated with the request fields Commitment []byte `protobuf:"bytes,1,opt,name=commitment,proto3" json:"commitment,omitempty"` // merkle proof of existence Proof []byte `protobuf:"bytes,2,opt,name=proof,proto3" json:"proof,omitempty"` // height at which the proof was retrieved ProofHeight types.Height `protobuf:"bytes,3,opt,name=proof_height,json=proofHeight,proto3" json:"proof_height"` }
QueryCleanPacketCommitmentResponse defines the client query response for a packet which also includes a proof and the height from which the proof was retrieved
func NewQueryCleanPacketCommitmentResponse ¶ added in v0.2.0
func NewQueryCleanPacketCommitmentResponse( commitment []byte, proof []byte, height clienttypes.Height, ) *QueryCleanPacketCommitmentResponse
NewQueryCleanPacketCommitmentResponse creates a new NewQueryCleanPacketCommitmentResponse instance
func (*QueryCleanPacketCommitmentResponse) Descriptor ¶ added in v0.2.0
func (*QueryCleanPacketCommitmentResponse) Descriptor() ([]byte, []int)
func (*QueryCleanPacketCommitmentResponse) GetCommitment ¶ added in v0.2.0
func (m *QueryCleanPacketCommitmentResponse) GetCommitment() []byte
func (*QueryCleanPacketCommitmentResponse) GetProof ¶ added in v0.2.0
func (m *QueryCleanPacketCommitmentResponse) GetProof() []byte
func (*QueryCleanPacketCommitmentResponse) GetProofHeight ¶ added in v0.2.0
func (m *QueryCleanPacketCommitmentResponse) GetProofHeight() types.Height
func (*QueryCleanPacketCommitmentResponse) Marshal ¶ added in v0.2.0
func (m *QueryCleanPacketCommitmentResponse) Marshal() (dAtA []byte, err error)
func (*QueryCleanPacketCommitmentResponse) MarshalTo ¶ added in v0.2.0
func (m *QueryCleanPacketCommitmentResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryCleanPacketCommitmentResponse) MarshalToSizedBuffer ¶ added in v0.2.0
func (m *QueryCleanPacketCommitmentResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryCleanPacketCommitmentResponse) ProtoMessage ¶ added in v0.2.0
func (*QueryCleanPacketCommitmentResponse) ProtoMessage()
func (*QueryCleanPacketCommitmentResponse) Reset ¶ added in v0.2.0
func (m *QueryCleanPacketCommitmentResponse) Reset()
func (*QueryCleanPacketCommitmentResponse) Size ¶ added in v0.2.0
func (m *QueryCleanPacketCommitmentResponse) Size() (n int)
func (*QueryCleanPacketCommitmentResponse) String ¶ added in v0.2.0
func (m *QueryCleanPacketCommitmentResponse) String() string
func (*QueryCleanPacketCommitmentResponse) Unmarshal ¶ added in v0.2.0
func (m *QueryCleanPacketCommitmentResponse) Unmarshal(dAtA []byte) error
func (*QueryCleanPacketCommitmentResponse) XXX_DiscardUnknown ¶ added in v0.2.0
func (m *QueryCleanPacketCommitmentResponse) XXX_DiscardUnknown()
func (*QueryCleanPacketCommitmentResponse) XXX_Marshal ¶ added in v0.2.0
func (m *QueryCleanPacketCommitmentResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryCleanPacketCommitmentResponse) XXX_Merge ¶ added in v0.2.0
func (m *QueryCleanPacketCommitmentResponse) XXX_Merge(src proto.Message)
func (*QueryCleanPacketCommitmentResponse) XXX_Size ¶ added in v0.2.0
func (m *QueryCleanPacketCommitmentResponse) XXX_Size() int
func (*QueryCleanPacketCommitmentResponse) XXX_Unmarshal ¶ added in v0.2.0
func (m *QueryCleanPacketCommitmentResponse) XXX_Unmarshal(b []byte) error
type QueryClient ¶
type QueryClient interface { // PacketCommitment queries a stored packet commitment hash. PacketCommitment(ctx context.Context, in *QueryPacketCommitmentRequest, opts ...grpc.CallOption) (*QueryPacketCommitmentResponse, error) // PacketCommitments returns all the packet commitments hashes associated PacketCommitments(ctx context.Context, in *QueryPacketCommitmentsRequest, opts ...grpc.CallOption) (*QueryPacketCommitmentsResponse, error) // PacketReceipt queries if a given packet sequence has been received on the queried chain PacketReceipt(ctx context.Context, in *QueryPacketReceiptRequest, opts ...grpc.CallOption) (*QueryPacketReceiptResponse, error) // PacketAcknowledgement queries a stored packet acknowledgement hash. PacketAcknowledgement(ctx context.Context, in *QueryPacketAcknowledgementRequest, opts ...grpc.CallOption) (*QueryPacketAcknowledgementResponse, error) // PacketAcknowledgements returns all the packet acknowledgements associated PacketAcknowledgements(ctx context.Context, in *QueryPacketAcknowledgementsRequest, opts ...grpc.CallOption) (*QueryPacketAcknowledgementsResponse, error) // UnreceivedPackets returns all the unreceived TIBC packets associated with sequences. UnreceivedPackets(ctx context.Context, in *QueryUnreceivedPacketsRequest, opts ...grpc.CallOption) (*QueryUnreceivedPacketsResponse, error) // UnreceivedAcks returns all the unreceived TIBC acknowledgements associated with sequences. UnreceivedAcks(ctx context.Context, in *QueryUnreceivedAcksRequest, opts ...grpc.CallOption) (*QueryUnreceivedAcksResponse, error) // CleanPacketCommitment queries a stored packet commitment hash. CleanPacketCommitment(ctx context.Context, in *QueryCleanPacketCommitmentRequest, opts ...grpc.CallOption) (*QueryCleanPacketCommitmentResponse, error) }
QueryClient is the client API for Query service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewQueryClient ¶
func NewQueryClient(cc grpc1.ClientConn) QueryClient
type QueryPacketAcknowledgementRequest ¶
type QueryPacketAcknowledgementRequest struct { // dest chain name DestChain string `protobuf:"bytes,1,opt,name=dest_chain,json=destChain,proto3" json:"dest_chain,omitempty"` // source chain name SourceChain string `protobuf:"bytes,2,opt,name=source_chain,json=sourceChain,proto3" json:"source_chain,omitempty"` // packet sequence Sequence uint64 `protobuf:"varint,3,opt,name=sequence,proto3" json:"sequence,omitempty"` }
QueryPacketAcknowledgementRequest is the request type for the Query/PacketAcknowledgement RPC method
func (*QueryPacketAcknowledgementRequest) Descriptor ¶
func (*QueryPacketAcknowledgementRequest) Descriptor() ([]byte, []int)
func (*QueryPacketAcknowledgementRequest) GetDestChain ¶
func (m *QueryPacketAcknowledgementRequest) GetDestChain() string
func (*QueryPacketAcknowledgementRequest) GetSequence ¶
func (m *QueryPacketAcknowledgementRequest) GetSequence() uint64
func (*QueryPacketAcknowledgementRequest) GetSourceChain ¶
func (m *QueryPacketAcknowledgementRequest) GetSourceChain() string
func (*QueryPacketAcknowledgementRequest) Marshal ¶
func (m *QueryPacketAcknowledgementRequest) Marshal() (dAtA []byte, err error)
func (*QueryPacketAcknowledgementRequest) MarshalTo ¶
func (m *QueryPacketAcknowledgementRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryPacketAcknowledgementRequest) MarshalToSizedBuffer ¶
func (m *QueryPacketAcknowledgementRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryPacketAcknowledgementRequest) ProtoMessage ¶
func (*QueryPacketAcknowledgementRequest) ProtoMessage()
func (*QueryPacketAcknowledgementRequest) Reset ¶
func (m *QueryPacketAcknowledgementRequest) Reset()
func (*QueryPacketAcknowledgementRequest) Size ¶
func (m *QueryPacketAcknowledgementRequest) Size() (n int)
func (*QueryPacketAcknowledgementRequest) String ¶
func (m *QueryPacketAcknowledgementRequest) String() string
func (*QueryPacketAcknowledgementRequest) Unmarshal ¶
func (m *QueryPacketAcknowledgementRequest) Unmarshal(dAtA []byte) error
func (*QueryPacketAcknowledgementRequest) XXX_DiscardUnknown ¶
func (m *QueryPacketAcknowledgementRequest) XXX_DiscardUnknown()
func (*QueryPacketAcknowledgementRequest) XXX_Marshal ¶
func (m *QueryPacketAcknowledgementRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryPacketAcknowledgementRequest) XXX_Merge ¶
func (m *QueryPacketAcknowledgementRequest) XXX_Merge(src proto.Message)
func (*QueryPacketAcknowledgementRequest) XXX_Size ¶
func (m *QueryPacketAcknowledgementRequest) XXX_Size() int
func (*QueryPacketAcknowledgementRequest) XXX_Unmarshal ¶
func (m *QueryPacketAcknowledgementRequest) XXX_Unmarshal(b []byte) error
type QueryPacketAcknowledgementResponse ¶
type QueryPacketAcknowledgementResponse struct { // packet associated with the request fields Acknowledgement []byte `protobuf:"bytes,1,opt,name=acknowledgement,proto3" json:"acknowledgement,omitempty"` // merkle proof of existence Proof []byte `protobuf:"bytes,2,opt,name=proof,proto3" json:"proof,omitempty"` // height at which the proof was retrieved ProofHeight types.Height `protobuf:"bytes,3,opt,name=proof_height,json=proofHeight,proto3" json:"proof_height"` }
QueryPacketAcknowledgementResponse defines the client query response for a packet which also includes a proof and the height from which the proof was retrieved
func NewQueryPacketAcknowledgementResponse ¶
func NewQueryPacketAcknowledgementResponse( acknowledgement []byte, proof []byte, height clienttypes.Height, ) *QueryPacketAcknowledgementResponse
NewQueryPacketAcknowledgementResponse creates a new QueryPacketAcknowledgementResponse instance
func (*QueryPacketAcknowledgementResponse) Descriptor ¶
func (*QueryPacketAcknowledgementResponse) Descriptor() ([]byte, []int)
func (*QueryPacketAcknowledgementResponse) GetAcknowledgement ¶
func (m *QueryPacketAcknowledgementResponse) GetAcknowledgement() []byte
func (*QueryPacketAcknowledgementResponse) GetProof ¶
func (m *QueryPacketAcknowledgementResponse) GetProof() []byte
func (*QueryPacketAcknowledgementResponse) GetProofHeight ¶
func (m *QueryPacketAcknowledgementResponse) GetProofHeight() types.Height
func (*QueryPacketAcknowledgementResponse) Marshal ¶
func (m *QueryPacketAcknowledgementResponse) Marshal() (dAtA []byte, err error)
func (*QueryPacketAcknowledgementResponse) MarshalTo ¶
func (m *QueryPacketAcknowledgementResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryPacketAcknowledgementResponse) MarshalToSizedBuffer ¶
func (m *QueryPacketAcknowledgementResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryPacketAcknowledgementResponse) ProtoMessage ¶
func (*QueryPacketAcknowledgementResponse) ProtoMessage()
func (*QueryPacketAcknowledgementResponse) Reset ¶
func (m *QueryPacketAcknowledgementResponse) Reset()
func (*QueryPacketAcknowledgementResponse) Size ¶
func (m *QueryPacketAcknowledgementResponse) Size() (n int)
func (*QueryPacketAcknowledgementResponse) String ¶
func (m *QueryPacketAcknowledgementResponse) String() string
func (*QueryPacketAcknowledgementResponse) Unmarshal ¶
func (m *QueryPacketAcknowledgementResponse) Unmarshal(dAtA []byte) error
func (*QueryPacketAcknowledgementResponse) XXX_DiscardUnknown ¶
func (m *QueryPacketAcknowledgementResponse) XXX_DiscardUnknown()
func (*QueryPacketAcknowledgementResponse) XXX_Marshal ¶
func (m *QueryPacketAcknowledgementResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryPacketAcknowledgementResponse) XXX_Merge ¶
func (m *QueryPacketAcknowledgementResponse) XXX_Merge(src proto.Message)
func (*QueryPacketAcknowledgementResponse) XXX_Size ¶
func (m *QueryPacketAcknowledgementResponse) XXX_Size() int
func (*QueryPacketAcknowledgementResponse) XXX_Unmarshal ¶
func (m *QueryPacketAcknowledgementResponse) XXX_Unmarshal(b []byte) error
type QueryPacketAcknowledgementsRequest ¶
type QueryPacketAcknowledgementsRequest struct { // dest chain name DestChain string `protobuf:"bytes,1,opt,name=dest_chain,json=destChain,proto3" json:"dest_chain,omitempty"` // source chain name SourceChain string `protobuf:"bytes,2,opt,name=source_chain,json=sourceChain,proto3" json:"source_chain,omitempty"` // pagination request Pagination *query.PageRequest `protobuf:"bytes,3,opt,name=pagination,proto3" json:"pagination,omitempty"` }
QueryPacketAcknowledgementsRequest is the request type for the Query/QueryPacketCommitments RPC method
func (*QueryPacketAcknowledgementsRequest) Descriptor ¶
func (*QueryPacketAcknowledgementsRequest) Descriptor() ([]byte, []int)
func (*QueryPacketAcknowledgementsRequest) GetDestChain ¶
func (m *QueryPacketAcknowledgementsRequest) GetDestChain() string
func (*QueryPacketAcknowledgementsRequest) GetPagination ¶
func (m *QueryPacketAcknowledgementsRequest) GetPagination() *query.PageRequest
func (*QueryPacketAcknowledgementsRequest) GetSourceChain ¶
func (m *QueryPacketAcknowledgementsRequest) GetSourceChain() string
func (*QueryPacketAcknowledgementsRequest) Marshal ¶
func (m *QueryPacketAcknowledgementsRequest) Marshal() (dAtA []byte, err error)
func (*QueryPacketAcknowledgementsRequest) MarshalTo ¶
func (m *QueryPacketAcknowledgementsRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryPacketAcknowledgementsRequest) MarshalToSizedBuffer ¶
func (m *QueryPacketAcknowledgementsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryPacketAcknowledgementsRequest) ProtoMessage ¶
func (*QueryPacketAcknowledgementsRequest) ProtoMessage()
func (*QueryPacketAcknowledgementsRequest) Reset ¶
func (m *QueryPacketAcknowledgementsRequest) Reset()
func (*QueryPacketAcknowledgementsRequest) Size ¶
func (m *QueryPacketAcknowledgementsRequest) Size() (n int)
func (*QueryPacketAcknowledgementsRequest) String ¶
func (m *QueryPacketAcknowledgementsRequest) String() string
func (*QueryPacketAcknowledgementsRequest) Unmarshal ¶
func (m *QueryPacketAcknowledgementsRequest) Unmarshal(dAtA []byte) error
func (*QueryPacketAcknowledgementsRequest) XXX_DiscardUnknown ¶
func (m *QueryPacketAcknowledgementsRequest) XXX_DiscardUnknown()
func (*QueryPacketAcknowledgementsRequest) XXX_Marshal ¶
func (m *QueryPacketAcknowledgementsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryPacketAcknowledgementsRequest) XXX_Merge ¶
func (m *QueryPacketAcknowledgementsRequest) XXX_Merge(src proto.Message)
func (*QueryPacketAcknowledgementsRequest) XXX_Size ¶
func (m *QueryPacketAcknowledgementsRequest) XXX_Size() int
func (*QueryPacketAcknowledgementsRequest) XXX_Unmarshal ¶
func (m *QueryPacketAcknowledgementsRequest) XXX_Unmarshal(b []byte) error
type QueryPacketAcknowledgementsResponse ¶
type QueryPacketAcknowledgementsResponse struct { Acknowledgements []*PacketState `protobuf:"bytes,1,rep,name=acknowledgements,proto3" json:"acknowledgements,omitempty"` // pagination response Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"` // query block height Height types.Height `protobuf:"bytes,3,opt,name=height,proto3" json:"height"` }
QueryPacketAcknowledgemetsResponse is the request type for the Query/QueryPacketAcknowledgements RPC method
func (*QueryPacketAcknowledgementsResponse) Descriptor ¶
func (*QueryPacketAcknowledgementsResponse) Descriptor() ([]byte, []int)
func (*QueryPacketAcknowledgementsResponse) GetAcknowledgements ¶
func (m *QueryPacketAcknowledgementsResponse) GetAcknowledgements() []*PacketState
func (*QueryPacketAcknowledgementsResponse) GetHeight ¶
func (m *QueryPacketAcknowledgementsResponse) GetHeight() types.Height
func (*QueryPacketAcknowledgementsResponse) GetPagination ¶
func (m *QueryPacketAcknowledgementsResponse) GetPagination() *query.PageResponse
func (*QueryPacketAcknowledgementsResponse) Marshal ¶
func (m *QueryPacketAcknowledgementsResponse) Marshal() (dAtA []byte, err error)
func (*QueryPacketAcknowledgementsResponse) MarshalTo ¶
func (m *QueryPacketAcknowledgementsResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryPacketAcknowledgementsResponse) MarshalToSizedBuffer ¶
func (m *QueryPacketAcknowledgementsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryPacketAcknowledgementsResponse) ProtoMessage ¶
func (*QueryPacketAcknowledgementsResponse) ProtoMessage()
func (*QueryPacketAcknowledgementsResponse) Reset ¶
func (m *QueryPacketAcknowledgementsResponse) Reset()
func (*QueryPacketAcknowledgementsResponse) Size ¶
func (m *QueryPacketAcknowledgementsResponse) Size() (n int)
func (*QueryPacketAcknowledgementsResponse) String ¶
func (m *QueryPacketAcknowledgementsResponse) String() string
func (*QueryPacketAcknowledgementsResponse) Unmarshal ¶
func (m *QueryPacketAcknowledgementsResponse) Unmarshal(dAtA []byte) error
func (*QueryPacketAcknowledgementsResponse) XXX_DiscardUnknown ¶
func (m *QueryPacketAcknowledgementsResponse) XXX_DiscardUnknown()
func (*QueryPacketAcknowledgementsResponse) XXX_Marshal ¶
func (m *QueryPacketAcknowledgementsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryPacketAcknowledgementsResponse) XXX_Merge ¶
func (m *QueryPacketAcknowledgementsResponse) XXX_Merge(src proto.Message)
func (*QueryPacketAcknowledgementsResponse) XXX_Size ¶
func (m *QueryPacketAcknowledgementsResponse) XXX_Size() int
func (*QueryPacketAcknowledgementsResponse) XXX_Unmarshal ¶
func (m *QueryPacketAcknowledgementsResponse) XXX_Unmarshal(b []byte) error
type QueryPacketCommitmentRequest ¶
type QueryPacketCommitmentRequest struct { // dest chain name DestChain string `protobuf:"bytes,1,opt,name=dest_chain,json=destChain,proto3" json:"dest_chain,omitempty"` // source chain name SourceChain string `protobuf:"bytes,2,opt,name=source_chain,json=sourceChain,proto3" json:"source_chain,omitempty"` // packet sequence Sequence uint64 `protobuf:"varint,3,opt,name=sequence,proto3" json:"sequence,omitempty"` }
QueryPacketCommitmentRequest is the request type for the QueryPacketCommitment RPC method
func (*QueryPacketCommitmentRequest) Descriptor ¶
func (*QueryPacketCommitmentRequest) Descriptor() ([]byte, []int)
func (*QueryPacketCommitmentRequest) GetDestChain ¶
func (m *QueryPacketCommitmentRequest) GetDestChain() string
func (*QueryPacketCommitmentRequest) GetSequence ¶
func (m *QueryPacketCommitmentRequest) GetSequence() uint64
func (*QueryPacketCommitmentRequest) GetSourceChain ¶
func (m *QueryPacketCommitmentRequest) GetSourceChain() string
func (*QueryPacketCommitmentRequest) Marshal ¶
func (m *QueryPacketCommitmentRequest) Marshal() (dAtA []byte, err error)
func (*QueryPacketCommitmentRequest) MarshalTo ¶
func (m *QueryPacketCommitmentRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryPacketCommitmentRequest) MarshalToSizedBuffer ¶
func (m *QueryPacketCommitmentRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryPacketCommitmentRequest) ProtoMessage ¶
func (*QueryPacketCommitmentRequest) ProtoMessage()
func (*QueryPacketCommitmentRequest) Reset ¶
func (m *QueryPacketCommitmentRequest) Reset()
func (*QueryPacketCommitmentRequest) Size ¶
func (m *QueryPacketCommitmentRequest) Size() (n int)
func (*QueryPacketCommitmentRequest) String ¶
func (m *QueryPacketCommitmentRequest) String() string
func (*QueryPacketCommitmentRequest) Unmarshal ¶
func (m *QueryPacketCommitmentRequest) Unmarshal(dAtA []byte) error
func (*QueryPacketCommitmentRequest) XXX_DiscardUnknown ¶
func (m *QueryPacketCommitmentRequest) XXX_DiscardUnknown()
func (*QueryPacketCommitmentRequest) XXX_Marshal ¶
func (m *QueryPacketCommitmentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryPacketCommitmentRequest) XXX_Merge ¶
func (m *QueryPacketCommitmentRequest) XXX_Merge(src proto.Message)
func (*QueryPacketCommitmentRequest) XXX_Size ¶
func (m *QueryPacketCommitmentRequest) XXX_Size() int
func (*QueryPacketCommitmentRequest) XXX_Unmarshal ¶
func (m *QueryPacketCommitmentRequest) XXX_Unmarshal(b []byte) error
type QueryPacketCommitmentResponse ¶
type QueryPacketCommitmentResponse struct { // packet associated with the request fields Commitment []byte `protobuf:"bytes,1,opt,name=commitment,proto3" json:"commitment,omitempty"` // merkle proof of existence Proof []byte `protobuf:"bytes,2,opt,name=proof,proto3" json:"proof,omitempty"` // height at which the proof was retrieved ProofHeight types.Height `protobuf:"bytes,3,opt,name=proof_height,json=proofHeight,proto3" json:"proof_height"` }
QueryPacketCommitmentResponse defines the client query response for a packet which also includes a proof and the height from which the proof was retrieved
func NewQueryPacketCommitmentResponse ¶
func NewQueryPacketCommitmentResponse( commitment []byte, proof []byte, height clienttypes.Height, ) *QueryPacketCommitmentResponse
NewQueryPacketCommitmentResponse creates a new QueryPacketCommitmentResponse instance
func (*QueryPacketCommitmentResponse) Descriptor ¶
func (*QueryPacketCommitmentResponse) Descriptor() ([]byte, []int)
func (*QueryPacketCommitmentResponse) GetCommitment ¶
func (m *QueryPacketCommitmentResponse) GetCommitment() []byte
func (*QueryPacketCommitmentResponse) GetProof ¶
func (m *QueryPacketCommitmentResponse) GetProof() []byte
func (*QueryPacketCommitmentResponse) GetProofHeight ¶
func (m *QueryPacketCommitmentResponse) GetProofHeight() types.Height
func (*QueryPacketCommitmentResponse) Marshal ¶
func (m *QueryPacketCommitmentResponse) Marshal() (dAtA []byte, err error)
func (*QueryPacketCommitmentResponse) MarshalTo ¶
func (m *QueryPacketCommitmentResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryPacketCommitmentResponse) MarshalToSizedBuffer ¶
func (m *QueryPacketCommitmentResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryPacketCommitmentResponse) ProtoMessage ¶
func (*QueryPacketCommitmentResponse) ProtoMessage()
func (*QueryPacketCommitmentResponse) Reset ¶
func (m *QueryPacketCommitmentResponse) Reset()
func (*QueryPacketCommitmentResponse) Size ¶
func (m *QueryPacketCommitmentResponse) Size() (n int)
func (*QueryPacketCommitmentResponse) String ¶
func (m *QueryPacketCommitmentResponse) String() string
func (*QueryPacketCommitmentResponse) Unmarshal ¶
func (m *QueryPacketCommitmentResponse) Unmarshal(dAtA []byte) error
func (*QueryPacketCommitmentResponse) XXX_DiscardUnknown ¶
func (m *QueryPacketCommitmentResponse) XXX_DiscardUnknown()
func (*QueryPacketCommitmentResponse) XXX_Marshal ¶
func (m *QueryPacketCommitmentResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryPacketCommitmentResponse) XXX_Merge ¶
func (m *QueryPacketCommitmentResponse) XXX_Merge(src proto.Message)
func (*QueryPacketCommitmentResponse) XXX_Size ¶
func (m *QueryPacketCommitmentResponse) XXX_Size() int
func (*QueryPacketCommitmentResponse) XXX_Unmarshal ¶
func (m *QueryPacketCommitmentResponse) XXX_Unmarshal(b []byte) error
type QueryPacketCommitmentsRequest ¶
type QueryPacketCommitmentsRequest struct { // dest chain name DestChain string `protobuf:"bytes,1,opt,name=dest_chain,json=destChain,proto3" json:"dest_chain,omitempty"` // source chain name SourceChain string `protobuf:"bytes,2,opt,name=source_chain,json=sourceChain,proto3" json:"source_chain,omitempty"` // pagination request Pagination *query.PageRequest `protobuf:"bytes,3,opt,name=pagination,proto3" json:"pagination,omitempty"` }
QueryPacketCommitmentsRequest is the request type for the Query/QueryPacketCommitments RPC method
func (*QueryPacketCommitmentsRequest) Descriptor ¶
func (*QueryPacketCommitmentsRequest) Descriptor() ([]byte, []int)
func (*QueryPacketCommitmentsRequest) GetDestChain ¶
func (m *QueryPacketCommitmentsRequest) GetDestChain() string
func (*QueryPacketCommitmentsRequest) GetPagination ¶
func (m *QueryPacketCommitmentsRequest) GetPagination() *query.PageRequest
func (*QueryPacketCommitmentsRequest) GetSourceChain ¶
func (m *QueryPacketCommitmentsRequest) GetSourceChain() string
func (*QueryPacketCommitmentsRequest) Marshal ¶
func (m *QueryPacketCommitmentsRequest) Marshal() (dAtA []byte, err error)
func (*QueryPacketCommitmentsRequest) MarshalTo ¶
func (m *QueryPacketCommitmentsRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryPacketCommitmentsRequest) MarshalToSizedBuffer ¶
func (m *QueryPacketCommitmentsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryPacketCommitmentsRequest) ProtoMessage ¶
func (*QueryPacketCommitmentsRequest) ProtoMessage()
func (*QueryPacketCommitmentsRequest) Reset ¶
func (m *QueryPacketCommitmentsRequest) Reset()
func (*QueryPacketCommitmentsRequest) Size ¶
func (m *QueryPacketCommitmentsRequest) Size() (n int)
func (*QueryPacketCommitmentsRequest) String ¶
func (m *QueryPacketCommitmentsRequest) String() string
func (*QueryPacketCommitmentsRequest) Unmarshal ¶
func (m *QueryPacketCommitmentsRequest) Unmarshal(dAtA []byte) error
func (*QueryPacketCommitmentsRequest) XXX_DiscardUnknown ¶
func (m *QueryPacketCommitmentsRequest) XXX_DiscardUnknown()
func (*QueryPacketCommitmentsRequest) XXX_Marshal ¶
func (m *QueryPacketCommitmentsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryPacketCommitmentsRequest) XXX_Merge ¶
func (m *QueryPacketCommitmentsRequest) XXX_Merge(src proto.Message)
func (*QueryPacketCommitmentsRequest) XXX_Size ¶
func (m *QueryPacketCommitmentsRequest) XXX_Size() int
func (*QueryPacketCommitmentsRequest) XXX_Unmarshal ¶
func (m *QueryPacketCommitmentsRequest) XXX_Unmarshal(b []byte) error
type QueryPacketCommitmentsResponse ¶
type QueryPacketCommitmentsResponse struct { Commitments []*PacketState `protobuf:"bytes,1,rep,name=commitments,proto3" json:"commitments,omitempty"` // pagination response Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"` // query block height Height types.Height `protobuf:"bytes,3,opt,name=height,proto3" json:"height"` }
QueryPacketCommitmentsResponse is the request type for the Query/QueryPacketCommitments RPC method
func (*QueryPacketCommitmentsResponse) Descriptor ¶
func (*QueryPacketCommitmentsResponse) Descriptor() ([]byte, []int)
func (*QueryPacketCommitmentsResponse) GetCommitments ¶
func (m *QueryPacketCommitmentsResponse) GetCommitments() []*PacketState
func (*QueryPacketCommitmentsResponse) GetHeight ¶
func (m *QueryPacketCommitmentsResponse) GetHeight() types.Height
func (*QueryPacketCommitmentsResponse) GetPagination ¶
func (m *QueryPacketCommitmentsResponse) GetPagination() *query.PageResponse
func (*QueryPacketCommitmentsResponse) Marshal ¶
func (m *QueryPacketCommitmentsResponse) Marshal() (dAtA []byte, err error)
func (*QueryPacketCommitmentsResponse) MarshalTo ¶
func (m *QueryPacketCommitmentsResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryPacketCommitmentsResponse) MarshalToSizedBuffer ¶
func (m *QueryPacketCommitmentsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryPacketCommitmentsResponse) ProtoMessage ¶
func (*QueryPacketCommitmentsResponse) ProtoMessage()
func (*QueryPacketCommitmentsResponse) Reset ¶
func (m *QueryPacketCommitmentsResponse) Reset()
func (*QueryPacketCommitmentsResponse) Size ¶
func (m *QueryPacketCommitmentsResponse) Size() (n int)
func (*QueryPacketCommitmentsResponse) String ¶
func (m *QueryPacketCommitmentsResponse) String() string
func (*QueryPacketCommitmentsResponse) Unmarshal ¶
func (m *QueryPacketCommitmentsResponse) Unmarshal(dAtA []byte) error
func (*QueryPacketCommitmentsResponse) XXX_DiscardUnknown ¶
func (m *QueryPacketCommitmentsResponse) XXX_DiscardUnknown()
func (*QueryPacketCommitmentsResponse) XXX_Marshal ¶
func (m *QueryPacketCommitmentsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryPacketCommitmentsResponse) XXX_Merge ¶
func (m *QueryPacketCommitmentsResponse) XXX_Merge(src proto.Message)
func (*QueryPacketCommitmentsResponse) XXX_Size ¶
func (m *QueryPacketCommitmentsResponse) XXX_Size() int
func (*QueryPacketCommitmentsResponse) XXX_Unmarshal ¶
func (m *QueryPacketCommitmentsResponse) XXX_Unmarshal(b []byte) error
type QueryPacketReceiptRequest ¶
type QueryPacketReceiptRequest struct { // dest chain name DestChain string `protobuf:"bytes,1,opt,name=dest_chain,json=destChain,proto3" json:"dest_chain,omitempty"` // source chain name SourceChain string `protobuf:"bytes,2,opt,name=source_chain,json=sourceChain,proto3" json:"source_chain,omitempty"` // packet sequence Sequence uint64 `protobuf:"varint,3,opt,name=sequence,proto3" json:"sequence,omitempty"` }
QueryPacketReceiptRequest is the request type for the Query/PacketReceipt RPC method
func (*QueryPacketReceiptRequest) Descriptor ¶
func (*QueryPacketReceiptRequest) Descriptor() ([]byte, []int)
func (*QueryPacketReceiptRequest) GetDestChain ¶
func (m *QueryPacketReceiptRequest) GetDestChain() string
func (*QueryPacketReceiptRequest) GetSequence ¶
func (m *QueryPacketReceiptRequest) GetSequence() uint64
func (*QueryPacketReceiptRequest) GetSourceChain ¶
func (m *QueryPacketReceiptRequest) GetSourceChain() string
func (*QueryPacketReceiptRequest) Marshal ¶
func (m *QueryPacketReceiptRequest) Marshal() (dAtA []byte, err error)
func (*QueryPacketReceiptRequest) MarshalTo ¶
func (m *QueryPacketReceiptRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryPacketReceiptRequest) MarshalToSizedBuffer ¶
func (m *QueryPacketReceiptRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryPacketReceiptRequest) ProtoMessage ¶
func (*QueryPacketReceiptRequest) ProtoMessage()
func (*QueryPacketReceiptRequest) Reset ¶
func (m *QueryPacketReceiptRequest) Reset()
func (*QueryPacketReceiptRequest) Size ¶
func (m *QueryPacketReceiptRequest) Size() (n int)
func (*QueryPacketReceiptRequest) String ¶
func (m *QueryPacketReceiptRequest) String() string
func (*QueryPacketReceiptRequest) Unmarshal ¶
func (m *QueryPacketReceiptRequest) Unmarshal(dAtA []byte) error
func (*QueryPacketReceiptRequest) XXX_DiscardUnknown ¶
func (m *QueryPacketReceiptRequest) XXX_DiscardUnknown()
func (*QueryPacketReceiptRequest) XXX_Marshal ¶
func (m *QueryPacketReceiptRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryPacketReceiptRequest) XXX_Merge ¶
func (m *QueryPacketReceiptRequest) XXX_Merge(src proto.Message)
func (*QueryPacketReceiptRequest) XXX_Size ¶
func (m *QueryPacketReceiptRequest) XXX_Size() int
func (*QueryPacketReceiptRequest) XXX_Unmarshal ¶
func (m *QueryPacketReceiptRequest) XXX_Unmarshal(b []byte) error
type QueryPacketReceiptResponse ¶
type QueryPacketReceiptResponse struct { // success flag for if receipt exists Received bool `protobuf:"varint,2,opt,name=received,proto3" json:"received,omitempty"` // merkle proof of existence Proof []byte `protobuf:"bytes,3,opt,name=proof,proto3" json:"proof,omitempty"` // height at which the proof was retrieved ProofHeight types.Height `protobuf:"bytes,4,opt,name=proof_height,json=proofHeight,proto3" json:"proof_height"` }
QueryPacketReceiptResponse defines the client query response for a packet receipt which also includes a proof, and the height from which the proof was retrieved
func NewQueryPacketReceiptResponse ¶
func NewQueryPacketReceiptResponse( recvd bool, proof []byte, height clienttypes.Height, ) *QueryPacketReceiptResponse
NewQueryPacketReceiptResponse creates a new QueryPacketReceiptResponse instance
func (*QueryPacketReceiptResponse) Descriptor ¶
func (*QueryPacketReceiptResponse) Descriptor() ([]byte, []int)
func (*QueryPacketReceiptResponse) GetProof ¶
func (m *QueryPacketReceiptResponse) GetProof() []byte
func (*QueryPacketReceiptResponse) GetProofHeight ¶
func (m *QueryPacketReceiptResponse) GetProofHeight() types.Height
func (*QueryPacketReceiptResponse) GetReceived ¶
func (m *QueryPacketReceiptResponse) GetReceived() bool
func (*QueryPacketReceiptResponse) Marshal ¶
func (m *QueryPacketReceiptResponse) Marshal() (dAtA []byte, err error)
func (*QueryPacketReceiptResponse) MarshalTo ¶
func (m *QueryPacketReceiptResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryPacketReceiptResponse) MarshalToSizedBuffer ¶
func (m *QueryPacketReceiptResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryPacketReceiptResponse) ProtoMessage ¶
func (*QueryPacketReceiptResponse) ProtoMessage()
func (*QueryPacketReceiptResponse) Reset ¶
func (m *QueryPacketReceiptResponse) Reset()
func (*QueryPacketReceiptResponse) Size ¶
func (m *QueryPacketReceiptResponse) Size() (n int)
func (*QueryPacketReceiptResponse) String ¶
func (m *QueryPacketReceiptResponse) String() string
func (*QueryPacketReceiptResponse) Unmarshal ¶
func (m *QueryPacketReceiptResponse) Unmarshal(dAtA []byte) error
func (*QueryPacketReceiptResponse) XXX_DiscardUnknown ¶
func (m *QueryPacketReceiptResponse) XXX_DiscardUnknown()
func (*QueryPacketReceiptResponse) XXX_Marshal ¶
func (m *QueryPacketReceiptResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryPacketReceiptResponse) XXX_Merge ¶
func (m *QueryPacketReceiptResponse) XXX_Merge(src proto.Message)
func (*QueryPacketReceiptResponse) XXX_Size ¶
func (m *QueryPacketReceiptResponse) XXX_Size() int
func (*QueryPacketReceiptResponse) XXX_Unmarshal ¶
func (m *QueryPacketReceiptResponse) XXX_Unmarshal(b []byte) error
type QueryServer ¶
type QueryServer interface { // PacketCommitment queries a stored packet commitment hash. PacketCommitment(context.Context, *QueryPacketCommitmentRequest) (*QueryPacketCommitmentResponse, error) // PacketCommitments returns all the packet commitments hashes associated PacketCommitments(context.Context, *QueryPacketCommitmentsRequest) (*QueryPacketCommitmentsResponse, error) // PacketReceipt queries if a given packet sequence has been received on the queried chain PacketReceipt(context.Context, *QueryPacketReceiptRequest) (*QueryPacketReceiptResponse, error) // PacketAcknowledgement queries a stored packet acknowledgement hash. PacketAcknowledgement(context.Context, *QueryPacketAcknowledgementRequest) (*QueryPacketAcknowledgementResponse, error) // PacketAcknowledgements returns all the packet acknowledgements associated PacketAcknowledgements(context.Context, *QueryPacketAcknowledgementsRequest) (*QueryPacketAcknowledgementsResponse, error) // UnreceivedPackets returns all the unreceived TIBC packets associated with sequences. UnreceivedPackets(context.Context, *QueryUnreceivedPacketsRequest) (*QueryUnreceivedPacketsResponse, error) // UnreceivedAcks returns all the unreceived TIBC acknowledgements associated with sequences. UnreceivedAcks(context.Context, *QueryUnreceivedAcksRequest) (*QueryUnreceivedAcksResponse, error) // CleanPacketCommitment queries a stored packet commitment hash. CleanPacketCommitment(context.Context, *QueryCleanPacketCommitmentRequest) (*QueryCleanPacketCommitmentResponse, error) }
QueryServer is the server API for Query service.
type QueryUnreceivedAcksRequest ¶
type QueryUnreceivedAcksRequest struct { // dest chain name DestChain string `protobuf:"bytes,1,opt,name=dest_chain,json=destChain,proto3" json:"dest_chain,omitempty"` // source chain name SourceChain string `protobuf:"bytes,2,opt,name=source_chain,json=sourceChain,proto3" json:"source_chain,omitempty"` // list of acknowledgement sequences PacketAckSequences []uint64 `protobuf:"varint,3,rep,packed,name=packet_ack_sequences,json=packetAckSequences,proto3" json:"packet_ack_sequences,omitempty"` }
QueryUnreceivedAcks is the request type for the Query/UnreceivedAcks RPC method
func (*QueryUnreceivedAcksRequest) Descriptor ¶
func (*QueryUnreceivedAcksRequest) Descriptor() ([]byte, []int)
func (*QueryUnreceivedAcksRequest) GetDestChain ¶
func (m *QueryUnreceivedAcksRequest) GetDestChain() string
func (*QueryUnreceivedAcksRequest) GetPacketAckSequences ¶
func (m *QueryUnreceivedAcksRequest) GetPacketAckSequences() []uint64
func (*QueryUnreceivedAcksRequest) GetSourceChain ¶
func (m *QueryUnreceivedAcksRequest) GetSourceChain() string
func (*QueryUnreceivedAcksRequest) Marshal ¶
func (m *QueryUnreceivedAcksRequest) Marshal() (dAtA []byte, err error)
func (*QueryUnreceivedAcksRequest) MarshalTo ¶
func (m *QueryUnreceivedAcksRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryUnreceivedAcksRequest) MarshalToSizedBuffer ¶
func (m *QueryUnreceivedAcksRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryUnreceivedAcksRequest) ProtoMessage ¶
func (*QueryUnreceivedAcksRequest) ProtoMessage()
func (*QueryUnreceivedAcksRequest) Reset ¶
func (m *QueryUnreceivedAcksRequest) Reset()
func (*QueryUnreceivedAcksRequest) Size ¶
func (m *QueryUnreceivedAcksRequest) Size() (n int)
func (*QueryUnreceivedAcksRequest) String ¶
func (m *QueryUnreceivedAcksRequest) String() string
func (*QueryUnreceivedAcksRequest) Unmarshal ¶
func (m *QueryUnreceivedAcksRequest) Unmarshal(dAtA []byte) error
func (*QueryUnreceivedAcksRequest) XXX_DiscardUnknown ¶
func (m *QueryUnreceivedAcksRequest) XXX_DiscardUnknown()
func (*QueryUnreceivedAcksRequest) XXX_Marshal ¶
func (m *QueryUnreceivedAcksRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryUnreceivedAcksRequest) XXX_Merge ¶
func (m *QueryUnreceivedAcksRequest) XXX_Merge(src proto.Message)
func (*QueryUnreceivedAcksRequest) XXX_Size ¶
func (m *QueryUnreceivedAcksRequest) XXX_Size() int
func (*QueryUnreceivedAcksRequest) XXX_Unmarshal ¶
func (m *QueryUnreceivedAcksRequest) XXX_Unmarshal(b []byte) error
type QueryUnreceivedAcksResponse ¶
type QueryUnreceivedAcksResponse struct { // list of unreceived acknowledgement sequences Sequences []uint64 `protobuf:"varint,1,rep,packed,name=sequences,proto3" json:"sequences,omitempty"` // query block height Height types.Height `protobuf:"bytes,2,opt,name=height,proto3" json:"height"` }
QueryUnreceivedAcksResponse is the response type for the Query/UnreceivedAcks RPC method
func (*QueryUnreceivedAcksResponse) Descriptor ¶
func (*QueryUnreceivedAcksResponse) Descriptor() ([]byte, []int)
func (*QueryUnreceivedAcksResponse) GetHeight ¶
func (m *QueryUnreceivedAcksResponse) GetHeight() types.Height
func (*QueryUnreceivedAcksResponse) GetSequences ¶
func (m *QueryUnreceivedAcksResponse) GetSequences() []uint64
func (*QueryUnreceivedAcksResponse) Marshal ¶
func (m *QueryUnreceivedAcksResponse) Marshal() (dAtA []byte, err error)
func (*QueryUnreceivedAcksResponse) MarshalTo ¶
func (m *QueryUnreceivedAcksResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryUnreceivedAcksResponse) MarshalToSizedBuffer ¶
func (m *QueryUnreceivedAcksResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryUnreceivedAcksResponse) ProtoMessage ¶
func (*QueryUnreceivedAcksResponse) ProtoMessage()
func (*QueryUnreceivedAcksResponse) Reset ¶
func (m *QueryUnreceivedAcksResponse) Reset()
func (*QueryUnreceivedAcksResponse) Size ¶
func (m *QueryUnreceivedAcksResponse) Size() (n int)
func (*QueryUnreceivedAcksResponse) String ¶
func (m *QueryUnreceivedAcksResponse) String() string
func (*QueryUnreceivedAcksResponse) Unmarshal ¶
func (m *QueryUnreceivedAcksResponse) Unmarshal(dAtA []byte) error
func (*QueryUnreceivedAcksResponse) XXX_DiscardUnknown ¶
func (m *QueryUnreceivedAcksResponse) XXX_DiscardUnknown()
func (*QueryUnreceivedAcksResponse) XXX_Marshal ¶
func (m *QueryUnreceivedAcksResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryUnreceivedAcksResponse) XXX_Merge ¶
func (m *QueryUnreceivedAcksResponse) XXX_Merge(src proto.Message)
func (*QueryUnreceivedAcksResponse) XXX_Size ¶
func (m *QueryUnreceivedAcksResponse) XXX_Size() int
func (*QueryUnreceivedAcksResponse) XXX_Unmarshal ¶
func (m *QueryUnreceivedAcksResponse) XXX_Unmarshal(b []byte) error
type QueryUnreceivedPacketsRequest ¶
type QueryUnreceivedPacketsRequest struct { // dest chain name DestChain string `protobuf:"bytes,1,opt,name=dest_chain,json=destChain,proto3" json:"dest_chain,omitempty"` // source chain name SourceChain string `protobuf:"bytes,2,opt,name=source_chain,json=sourceChain,proto3" json:"source_chain,omitempty"` // list of packet sequences PacketCommitmentSequences []uint64 `` /* 146-byte string literal not displayed */ }
QueryUnreceivedPacketsRequest is the request type for the Query/UnreceivedPackets RPC method
func (*QueryUnreceivedPacketsRequest) Descriptor ¶
func (*QueryUnreceivedPacketsRequest) Descriptor() ([]byte, []int)
func (*QueryUnreceivedPacketsRequest) GetDestChain ¶
func (m *QueryUnreceivedPacketsRequest) GetDestChain() string
func (*QueryUnreceivedPacketsRequest) GetPacketCommitmentSequences ¶
func (m *QueryUnreceivedPacketsRequest) GetPacketCommitmentSequences() []uint64
func (*QueryUnreceivedPacketsRequest) GetSourceChain ¶
func (m *QueryUnreceivedPacketsRequest) GetSourceChain() string
func (*QueryUnreceivedPacketsRequest) Marshal ¶
func (m *QueryUnreceivedPacketsRequest) Marshal() (dAtA []byte, err error)
func (*QueryUnreceivedPacketsRequest) MarshalTo ¶
func (m *QueryUnreceivedPacketsRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryUnreceivedPacketsRequest) MarshalToSizedBuffer ¶
func (m *QueryUnreceivedPacketsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryUnreceivedPacketsRequest) ProtoMessage ¶
func (*QueryUnreceivedPacketsRequest) ProtoMessage()
func (*QueryUnreceivedPacketsRequest) Reset ¶
func (m *QueryUnreceivedPacketsRequest) Reset()
func (*QueryUnreceivedPacketsRequest) Size ¶
func (m *QueryUnreceivedPacketsRequest) Size() (n int)
func (*QueryUnreceivedPacketsRequest) String ¶
func (m *QueryUnreceivedPacketsRequest) String() string
func (*QueryUnreceivedPacketsRequest) Unmarshal ¶
func (m *QueryUnreceivedPacketsRequest) Unmarshal(dAtA []byte) error
func (*QueryUnreceivedPacketsRequest) XXX_DiscardUnknown ¶
func (m *QueryUnreceivedPacketsRequest) XXX_DiscardUnknown()
func (*QueryUnreceivedPacketsRequest) XXX_Marshal ¶
func (m *QueryUnreceivedPacketsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryUnreceivedPacketsRequest) XXX_Merge ¶
func (m *QueryUnreceivedPacketsRequest) XXX_Merge(src proto.Message)
func (*QueryUnreceivedPacketsRequest) XXX_Size ¶
func (m *QueryUnreceivedPacketsRequest) XXX_Size() int
func (*QueryUnreceivedPacketsRequest) XXX_Unmarshal ¶
func (m *QueryUnreceivedPacketsRequest) XXX_Unmarshal(b []byte) error
type QueryUnreceivedPacketsResponse ¶
type QueryUnreceivedPacketsResponse struct { // list of unreceived packet sequences Sequences []uint64 `protobuf:"varint,1,rep,packed,name=sequences,proto3" json:"sequences,omitempty"` // query block height Height types.Height `protobuf:"bytes,2,opt,name=height,proto3" json:"height"` }
QueryUnreceivedPacketsResponse is the response type for the Query/UnreceivedPacketCommitments RPC method
func (*QueryUnreceivedPacketsResponse) Descriptor ¶
func (*QueryUnreceivedPacketsResponse) Descriptor() ([]byte, []int)
func (*QueryUnreceivedPacketsResponse) GetHeight ¶
func (m *QueryUnreceivedPacketsResponse) GetHeight() types.Height
func (*QueryUnreceivedPacketsResponse) GetSequences ¶
func (m *QueryUnreceivedPacketsResponse) GetSequences() []uint64
func (*QueryUnreceivedPacketsResponse) Marshal ¶
func (m *QueryUnreceivedPacketsResponse) Marshal() (dAtA []byte, err error)
func (*QueryUnreceivedPacketsResponse) MarshalTo ¶
func (m *QueryUnreceivedPacketsResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryUnreceivedPacketsResponse) MarshalToSizedBuffer ¶
func (m *QueryUnreceivedPacketsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryUnreceivedPacketsResponse) ProtoMessage ¶
func (*QueryUnreceivedPacketsResponse) ProtoMessage()
func (*QueryUnreceivedPacketsResponse) Reset ¶
func (m *QueryUnreceivedPacketsResponse) Reset()
func (*QueryUnreceivedPacketsResponse) Size ¶
func (m *QueryUnreceivedPacketsResponse) Size() (n int)
func (*QueryUnreceivedPacketsResponse) String ¶
func (m *QueryUnreceivedPacketsResponse) String() string
func (*QueryUnreceivedPacketsResponse) Unmarshal ¶
func (m *QueryUnreceivedPacketsResponse) Unmarshal(dAtA []byte) error
func (*QueryUnreceivedPacketsResponse) XXX_DiscardUnknown ¶
func (m *QueryUnreceivedPacketsResponse) XXX_DiscardUnknown()
func (*QueryUnreceivedPacketsResponse) XXX_Marshal ¶
func (m *QueryUnreceivedPacketsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryUnreceivedPacketsResponse) XXX_Merge ¶
func (m *QueryUnreceivedPacketsResponse) XXX_Merge(src proto.Message)
func (*QueryUnreceivedPacketsResponse) XXX_Size ¶
func (m *QueryUnreceivedPacketsResponse) XXX_Size() int
func (*QueryUnreceivedPacketsResponse) XXX_Unmarshal ¶
func (m *QueryUnreceivedPacketsResponse) XXX_Unmarshal(b []byte) error
type RoutingKeeper ¶
type RoutingKeeper interface {
Authenticate(ctx sdk.Context, sourceChain, destinationChain, port string) bool
}
PortKeeper expected account TIBC port keeper
type UnimplementedMsgServer ¶
type UnimplementedMsgServer struct { }
UnimplementedMsgServer can be embedded to have forward compatible implementations.
func (*UnimplementedMsgServer) Acknowledgement ¶
func (*UnimplementedMsgServer) Acknowledgement(ctx context.Context, req *MsgAcknowledgement) (*MsgAcknowledgementResponse, error)
func (*UnimplementedMsgServer) CleanPacket ¶
func (*UnimplementedMsgServer) CleanPacket(ctx context.Context, req *MsgCleanPacket) (*MsgCleanPacketResponse, error)
func (*UnimplementedMsgServer) RecvCleanPacket ¶
func (*UnimplementedMsgServer) RecvCleanPacket(ctx context.Context, req *MsgRecvCleanPacket) (*MsgRecvCleanPacketResponse, error)
func (*UnimplementedMsgServer) RecvPacket ¶
func (*UnimplementedMsgServer) RecvPacket(ctx context.Context, req *MsgRecvPacket) (*MsgRecvPacketResponse, error)
type UnimplementedQueryServer ¶
type UnimplementedQueryServer struct { }
UnimplementedQueryServer can be embedded to have forward compatible implementations.
func (*UnimplementedQueryServer) CleanPacketCommitment ¶ added in v0.2.0
func (*UnimplementedQueryServer) CleanPacketCommitment(ctx context.Context, req *QueryCleanPacketCommitmentRequest) (*QueryCleanPacketCommitmentResponse, error)
func (*UnimplementedQueryServer) PacketAcknowledgement ¶
func (*UnimplementedQueryServer) PacketAcknowledgement(ctx context.Context, req *QueryPacketAcknowledgementRequest) (*QueryPacketAcknowledgementResponse, error)
func (*UnimplementedQueryServer) PacketAcknowledgements ¶
func (*UnimplementedQueryServer) PacketAcknowledgements(ctx context.Context, req *QueryPacketAcknowledgementsRequest) (*QueryPacketAcknowledgementsResponse, error)
func (*UnimplementedQueryServer) PacketCommitment ¶
func (*UnimplementedQueryServer) PacketCommitment(ctx context.Context, req *QueryPacketCommitmentRequest) (*QueryPacketCommitmentResponse, error)
func (*UnimplementedQueryServer) PacketCommitments ¶
func (*UnimplementedQueryServer) PacketCommitments(ctx context.Context, req *QueryPacketCommitmentsRequest) (*QueryPacketCommitmentsResponse, error)
func (*UnimplementedQueryServer) PacketReceipt ¶
func (*UnimplementedQueryServer) PacketReceipt(ctx context.Context, req *QueryPacketReceiptRequest) (*QueryPacketReceiptResponse, error)
func (*UnimplementedQueryServer) UnreceivedAcks ¶
func (*UnimplementedQueryServer) UnreceivedAcks(ctx context.Context, req *QueryUnreceivedAcksRequest) (*QueryUnreceivedAcksResponse, error)
func (*UnimplementedQueryServer) UnreceivedPackets ¶
func (*UnimplementedQueryServer) UnreceivedPackets(ctx context.Context, req *QueryUnreceivedPacketsRequest) (*QueryUnreceivedPacketsResponse, error)