Documentation ¶
Overview ¶
Package types is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Index ¶
- Constants
- Variables
- func CommitAcknowledgement(data []byte) []byte
- func CommitPacket(cdc codec.BinaryMarshaler, packet exported.PacketI) []byte
- func FormatChannelIdentifier(sequence uint64) string
- func IsValidChannelID(channelID string) bool
- func ParseChannelSequence(channelID string) (uint64, error)
- func RegisterInterfaces(registry codectypes.InterfaceRegistry)
- func RegisterMsgServer(s grpc1.Server, srv MsgServer)
- func RegisterQueryHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterQueryHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryClient) error
- func RegisterQueryHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterQueryHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryServer) error
- func RegisterQueryServer(s grpc1.Server, srv QueryServer)
- type Acknowledgement
- func (*Acknowledgement) Descriptor() ([]byte, []int)
- func (ack Acknowledgement) GetBytes() []byte
- func (m *Acknowledgement) GetError() string
- func (m *Acknowledgement) GetResponse() isAcknowledgement_Response
- func (m *Acknowledgement) GetResult() []byte
- func (m *Acknowledgement) Marshal() (dAtA []byte, err error)
- func (m *Acknowledgement) MarshalTo(dAtA []byte) (int, error)
- func (m *Acknowledgement) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Acknowledgement) ProtoMessage()
- func (m *Acknowledgement) Reset()
- func (m *Acknowledgement) Size() (n int)
- func (m *Acknowledgement) String() string
- func (m *Acknowledgement) Unmarshal(dAtA []byte) error
- func (ack Acknowledgement) ValidateBasic() 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 Channel
- func (*Channel) Descriptor() ([]byte, []int)
- func (ch Channel) GetConnectionHops() []string
- func (ch Channel) GetCounterparty() exported.CounterpartyChannelI
- func (ch Channel) GetOrdering() int32
- func (ch Channel) GetState() int32
- func (ch Channel) GetVersion() string
- func (m *Channel) Marshal() (dAtA []byte, err error)
- func (m *Channel) MarshalTo(dAtA []byte) (int, error)
- func (m *Channel) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Channel) ProtoMessage()
- func (m *Channel) Reset()
- func (m *Channel) Size() (n int)
- func (m *Channel) String() string
- func (m *Channel) Unmarshal(dAtA []byte) error
- func (ch Channel) ValidateBasic() error
- func (m *Channel) XXX_DiscardUnknown()
- func (m *Channel) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Channel) XXX_Merge(src proto.Message)
- func (m *Channel) XXX_Size() int
- func (m *Channel) XXX_Unmarshal(b []byte) error
- type ClientKeeper
- type ConnectionKeeper
- type Counterparty
- func (*Counterparty) Descriptor() ([]byte, []int)
- func (c Counterparty) GetChannelID() string
- func (c Counterparty) GetPortID() string
- func (m *Counterparty) Marshal() (dAtA []byte, err error)
- func (m *Counterparty) MarshalTo(dAtA []byte) (int, error)
- func (m *Counterparty) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Counterparty) ProtoMessage()
- func (m *Counterparty) Reset()
- func (m *Counterparty) Size() (n int)
- func (m *Counterparty) String() string
- func (m *Counterparty) Unmarshal(dAtA []byte) error
- func (c Counterparty) ValidateBasic() error
- func (m *Counterparty) XXX_DiscardUnknown()
- func (m *Counterparty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Counterparty) XXX_Merge(src proto.Message)
- func (m *Counterparty) XXX_Size() int
- func (m *Counterparty) XXX_Unmarshal(b []byte) error
- type GenesisState
- func (*GenesisState) Descriptor() ([]byte, []int)
- func (m *GenesisState) GetAckSequences() []PacketSequence
- func (m *GenesisState) GetAcknowledgements() []PacketState
- func (m *GenesisState) GetChannels() []IdentifiedChannel
- func (m *GenesisState) GetCommitments() []PacketState
- func (m *GenesisState) GetNextChannelSequence() uint64
- func (m *GenesisState) GetReceipts() []PacketState
- func (m *GenesisState) GetRecvSequences() []PacketSequence
- func (m *GenesisState) GetSendSequences() []PacketSequence
- func (m *GenesisState) Marshal() (dAtA []byte, err error)
- func (m *GenesisState) MarshalTo(dAtA []byte) (int, error)
- func (m *GenesisState) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GenesisState) ProtoMessage()
- func (m *GenesisState) Reset()
- func (m *GenesisState) Size() (n int)
- func (m *GenesisState) String() string
- func (m *GenesisState) Unmarshal(dAtA []byte) error
- func (gs GenesisState) Validate() error
- func (m *GenesisState) XXX_DiscardUnknown()
- func (m *GenesisState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GenesisState) XXX_Merge(src proto.Message)
- func (m *GenesisState) XXX_Size() int
- func (m *GenesisState) XXX_Unmarshal(b []byte) error
- type IdentifiedChannel
- func (*IdentifiedChannel) Descriptor() ([]byte, []int)
- func (m *IdentifiedChannel) Marshal() (dAtA []byte, err error)
- func (m *IdentifiedChannel) MarshalTo(dAtA []byte) (int, error)
- func (m *IdentifiedChannel) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*IdentifiedChannel) ProtoMessage()
- func (m *IdentifiedChannel) Reset()
- func (m *IdentifiedChannel) Size() (n int)
- func (m *IdentifiedChannel) String() string
- func (m *IdentifiedChannel) Unmarshal(dAtA []byte) error
- func (ic IdentifiedChannel) ValidateBasic() error
- func (m *IdentifiedChannel) XXX_DiscardUnknown()
- func (m *IdentifiedChannel) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *IdentifiedChannel) XXX_Merge(src proto.Message)
- func (m *IdentifiedChannel) XXX_Size() int
- func (m *IdentifiedChannel) XXX_Unmarshal(b []byte) error
- type MsgAcknowledgement
- func (*MsgAcknowledgement) Descriptor() ([]byte, []int)
- func (msg MsgAcknowledgement) GetSignBytes() []byte
- func (msg MsgAcknowledgement) GetSigners() []sdk.AccAddress
- func (m *MsgAcknowledgement) Marshal() (dAtA []byte, err error)
- func (m *MsgAcknowledgement) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgAcknowledgement) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgAcknowledgement) ProtoMessage()
- func (m *MsgAcknowledgement) Reset()
- func (msg MsgAcknowledgement) Route() string
- func (m *MsgAcknowledgement) Size() (n int)
- func (m *MsgAcknowledgement) String() string
- func (msg MsgAcknowledgement) Type() string
- func (m *MsgAcknowledgement) Unmarshal(dAtA []byte) error
- func (msg MsgAcknowledgement) ValidateBasic() error
- func (m *MsgAcknowledgement) XXX_DiscardUnknown()
- func (m *MsgAcknowledgement) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgAcknowledgement) XXX_Merge(src proto.Message)
- func (m *MsgAcknowledgement) XXX_Size() int
- func (m *MsgAcknowledgement) XXX_Unmarshal(b []byte) error
- type MsgAcknowledgementResponse
- func (*MsgAcknowledgementResponse) Descriptor() ([]byte, []int)
- func (m *MsgAcknowledgementResponse) Marshal() (dAtA []byte, err error)
- func (m *MsgAcknowledgementResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgAcknowledgementResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgAcknowledgementResponse) ProtoMessage()
- func (m *MsgAcknowledgementResponse) Reset()
- func (m *MsgAcknowledgementResponse) Size() (n int)
- func (m *MsgAcknowledgementResponse) String() string
- func (m *MsgAcknowledgementResponse) Unmarshal(dAtA []byte) error
- func (m *MsgAcknowledgementResponse) XXX_DiscardUnknown()
- func (m *MsgAcknowledgementResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgAcknowledgementResponse) XXX_Merge(src proto.Message)
- func (m *MsgAcknowledgementResponse) XXX_Size() int
- func (m *MsgAcknowledgementResponse) XXX_Unmarshal(b []byte) error
- type MsgChannelCloseConfirm
- func (*MsgChannelCloseConfirm) Descriptor() ([]byte, []int)
- func (msg MsgChannelCloseConfirm) GetSignBytes() []byte
- func (msg MsgChannelCloseConfirm) GetSigners() []sdk.AccAddress
- func (m *MsgChannelCloseConfirm) Marshal() (dAtA []byte, err error)
- func (m *MsgChannelCloseConfirm) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgChannelCloseConfirm) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgChannelCloseConfirm) ProtoMessage()
- func (m *MsgChannelCloseConfirm) Reset()
- func (msg MsgChannelCloseConfirm) Route() string
- func (m *MsgChannelCloseConfirm) Size() (n int)
- func (m *MsgChannelCloseConfirm) String() string
- func (msg MsgChannelCloseConfirm) Type() string
- func (m *MsgChannelCloseConfirm) Unmarshal(dAtA []byte) error
- func (msg MsgChannelCloseConfirm) ValidateBasic() error
- func (m *MsgChannelCloseConfirm) XXX_DiscardUnknown()
- func (m *MsgChannelCloseConfirm) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgChannelCloseConfirm) XXX_Merge(src proto.Message)
- func (m *MsgChannelCloseConfirm) XXX_Size() int
- func (m *MsgChannelCloseConfirm) XXX_Unmarshal(b []byte) error
- type MsgChannelCloseConfirmResponse
- func (*MsgChannelCloseConfirmResponse) Descriptor() ([]byte, []int)
- func (m *MsgChannelCloseConfirmResponse) Marshal() (dAtA []byte, err error)
- func (m *MsgChannelCloseConfirmResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgChannelCloseConfirmResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgChannelCloseConfirmResponse) ProtoMessage()
- func (m *MsgChannelCloseConfirmResponse) Reset()
- func (m *MsgChannelCloseConfirmResponse) Size() (n int)
- func (m *MsgChannelCloseConfirmResponse) String() string
- func (m *MsgChannelCloseConfirmResponse) Unmarshal(dAtA []byte) error
- func (m *MsgChannelCloseConfirmResponse) XXX_DiscardUnknown()
- func (m *MsgChannelCloseConfirmResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgChannelCloseConfirmResponse) XXX_Merge(src proto.Message)
- func (m *MsgChannelCloseConfirmResponse) XXX_Size() int
- func (m *MsgChannelCloseConfirmResponse) XXX_Unmarshal(b []byte) error
- type MsgChannelCloseInit
- func (*MsgChannelCloseInit) Descriptor() ([]byte, []int)
- func (msg MsgChannelCloseInit) GetSignBytes() []byte
- func (msg MsgChannelCloseInit) GetSigners() []sdk.AccAddress
- func (m *MsgChannelCloseInit) Marshal() (dAtA []byte, err error)
- func (m *MsgChannelCloseInit) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgChannelCloseInit) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgChannelCloseInit) ProtoMessage()
- func (m *MsgChannelCloseInit) Reset()
- func (msg MsgChannelCloseInit) Route() string
- func (m *MsgChannelCloseInit) Size() (n int)
- func (m *MsgChannelCloseInit) String() string
- func (msg MsgChannelCloseInit) Type() string
- func (m *MsgChannelCloseInit) Unmarshal(dAtA []byte) error
- func (msg MsgChannelCloseInit) ValidateBasic() error
- func (m *MsgChannelCloseInit) XXX_DiscardUnknown()
- func (m *MsgChannelCloseInit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgChannelCloseInit) XXX_Merge(src proto.Message)
- func (m *MsgChannelCloseInit) XXX_Size() int
- func (m *MsgChannelCloseInit) XXX_Unmarshal(b []byte) error
- type MsgChannelCloseInitResponse
- func (*MsgChannelCloseInitResponse) Descriptor() ([]byte, []int)
- func (m *MsgChannelCloseInitResponse) Marshal() (dAtA []byte, err error)
- func (m *MsgChannelCloseInitResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgChannelCloseInitResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgChannelCloseInitResponse) ProtoMessage()
- func (m *MsgChannelCloseInitResponse) Reset()
- func (m *MsgChannelCloseInitResponse) Size() (n int)
- func (m *MsgChannelCloseInitResponse) String() string
- func (m *MsgChannelCloseInitResponse) Unmarshal(dAtA []byte) error
- func (m *MsgChannelCloseInitResponse) XXX_DiscardUnknown()
- func (m *MsgChannelCloseInitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgChannelCloseInitResponse) XXX_Merge(src proto.Message)
- func (m *MsgChannelCloseInitResponse) XXX_Size() int
- func (m *MsgChannelCloseInitResponse) XXX_Unmarshal(b []byte) error
- type MsgChannelOpenAck
- func (*MsgChannelOpenAck) Descriptor() ([]byte, []int)
- func (msg MsgChannelOpenAck) GetSignBytes() []byte
- func (msg MsgChannelOpenAck) GetSigners() []sdk.AccAddress
- func (m *MsgChannelOpenAck) Marshal() (dAtA []byte, err error)
- func (m *MsgChannelOpenAck) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgChannelOpenAck) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgChannelOpenAck) ProtoMessage()
- func (m *MsgChannelOpenAck) Reset()
- func (msg MsgChannelOpenAck) Route() string
- func (m *MsgChannelOpenAck) Size() (n int)
- func (m *MsgChannelOpenAck) String() string
- func (msg MsgChannelOpenAck) Type() string
- func (m *MsgChannelOpenAck) Unmarshal(dAtA []byte) error
- func (msg MsgChannelOpenAck) ValidateBasic() error
- func (m *MsgChannelOpenAck) XXX_DiscardUnknown()
- func (m *MsgChannelOpenAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgChannelOpenAck) XXX_Merge(src proto.Message)
- func (m *MsgChannelOpenAck) XXX_Size() int
- func (m *MsgChannelOpenAck) XXX_Unmarshal(b []byte) error
- type MsgChannelOpenAckResponse
- func (*MsgChannelOpenAckResponse) Descriptor() ([]byte, []int)
- func (m *MsgChannelOpenAckResponse) Marshal() (dAtA []byte, err error)
- func (m *MsgChannelOpenAckResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgChannelOpenAckResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgChannelOpenAckResponse) ProtoMessage()
- func (m *MsgChannelOpenAckResponse) Reset()
- func (m *MsgChannelOpenAckResponse) Size() (n int)
- func (m *MsgChannelOpenAckResponse) String() string
- func (m *MsgChannelOpenAckResponse) Unmarshal(dAtA []byte) error
- func (m *MsgChannelOpenAckResponse) XXX_DiscardUnknown()
- func (m *MsgChannelOpenAckResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgChannelOpenAckResponse) XXX_Merge(src proto.Message)
- func (m *MsgChannelOpenAckResponse) XXX_Size() int
- func (m *MsgChannelOpenAckResponse) XXX_Unmarshal(b []byte) error
- type MsgChannelOpenConfirm
- func (*MsgChannelOpenConfirm) Descriptor() ([]byte, []int)
- func (msg MsgChannelOpenConfirm) GetSignBytes() []byte
- func (msg MsgChannelOpenConfirm) GetSigners() []sdk.AccAddress
- func (m *MsgChannelOpenConfirm) Marshal() (dAtA []byte, err error)
- func (m *MsgChannelOpenConfirm) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgChannelOpenConfirm) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgChannelOpenConfirm) ProtoMessage()
- func (m *MsgChannelOpenConfirm) Reset()
- func (msg MsgChannelOpenConfirm) Route() string
- func (m *MsgChannelOpenConfirm) Size() (n int)
- func (m *MsgChannelOpenConfirm) String() string
- func (msg MsgChannelOpenConfirm) Type() string
- func (m *MsgChannelOpenConfirm) Unmarshal(dAtA []byte) error
- func (msg MsgChannelOpenConfirm) ValidateBasic() error
- func (m *MsgChannelOpenConfirm) XXX_DiscardUnknown()
- func (m *MsgChannelOpenConfirm) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgChannelOpenConfirm) XXX_Merge(src proto.Message)
- func (m *MsgChannelOpenConfirm) XXX_Size() int
- func (m *MsgChannelOpenConfirm) XXX_Unmarshal(b []byte) error
- type MsgChannelOpenConfirmResponse
- func (*MsgChannelOpenConfirmResponse) Descriptor() ([]byte, []int)
- func (m *MsgChannelOpenConfirmResponse) Marshal() (dAtA []byte, err error)
- func (m *MsgChannelOpenConfirmResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgChannelOpenConfirmResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgChannelOpenConfirmResponse) ProtoMessage()
- func (m *MsgChannelOpenConfirmResponse) Reset()
- func (m *MsgChannelOpenConfirmResponse) Size() (n int)
- func (m *MsgChannelOpenConfirmResponse) String() string
- func (m *MsgChannelOpenConfirmResponse) Unmarshal(dAtA []byte) error
- func (m *MsgChannelOpenConfirmResponse) XXX_DiscardUnknown()
- func (m *MsgChannelOpenConfirmResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgChannelOpenConfirmResponse) XXX_Merge(src proto.Message)
- func (m *MsgChannelOpenConfirmResponse) XXX_Size() int
- func (m *MsgChannelOpenConfirmResponse) XXX_Unmarshal(b []byte) error
- type MsgChannelOpenInit
- func (*MsgChannelOpenInit) Descriptor() ([]byte, []int)
- func (msg MsgChannelOpenInit) GetSignBytes() []byte
- func (msg MsgChannelOpenInit) GetSigners() []sdk.AccAddress
- func (m *MsgChannelOpenInit) Marshal() (dAtA []byte, err error)
- func (m *MsgChannelOpenInit) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgChannelOpenInit) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgChannelOpenInit) ProtoMessage()
- func (m *MsgChannelOpenInit) Reset()
- func (msg MsgChannelOpenInit) Route() string
- func (m *MsgChannelOpenInit) Size() (n int)
- func (m *MsgChannelOpenInit) String() string
- func (msg MsgChannelOpenInit) Type() string
- func (m *MsgChannelOpenInit) Unmarshal(dAtA []byte) error
- func (msg MsgChannelOpenInit) ValidateBasic() error
- func (m *MsgChannelOpenInit) XXX_DiscardUnknown()
- func (m *MsgChannelOpenInit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgChannelOpenInit) XXX_Merge(src proto.Message)
- func (m *MsgChannelOpenInit) XXX_Size() int
- func (m *MsgChannelOpenInit) XXX_Unmarshal(b []byte) error
- type MsgChannelOpenInitResponse
- func (*MsgChannelOpenInitResponse) Descriptor() ([]byte, []int)
- func (m *MsgChannelOpenInitResponse) Marshal() (dAtA []byte, err error)
- func (m *MsgChannelOpenInitResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgChannelOpenInitResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgChannelOpenInitResponse) ProtoMessage()
- func (m *MsgChannelOpenInitResponse) Reset()
- func (m *MsgChannelOpenInitResponse) Size() (n int)
- func (m *MsgChannelOpenInitResponse) String() string
- func (m *MsgChannelOpenInitResponse) Unmarshal(dAtA []byte) error
- func (m *MsgChannelOpenInitResponse) XXX_DiscardUnknown()
- func (m *MsgChannelOpenInitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgChannelOpenInitResponse) XXX_Merge(src proto.Message)
- func (m *MsgChannelOpenInitResponse) XXX_Size() int
- func (m *MsgChannelOpenInitResponse) XXX_Unmarshal(b []byte) error
- type MsgChannelOpenTry
- func (*MsgChannelOpenTry) Descriptor() ([]byte, []int)
- func (msg MsgChannelOpenTry) GetSignBytes() []byte
- func (msg MsgChannelOpenTry) GetSigners() []sdk.AccAddress
- func (m *MsgChannelOpenTry) Marshal() (dAtA []byte, err error)
- func (m *MsgChannelOpenTry) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgChannelOpenTry) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgChannelOpenTry) ProtoMessage()
- func (m *MsgChannelOpenTry) Reset()
- func (msg MsgChannelOpenTry) Route() string
- func (m *MsgChannelOpenTry) Size() (n int)
- func (m *MsgChannelOpenTry) String() string
- func (msg MsgChannelOpenTry) Type() string
- func (m *MsgChannelOpenTry) Unmarshal(dAtA []byte) error
- func (msg MsgChannelOpenTry) ValidateBasic() error
- func (m *MsgChannelOpenTry) XXX_DiscardUnknown()
- func (m *MsgChannelOpenTry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgChannelOpenTry) XXX_Merge(src proto.Message)
- func (m *MsgChannelOpenTry) XXX_Size() int
- func (m *MsgChannelOpenTry) XXX_Unmarshal(b []byte) error
- type MsgChannelOpenTryResponse
- func (*MsgChannelOpenTryResponse) Descriptor() ([]byte, []int)
- func (m *MsgChannelOpenTryResponse) Marshal() (dAtA []byte, err error)
- func (m *MsgChannelOpenTryResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgChannelOpenTryResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgChannelOpenTryResponse) ProtoMessage()
- func (m *MsgChannelOpenTryResponse) Reset()
- func (m *MsgChannelOpenTryResponse) Size() (n int)
- func (m *MsgChannelOpenTryResponse) String() string
- func (m *MsgChannelOpenTryResponse) Unmarshal(dAtA []byte) error
- func (m *MsgChannelOpenTryResponse) XXX_DiscardUnknown()
- func (m *MsgChannelOpenTryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgChannelOpenTryResponse) XXX_Merge(src proto.Message)
- func (m *MsgChannelOpenTryResponse) XXX_Size() int
- func (m *MsgChannelOpenTryResponse) XXX_Unmarshal(b []byte) error
- type MsgClient
- type MsgRecvPacket
- func (*MsgRecvPacket) Descriptor() ([]byte, []int)
- func (msg MsgRecvPacket) GetDataSignBytes() []byte
- func (msg MsgRecvPacket) GetSignBytes() []byte
- func (msg MsgRecvPacket) GetSigners() []sdk.AccAddress
- func (m *MsgRecvPacket) Marshal() (dAtA []byte, err error)
- func (m *MsgRecvPacket) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgRecvPacket) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgRecvPacket) ProtoMessage()
- func (m *MsgRecvPacket) Reset()
- func (msg MsgRecvPacket) Route() string
- func (m *MsgRecvPacket) Size() (n int)
- func (m *MsgRecvPacket) String() string
- func (msg MsgRecvPacket) Type() string
- func (m *MsgRecvPacket) Unmarshal(dAtA []byte) error
- func (msg MsgRecvPacket) ValidateBasic() error
- func (m *MsgRecvPacket) XXX_DiscardUnknown()
- func (m *MsgRecvPacket) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgRecvPacket) XXX_Merge(src proto.Message)
- func (m *MsgRecvPacket) XXX_Size() int
- func (m *MsgRecvPacket) XXX_Unmarshal(b []byte) error
- type MsgRecvPacketResponse
- func (*MsgRecvPacketResponse) Descriptor() ([]byte, []int)
- func (m *MsgRecvPacketResponse) Marshal() (dAtA []byte, err error)
- func (m *MsgRecvPacketResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgRecvPacketResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgRecvPacketResponse) ProtoMessage()
- func (m *MsgRecvPacketResponse) Reset()
- func (m *MsgRecvPacketResponse) Size() (n int)
- func (m *MsgRecvPacketResponse) String() string
- func (m *MsgRecvPacketResponse) Unmarshal(dAtA []byte) error
- func (m *MsgRecvPacketResponse) XXX_DiscardUnknown()
- func (m *MsgRecvPacketResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgRecvPacketResponse) XXX_Merge(src proto.Message)
- func (m *MsgRecvPacketResponse) XXX_Size() int
- func (m *MsgRecvPacketResponse) XXX_Unmarshal(b []byte) error
- type MsgServer
- type MsgTimeout
- func (*MsgTimeout) Descriptor() ([]byte, []int)
- func (msg MsgTimeout) GetSignBytes() []byte
- func (msg MsgTimeout) GetSigners() []sdk.AccAddress
- func (m *MsgTimeout) Marshal() (dAtA []byte, err error)
- func (m *MsgTimeout) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgTimeout) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgTimeout) ProtoMessage()
- func (m *MsgTimeout) Reset()
- func (msg MsgTimeout) Route() string
- func (m *MsgTimeout) Size() (n int)
- func (m *MsgTimeout) String() string
- func (msg MsgTimeout) Type() string
- func (m *MsgTimeout) Unmarshal(dAtA []byte) error
- func (msg MsgTimeout) ValidateBasic() error
- func (m *MsgTimeout) XXX_DiscardUnknown()
- func (m *MsgTimeout) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgTimeout) XXX_Merge(src proto.Message)
- func (m *MsgTimeout) XXX_Size() int
- func (m *MsgTimeout) XXX_Unmarshal(b []byte) error
- type MsgTimeoutOnClose
- func (*MsgTimeoutOnClose) Descriptor() ([]byte, []int)
- func (msg MsgTimeoutOnClose) GetSignBytes() []byte
- func (msg MsgTimeoutOnClose) GetSigners() []sdk.AccAddress
- func (m *MsgTimeoutOnClose) Marshal() (dAtA []byte, err error)
- func (m *MsgTimeoutOnClose) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgTimeoutOnClose) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgTimeoutOnClose) ProtoMessage()
- func (m *MsgTimeoutOnClose) Reset()
- func (msg MsgTimeoutOnClose) Route() string
- func (m *MsgTimeoutOnClose) Size() (n int)
- func (m *MsgTimeoutOnClose) String() string
- func (msg MsgTimeoutOnClose) Type() string
- func (m *MsgTimeoutOnClose) Unmarshal(dAtA []byte) error
- func (msg MsgTimeoutOnClose) ValidateBasic() error
- func (m *MsgTimeoutOnClose) XXX_DiscardUnknown()
- func (m *MsgTimeoutOnClose) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgTimeoutOnClose) XXX_Merge(src proto.Message)
- func (m *MsgTimeoutOnClose) XXX_Size() int
- func (m *MsgTimeoutOnClose) XXX_Unmarshal(b []byte) error
- type MsgTimeoutOnCloseResponse
- func (*MsgTimeoutOnCloseResponse) Descriptor() ([]byte, []int)
- func (m *MsgTimeoutOnCloseResponse) Marshal() (dAtA []byte, err error)
- func (m *MsgTimeoutOnCloseResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgTimeoutOnCloseResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgTimeoutOnCloseResponse) ProtoMessage()
- func (m *MsgTimeoutOnCloseResponse) Reset()
- func (m *MsgTimeoutOnCloseResponse) Size() (n int)
- func (m *MsgTimeoutOnCloseResponse) String() string
- func (m *MsgTimeoutOnCloseResponse) Unmarshal(dAtA []byte) error
- func (m *MsgTimeoutOnCloseResponse) XXX_DiscardUnknown()
- func (m *MsgTimeoutOnCloseResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgTimeoutOnCloseResponse) XXX_Merge(src proto.Message)
- func (m *MsgTimeoutOnCloseResponse) XXX_Size() int
- func (m *MsgTimeoutOnCloseResponse) XXX_Unmarshal(b []byte) error
- type MsgTimeoutResponse
- func (*MsgTimeoutResponse) Descriptor() ([]byte, []int)
- func (m *MsgTimeoutResponse) Marshal() (dAtA []byte, err error)
- func (m *MsgTimeoutResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgTimeoutResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgTimeoutResponse) ProtoMessage()
- func (m *MsgTimeoutResponse) Reset()
- func (m *MsgTimeoutResponse) Size() (n int)
- func (m *MsgTimeoutResponse) String() string
- func (m *MsgTimeoutResponse) Unmarshal(dAtA []byte) error
- func (m *MsgTimeoutResponse) XXX_DiscardUnknown()
- func (m *MsgTimeoutResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgTimeoutResponse) XXX_Merge(src proto.Message)
- func (m *MsgTimeoutResponse) XXX_Size() int
- func (m *MsgTimeoutResponse) XXX_Unmarshal(b []byte) error
- type Order
- type Packet
- func (*Packet) Descriptor() ([]byte, []int)
- func (p Packet) GetData() []byte
- func (p Packet) GetDestChannel() string
- func (p Packet) GetDestPort() string
- func (p Packet) GetSequence() uint64
- func (p Packet) GetSourceChannel() string
- func (p Packet) GetSourcePort() string
- func (p Packet) GetTimeoutHeight() exported.Height
- func (p Packet) GetTimeoutTimestamp() uint64
- 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) GetChannelId() string
- func (m *PacketSequence) GetPortId() string
- func (m *PacketSequence) GetSequence() uint64
- 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 PortKeeper
- type QueryChannelClientStateRequest
- func (*QueryChannelClientStateRequest) Descriptor() ([]byte, []int)
- func (m *QueryChannelClientStateRequest) GetChannelId() string
- func (m *QueryChannelClientStateRequest) GetPortId() string
- func (m *QueryChannelClientStateRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryChannelClientStateRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryChannelClientStateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryChannelClientStateRequest) ProtoMessage()
- func (m *QueryChannelClientStateRequest) Reset()
- func (m *QueryChannelClientStateRequest) Size() (n int)
- func (m *QueryChannelClientStateRequest) String() string
- func (m *QueryChannelClientStateRequest) Unmarshal(dAtA []byte) error
- func (m *QueryChannelClientStateRequest) XXX_DiscardUnknown()
- func (m *QueryChannelClientStateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryChannelClientStateRequest) XXX_Merge(src proto.Message)
- func (m *QueryChannelClientStateRequest) XXX_Size() int
- func (m *QueryChannelClientStateRequest) XXX_Unmarshal(b []byte) error
- type QueryChannelClientStateResponse
- func (*QueryChannelClientStateResponse) Descriptor() ([]byte, []int)
- func (m *QueryChannelClientStateResponse) GetIdentifiedClientState() *types.IdentifiedClientState
- func (m *QueryChannelClientStateResponse) GetProof() []byte
- func (m *QueryChannelClientStateResponse) GetProofHeight() types.Height
- func (m *QueryChannelClientStateResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryChannelClientStateResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryChannelClientStateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryChannelClientStateResponse) ProtoMessage()
- func (m *QueryChannelClientStateResponse) Reset()
- func (m *QueryChannelClientStateResponse) Size() (n int)
- func (m *QueryChannelClientStateResponse) String() string
- func (m *QueryChannelClientStateResponse) Unmarshal(dAtA []byte) error
- func (qccsr QueryChannelClientStateResponse) UnpackInterfaces(unpacker codectypes.AnyUnpacker) error
- func (m *QueryChannelClientStateResponse) XXX_DiscardUnknown()
- func (m *QueryChannelClientStateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryChannelClientStateResponse) XXX_Merge(src proto.Message)
- func (m *QueryChannelClientStateResponse) XXX_Size() int
- func (m *QueryChannelClientStateResponse) XXX_Unmarshal(b []byte) error
- type QueryChannelConsensusStateRequest
- func (*QueryChannelConsensusStateRequest) Descriptor() ([]byte, []int)
- func (m *QueryChannelConsensusStateRequest) GetChannelId() string
- func (m *QueryChannelConsensusStateRequest) GetPortId() string
- func (m *QueryChannelConsensusStateRequest) GetRevisionHeight() uint64
- func (m *QueryChannelConsensusStateRequest) GetRevisionNumber() uint64
- func (m *QueryChannelConsensusStateRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryChannelConsensusStateRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryChannelConsensusStateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryChannelConsensusStateRequest) ProtoMessage()
- func (m *QueryChannelConsensusStateRequest) Reset()
- func (m *QueryChannelConsensusStateRequest) Size() (n int)
- func (m *QueryChannelConsensusStateRequest) String() string
- func (m *QueryChannelConsensusStateRequest) Unmarshal(dAtA []byte) error
- func (m *QueryChannelConsensusStateRequest) XXX_DiscardUnknown()
- func (m *QueryChannelConsensusStateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryChannelConsensusStateRequest) XXX_Merge(src proto.Message)
- func (m *QueryChannelConsensusStateRequest) XXX_Size() int
- func (m *QueryChannelConsensusStateRequest) XXX_Unmarshal(b []byte) error
- type QueryChannelConsensusStateResponse
- func (*QueryChannelConsensusStateResponse) Descriptor() ([]byte, []int)
- func (m *QueryChannelConsensusStateResponse) GetClientId() string
- func (m *QueryChannelConsensusStateResponse) GetConsensusState() *types1.Any
- func (m *QueryChannelConsensusStateResponse) GetProof() []byte
- func (m *QueryChannelConsensusStateResponse) GetProofHeight() types.Height
- func (m *QueryChannelConsensusStateResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryChannelConsensusStateResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryChannelConsensusStateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryChannelConsensusStateResponse) ProtoMessage()
- func (m *QueryChannelConsensusStateResponse) Reset()
- func (m *QueryChannelConsensusStateResponse) Size() (n int)
- func (m *QueryChannelConsensusStateResponse) String() string
- func (m *QueryChannelConsensusStateResponse) Unmarshal(dAtA []byte) error
- func (qccsr QueryChannelConsensusStateResponse) UnpackInterfaces(unpacker codectypes.AnyUnpacker) error
- func (m *QueryChannelConsensusStateResponse) XXX_DiscardUnknown()
- func (m *QueryChannelConsensusStateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryChannelConsensusStateResponse) XXX_Merge(src proto.Message)
- func (m *QueryChannelConsensusStateResponse) XXX_Size() int
- func (m *QueryChannelConsensusStateResponse) XXX_Unmarshal(b []byte) error
- type QueryChannelRequest
- func (*QueryChannelRequest) Descriptor() ([]byte, []int)
- func (m *QueryChannelRequest) GetChannelId() string
- func (m *QueryChannelRequest) GetPortId() string
- func (m *QueryChannelRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryChannelRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryChannelRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryChannelRequest) ProtoMessage()
- func (m *QueryChannelRequest) Reset()
- func (m *QueryChannelRequest) Size() (n int)
- func (m *QueryChannelRequest) String() string
- func (m *QueryChannelRequest) Unmarshal(dAtA []byte) error
- func (m *QueryChannelRequest) XXX_DiscardUnknown()
- func (m *QueryChannelRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryChannelRequest) XXX_Merge(src proto.Message)
- func (m *QueryChannelRequest) XXX_Size() int
- func (m *QueryChannelRequest) XXX_Unmarshal(b []byte) error
- type QueryChannelResponse
- func (*QueryChannelResponse) Descriptor() ([]byte, []int)
- func (m *QueryChannelResponse) GetChannel() *Channel
- func (m *QueryChannelResponse) GetProof() []byte
- func (m *QueryChannelResponse) GetProofHeight() types.Height
- func (m *QueryChannelResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryChannelResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryChannelResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryChannelResponse) ProtoMessage()
- func (m *QueryChannelResponse) Reset()
- func (m *QueryChannelResponse) Size() (n int)
- func (m *QueryChannelResponse) String() string
- func (m *QueryChannelResponse) Unmarshal(dAtA []byte) error
- func (m *QueryChannelResponse) XXX_DiscardUnknown()
- func (m *QueryChannelResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryChannelResponse) XXX_Merge(src proto.Message)
- func (m *QueryChannelResponse) XXX_Size() int
- func (m *QueryChannelResponse) XXX_Unmarshal(b []byte) error
- type QueryChannelsRequest
- func (*QueryChannelsRequest) Descriptor() ([]byte, []int)
- func (m *QueryChannelsRequest) GetPagination() *query.PageRequest
- func (m *QueryChannelsRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryChannelsRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryChannelsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryChannelsRequest) ProtoMessage()
- func (m *QueryChannelsRequest) Reset()
- func (m *QueryChannelsRequest) Size() (n int)
- func (m *QueryChannelsRequest) String() string
- func (m *QueryChannelsRequest) Unmarshal(dAtA []byte) error
- func (m *QueryChannelsRequest) XXX_DiscardUnknown()
- func (m *QueryChannelsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryChannelsRequest) XXX_Merge(src proto.Message)
- func (m *QueryChannelsRequest) XXX_Size() int
- func (m *QueryChannelsRequest) XXX_Unmarshal(b []byte) error
- type QueryChannelsResponse
- func (*QueryChannelsResponse) Descriptor() ([]byte, []int)
- func (m *QueryChannelsResponse) GetChannels() []*IdentifiedChannel
- func (m *QueryChannelsResponse) GetHeight() types.Height
- func (m *QueryChannelsResponse) GetPagination() *query.PageResponse
- func (m *QueryChannelsResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryChannelsResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryChannelsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryChannelsResponse) ProtoMessage()
- func (m *QueryChannelsResponse) Reset()
- func (m *QueryChannelsResponse) Size() (n int)
- func (m *QueryChannelsResponse) String() string
- func (m *QueryChannelsResponse) Unmarshal(dAtA []byte) error
- func (m *QueryChannelsResponse) XXX_DiscardUnknown()
- func (m *QueryChannelsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryChannelsResponse) XXX_Merge(src proto.Message)
- func (m *QueryChannelsResponse) XXX_Size() int
- func (m *QueryChannelsResponse) XXX_Unmarshal(b []byte) error
- type QueryClient
- type QueryConnectionChannelsRequest
- func (*QueryConnectionChannelsRequest) Descriptor() ([]byte, []int)
- func (m *QueryConnectionChannelsRequest) GetConnection() string
- func (m *QueryConnectionChannelsRequest) GetPagination() *query.PageRequest
- func (m *QueryConnectionChannelsRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryConnectionChannelsRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryConnectionChannelsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryConnectionChannelsRequest) ProtoMessage()
- func (m *QueryConnectionChannelsRequest) Reset()
- func (m *QueryConnectionChannelsRequest) Size() (n int)
- func (m *QueryConnectionChannelsRequest) String() string
- func (m *QueryConnectionChannelsRequest) Unmarshal(dAtA []byte) error
- func (m *QueryConnectionChannelsRequest) XXX_DiscardUnknown()
- func (m *QueryConnectionChannelsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryConnectionChannelsRequest) XXX_Merge(src proto.Message)
- func (m *QueryConnectionChannelsRequest) XXX_Size() int
- func (m *QueryConnectionChannelsRequest) XXX_Unmarshal(b []byte) error
- type QueryConnectionChannelsResponse
- func (*QueryConnectionChannelsResponse) Descriptor() ([]byte, []int)
- func (m *QueryConnectionChannelsResponse) GetChannels() []*IdentifiedChannel
- func (m *QueryConnectionChannelsResponse) GetHeight() types.Height
- func (m *QueryConnectionChannelsResponse) GetPagination() *query.PageResponse
- func (m *QueryConnectionChannelsResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryConnectionChannelsResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryConnectionChannelsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryConnectionChannelsResponse) ProtoMessage()
- func (m *QueryConnectionChannelsResponse) Reset()
- func (m *QueryConnectionChannelsResponse) Size() (n int)
- func (m *QueryConnectionChannelsResponse) String() string
- func (m *QueryConnectionChannelsResponse) Unmarshal(dAtA []byte) error
- func (m *QueryConnectionChannelsResponse) XXX_DiscardUnknown()
- func (m *QueryConnectionChannelsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryConnectionChannelsResponse) XXX_Merge(src proto.Message)
- func (m *QueryConnectionChannelsResponse) XXX_Size() int
- func (m *QueryConnectionChannelsResponse) XXX_Unmarshal(b []byte) error
- type QueryNextSequenceReceiveRequest
- func (*QueryNextSequenceReceiveRequest) Descriptor() ([]byte, []int)
- func (m *QueryNextSequenceReceiveRequest) GetChannelId() string
- func (m *QueryNextSequenceReceiveRequest) GetPortId() string
- func (m *QueryNextSequenceReceiveRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryNextSequenceReceiveRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryNextSequenceReceiveRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryNextSequenceReceiveRequest) ProtoMessage()
- func (m *QueryNextSequenceReceiveRequest) Reset()
- func (m *QueryNextSequenceReceiveRequest) Size() (n int)
- func (m *QueryNextSequenceReceiveRequest) String() string
- func (m *QueryNextSequenceReceiveRequest) Unmarshal(dAtA []byte) error
- func (m *QueryNextSequenceReceiveRequest) XXX_DiscardUnknown()
- func (m *QueryNextSequenceReceiveRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryNextSequenceReceiveRequest) XXX_Merge(src proto.Message)
- func (m *QueryNextSequenceReceiveRequest) XXX_Size() int
- func (m *QueryNextSequenceReceiveRequest) XXX_Unmarshal(b []byte) error
- type QueryNextSequenceReceiveResponse
- func (*QueryNextSequenceReceiveResponse) Descriptor() ([]byte, []int)
- func (m *QueryNextSequenceReceiveResponse) GetNextSequenceReceive() uint64
- func (m *QueryNextSequenceReceiveResponse) GetProof() []byte
- func (m *QueryNextSequenceReceiveResponse) GetProofHeight() types.Height
- func (m *QueryNextSequenceReceiveResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryNextSequenceReceiveResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryNextSequenceReceiveResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryNextSequenceReceiveResponse) ProtoMessage()
- func (m *QueryNextSequenceReceiveResponse) Reset()
- func (m *QueryNextSequenceReceiveResponse) Size() (n int)
- func (m *QueryNextSequenceReceiveResponse) String() string
- func (m *QueryNextSequenceReceiveResponse) Unmarshal(dAtA []byte) error
- func (m *QueryNextSequenceReceiveResponse) XXX_DiscardUnknown()
- func (m *QueryNextSequenceReceiveResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryNextSequenceReceiveResponse) XXX_Merge(src proto.Message)
- func (m *QueryNextSequenceReceiveResponse) XXX_Size() int
- func (m *QueryNextSequenceReceiveResponse) XXX_Unmarshal(b []byte) error
- type QueryPacketAcknowledgementRequest
- func (*QueryPacketAcknowledgementRequest) Descriptor() ([]byte, []int)
- func (m *QueryPacketAcknowledgementRequest) GetChannelId() string
- func (m *QueryPacketAcknowledgementRequest) GetPortId() string
- func (m *QueryPacketAcknowledgementRequest) GetSequence() uint64
- 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) GetChannelId() string
- func (m *QueryPacketAcknowledgementsRequest) GetPagination() *query.PageRequest
- func (m *QueryPacketAcknowledgementsRequest) GetPortId() 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) GetChannelId() string
- func (m *QueryPacketCommitmentRequest) GetPortId() string
- func (m *QueryPacketCommitmentRequest) GetSequence() uint64
- 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) GetChannelId() string
- func (m *QueryPacketCommitmentsRequest) GetPagination() *query.PageRequest
- func (m *QueryPacketCommitmentsRequest) GetPortId() 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) GetChannelId() string
- func (m *QueryPacketReceiptRequest) GetPortId() string
- func (m *QueryPacketReceiptRequest) GetSequence() uint64
- 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) GetChannelId() string
- func (m *QueryUnreceivedAcksRequest) GetPacketAckSequences() []uint64
- func (m *QueryUnreceivedAcksRequest) GetPortId() 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) GetChannelId() string
- func (m *QueryUnreceivedPacketsRequest) GetPacketCommitmentSequences() []uint64
- func (m *QueryUnreceivedPacketsRequest) GetPortId() 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 State
- type UnimplementedMsgServer
- func (*UnimplementedMsgServer) Acknowledgement(ctx context.Context, req *MsgAcknowledgement) (*MsgAcknowledgementResponse, error)
- func (*UnimplementedMsgServer) ChannelCloseConfirm(ctx context.Context, req *MsgChannelCloseConfirm) (*MsgChannelCloseConfirmResponse, error)
- func (*UnimplementedMsgServer) ChannelCloseInit(ctx context.Context, req *MsgChannelCloseInit) (*MsgChannelCloseInitResponse, error)
- func (*UnimplementedMsgServer) ChannelOpenAck(ctx context.Context, req *MsgChannelOpenAck) (*MsgChannelOpenAckResponse, error)
- func (*UnimplementedMsgServer) ChannelOpenConfirm(ctx context.Context, req *MsgChannelOpenConfirm) (*MsgChannelOpenConfirmResponse, error)
- func (*UnimplementedMsgServer) ChannelOpenInit(ctx context.Context, req *MsgChannelOpenInit) (*MsgChannelOpenInitResponse, error)
- func (*UnimplementedMsgServer) ChannelOpenTry(ctx context.Context, req *MsgChannelOpenTry) (*MsgChannelOpenTryResponse, error)
- func (*UnimplementedMsgServer) RecvPacket(ctx context.Context, req *MsgRecvPacket) (*MsgRecvPacketResponse, error)
- func (*UnimplementedMsgServer) Timeout(ctx context.Context, req *MsgTimeout) (*MsgTimeoutResponse, error)
- func (*UnimplementedMsgServer) TimeoutOnClose(ctx context.Context, req *MsgTimeoutOnClose) (*MsgTimeoutOnCloseResponse, error)
- type UnimplementedQueryServer
- func (*UnimplementedQueryServer) Channel(ctx context.Context, req *QueryChannelRequest) (*QueryChannelResponse, error)
- func (*UnimplementedQueryServer) ChannelClientState(ctx context.Context, req *QueryChannelClientStateRequest) (*QueryChannelClientStateResponse, error)
- func (*UnimplementedQueryServer) ChannelConsensusState(ctx context.Context, req *QueryChannelConsensusStateRequest) (*QueryChannelConsensusStateResponse, error)
- func (*UnimplementedQueryServer) Channels(ctx context.Context, req *QueryChannelsRequest) (*QueryChannelsResponse, error)
- func (*UnimplementedQueryServer) ConnectionChannels(ctx context.Context, req *QueryConnectionChannelsRequest) (*QueryConnectionChannelsResponse, error)
- func (*UnimplementedQueryServer) NextSequenceReceive(ctx context.Context, req *QueryNextSequenceReceiveRequest) (*QueryNextSequenceReceiveResponse, error)
- func (*UnimplementedQueryServer) PacketAcknowledgement(ctx context.Context, req *QueryPacketAcknowledgementRequest) (*QueryPacketAcknowledgementResponse, error)
- func (*UnimplementedQueryServer) PacketAcknowledgements(ctx context.Context, req *QueryPacketAcknowledgementsRequest) (*QueryPacketAcknowledgementsResponse, error)
- func (*UnimplementedQueryServer) PacketCommitment(ctx context.Context, req *QueryPacketCommitmentRequest) (*QueryPacketCommitmentResponse, error)
- func (*UnimplementedQueryServer) PacketCommitments(ctx context.Context, req *QueryPacketCommitmentsRequest) (*QueryPacketCommitmentsResponse, error)
- func (*UnimplementedQueryServer) PacketReceipt(ctx context.Context, req *QueryPacketReceiptRequest) (*QueryPacketReceiptResponse, error)
- func (*UnimplementedQueryServer) UnreceivedAcks(ctx context.Context, req *QueryUnreceivedAcksRequest) (*QueryUnreceivedAcksResponse, error)
- func (*UnimplementedQueryServer) UnreceivedPackets(ctx context.Context, req *QueryUnreceivedPacketsRequest) (*QueryUnreceivedPacketsResponse, error)
Constants ¶
const ( AttributeKeyConnectionID = "connection_id" AttributeKeyPortID = "port_id" AttributeKeyChannelID = "channel_id" AttributeCounterpartyPortID = "counterparty_port_id" AttributeCounterpartyChannelID = "counterparty_channel_id" EventTypeSendPacket = "send_packet" EventTypeRecvPacket = "recv_packet" EventTypeWriteAck = "write_acknowledgement" EventTypeAcknowledgePacket = "acknowledge_packet" EventTypeTimeoutPacket = "timeout_packet" AttributeKeyData = "packet_data" AttributeKeyAck = "packet_ack" AttributeKeyTimeoutHeight = "packet_timeout_height" AttributeKeyTimeoutTimestamp = "packet_timeout_timestamp" AttributeKeySequence = "packet_sequence" AttributeKeySrcPort = "packet_src_port" AttributeKeySrcChannel = "packet_src_channel" AttributeKeyDstPort = "packet_dst_port" AttributeKeyDstChannel = "packet_dst_channel" AttributeKeyChannelOrdering = "packet_channel_ordering" AttributeKeyConnection = "packet_connection" )
ICP channel events
const ( // SubModuleName defines the ICP channels name SubModuleName = "channel" // StoreKey is the store key string for ICP channels StoreKey = SubModuleName // RouterKey is the message route for ICP channels RouterKey = SubModuleName // QuerierRoute is the querier route for ICP channels QuerierRoute = SubModuleName // KeyNextChannelSequence is the key used to store the next channel sequence in // the keeper. KeyNextChannelSequence = "nextChannelSequence" // ChannelPrefix is the prefix used when creating a channel identifier ChannelPrefix = "channel-" )
Variables ¶
var ( ErrInvalidLengthChannel = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowChannel = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupChannel = fmt.Errorf("proto: unexpected end of group") )
var ( ErrChannelExists = sdkerrors.Register(SubModuleName, 2, "channel already exists") ErrChannelNotFound = sdkerrors.Register(SubModuleName, 3, "channel not found") ErrInvalidChannel = sdkerrors.Register(SubModuleName, 4, "invalid channel") ErrInvalidChannelState = sdkerrors.Register(SubModuleName, 5, "invalid channel state") ErrInvalidChannelOrdering = sdkerrors.Register(SubModuleName, 6, "invalid channel ordering") ErrInvalidCounterparty = sdkerrors.Register(SubModuleName, 7, "invalid counterparty channel") ErrInvalidChannelCapability = sdkerrors.Register(SubModuleName, 8, "invalid channel capability") ErrChannelCapabilityNotFound = sdkerrors.Register(SubModuleName, 9, "channel capability not found") ErrSequenceSendNotFound = sdkerrors.Register(SubModuleName, 10, "sequence send not found") ErrSequenceReceiveNotFound = sdkerrors.Register(SubModuleName, 11, "sequence receive not found") ErrSequenceAckNotFound = sdkerrors.Register(SubModuleName, 12, "sequence acknowledgement not found") ErrInvalidPacket = sdkerrors.Register(SubModuleName, 13, "invalid packet") ErrPacketTimeout = sdkerrors.Register(SubModuleName, 14, "packet timeout") ErrTooManyConnectionHops = sdkerrors.Register(SubModuleName, 15, "too many connection hops") ErrInvalidAcknowledgement = sdkerrors.Register(SubModuleName, 16, "invalid acknowledgement") ErrPacketCommitmentNotFound = sdkerrors.Register(SubModuleName, 17, "packet commitment not found") ErrPacketReceived = sdkerrors.Register(SubModuleName, 18, "packet already received") ErrAcknowledgementExists = sdkerrors.Register(SubModuleName, 19, "acknowledgement for packet already exists") ErrInvalidChannelIdentifier = sdkerrors.Register(SubModuleName, 20, "invalid channel identifier") )
ICP channel sentinel errors
var ( EventTypeChannelOpenInit = MsgChannelOpenInit{}.Type() EventTypeChannelOpenTry = MsgChannelOpenTry{}.Type() EventTypeChannelOpenAck = MsgChannelOpenAck{}.Type() EventTypeChannelOpenConfirm = MsgChannelOpenConfirm{}.Type() EventTypeChannelCloseInit = MsgChannelCloseInit{}.Type() EventTypeChannelCloseConfirm = MsgChannelCloseConfirm{}.Type() AttributeValueCategory = fmt.Sprintf("%s_%s", host.ModuleName, SubModuleName) )
ICP channel events vars
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 ( 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 IsChannelIDFormat = regexp.MustCompile(`^channel-[0-9]{1,20}$`).MatchString
IsChannelIDFormat checks if a channelID is in the format required on the SDK for parsing channel identifiers. The channel identifier must be in the form: `channel-{N}
var Order_name = map[int32]string{
0: "ORDER_NONE_UNSPECIFIED",
1: "ORDER_UNORDERED",
2: "ORDER_ORDERED",
}
var Order_value = map[string]int32{
"ORDER_NONE_UNSPECIFIED": 0,
"ORDER_UNORDERED": 1,
"ORDER_ORDERED": 2,
}
var State_name = map[int32]string{
0: "STATE_UNINITIALIZED_UNSPECIFIED",
1: "STATE_INIT",
2: "STATE_TRYOPEN",
3: "STATE_OPEN",
4: "STATE_CLOSED",
}
var State_value = map[string]int32{
"STATE_UNINITIALIZED_UNSPECIFIED": 0,
"STATE_INIT": 1,
"STATE_TRYOPEN": 2,
"STATE_OPEN": 3,
"STATE_CLOSED": 4,
}
var SubModuleCdc = codec.NewProtoCodec(codectypes.NewInterfaceRegistry())
SubModuleCdc references the global x/icp/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/icp/core/04-channel and defined at the application level.
Functions ¶
func CommitAcknowledgement ¶
CommitAcknowledgement returns the hash of commitment bytes
func CommitPacket ¶
func CommitPacket(cdc codec.BinaryMarshaler, packet exported.PacketI) []byte
CommitPacket returns the packet commitment bytes. The commitment consists of: sha256_hash(timeout_timestamp + timeout_height.RevisionNumber + timeout_height.RevisionHeight + sha256_hash(data)) from a given packet. This results in a fixed length preimage. NOTE: sdk.Uint64ToBigEndian sets the uint64 to a slice of length 8.
func FormatChannelIdentifier ¶
FormatChannelIdentifier returns the channel identifier with the sequence appended. This is a SDK specific format not enforced by ICP protocol.
func IsValidChannelID ¶
IsValidChannelID checks if a channelID is valid and can be parsed to the channel identifier format.
func ParseChannelSequence ¶
ParseChannelSequence parses the channel sequence from the channel identifier.
func RegisterInterfaces ¶
func RegisterInterfaces(registry codectypes.InterfaceRegistry)
RegisterInterfaces register the icp channel 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. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterQueryHandlerFromEndpoint instead.
func RegisterQueryServer ¶
func RegisterQueryServer(s grpc1.Server, srv QueryServer)
Types ¶
type Acknowledgement ¶
type Acknowledgement struct { // response contains either a result or an error and must be non-empty // // Types that are valid to be assigned to Response: // *Acknowledgement_Result // *Acknowledgement_Error Response isAcknowledgement_Response `protobuf_oneof:"response"` }
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) ValidateBasic ¶
func (ack Acknowledgement) ValidateBasic() error
ValidateBasic performs a basic validation of the acknowledgement
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 Channel ¶
type Channel struct { // current state of the channel end State State `protobuf:"varint,1,opt,name=state,proto3,enum=icp.core.channel.v1.State" json:"state,omitempty"` // whether the channel is ordered or unordered Ordering Order `protobuf:"varint,2,opt,name=ordering,proto3,enum=icp.core.channel.v1.Order" json:"ordering,omitempty"` // counterparty channel end Counterparty Counterparty `protobuf:"bytes,3,opt,name=counterparty,proto3" json:"counterparty"` // list of connection identifiers, in order, along which packets sent on // this channel will travel ConnectionHops []string `` /* 126-byte string literal not displayed */ // opaque channel version, which is agreed upon during the handshake Version string `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"` }
Channel defines pipeline for exactly-once packet delivery between specific modules on separate blockchains, which has at least one end capable of sending packets and one end capable of receiving packets.
func NewChannel ¶
func NewChannel( state State, ordering Order, counterparty Counterparty, hops []string, version string, ) Channel
NewChannel creates a new Channel instance
func (*Channel) Descriptor ¶
func (Channel) GetConnectionHops ¶
GetConnectionHops implements Channel interface.
func (Channel) GetCounterparty ¶
func (ch Channel) GetCounterparty() exported.CounterpartyChannelI
GetCounterparty implements Channel interface.
func (Channel) GetOrdering ¶
GetOrdering implements Channel interface.
func (Channel) GetVersion ¶
GetVersion implements Channel interface.
func (*Channel) MarshalToSizedBuffer ¶
func (*Channel) ProtoMessage ¶
func (*Channel) ProtoMessage()
func (Channel) ValidateBasic ¶
ValidateBasic performs a basic validation of the channel fields
func (*Channel) XXX_DiscardUnknown ¶
func (m *Channel) XXX_DiscardUnknown()
func (*Channel) XXX_Marshal ¶
func (*Channel) XXX_Unmarshal ¶
type ClientKeeper ¶
type ClientKeeper interface { GetClientState(ctx sdk.Context, clientID string) (exported.ClientState, bool) GetClientConsensusState(ctx sdk.Context, clientID string, height exported.Height) (exported.ConsensusState, bool) }
ClientKeeper expected account ICP client keeper
type ConnectionKeeper ¶
type ConnectionKeeper interface { GetConnection(ctx sdk.Context, connectionID string) (connectiontypes.ConnectionEnd, bool) GetTimestampAtHeight( ctx sdk.Context, connection connectiontypes.ConnectionEnd, height exported.Height, ) (uint64, error) VerifyChannelState( ctx sdk.Context, connection exported.ConnectionI, height exported.Height, proof []byte, portID, channelID string, channel exported.ChannelI, ) error VerifyPacketCommitment( ctx sdk.Context, connection exported.ConnectionI, height exported.Height, proof []byte, portID, channelID string, sequence uint64, commitmentBytes []byte, ) error VerifyPacketAcknowledgement( ctx sdk.Context, connection exported.ConnectionI, height exported.Height, proof []byte, portID, channelID string, sequence uint64, acknowledgement []byte, ) error VerifyPacketReceiptAbsence( ctx sdk.Context, connection exported.ConnectionI, height exported.Height, proof []byte, portID, channelID string, sequence uint64, ) error VerifyNextSequenceRecv( ctx sdk.Context, connection exported.ConnectionI, height exported.Height, proof []byte, portID, channelID string, nextSequenceRecv uint64, ) error }
ConnectionKeeper expected account ICP connection keeper
type Counterparty ¶
type Counterparty struct { // port on the counterparty chain which owns the other end of the channel. PortId string `protobuf:"bytes,1,opt,name=port_id,json=portId,proto3" json:"port_id,omitempty" yaml:"port_id"` // channel end on the counterparty chain ChannelId string `protobuf:"bytes,2,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty" yaml:"channel_id"` }
Counterparty defines a channel end counterparty
func NewCounterparty ¶
func NewCounterparty(portID, channelID string) Counterparty
NewCounterparty returns a new Counterparty instance
func (*Counterparty) Descriptor ¶
func (*Counterparty) Descriptor() ([]byte, []int)
func (Counterparty) GetChannelID ¶
func (c Counterparty) GetChannelID() string
GetChannelID implements CounterpartyChannelI interface
func (Counterparty) GetPortID ¶
func (c Counterparty) GetPortID() string
GetPortID implements CounterpartyChannelI interface
func (*Counterparty) Marshal ¶
func (m *Counterparty) Marshal() (dAtA []byte, err error)
func (*Counterparty) MarshalToSizedBuffer ¶
func (m *Counterparty) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Counterparty) ProtoMessage ¶
func (*Counterparty) ProtoMessage()
func (*Counterparty) Reset ¶
func (m *Counterparty) Reset()
func (*Counterparty) Size ¶
func (m *Counterparty) Size() (n int)
func (*Counterparty) String ¶
func (m *Counterparty) String() string
func (*Counterparty) Unmarshal ¶
func (m *Counterparty) Unmarshal(dAtA []byte) error
func (Counterparty) ValidateBasic ¶
func (c Counterparty) ValidateBasic() error
ValidateBasic performs a basic validation check of the identifiers
func (*Counterparty) XXX_DiscardUnknown ¶
func (m *Counterparty) XXX_DiscardUnknown()
func (*Counterparty) XXX_Marshal ¶
func (m *Counterparty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Counterparty) XXX_Merge ¶
func (m *Counterparty) XXX_Merge(src proto.Message)
func (*Counterparty) XXX_Size ¶
func (m *Counterparty) XXX_Size() int
func (*Counterparty) XXX_Unmarshal ¶
func (m *Counterparty) XXX_Unmarshal(b []byte) error
type GenesisState ¶
type GenesisState struct { Channels []IdentifiedChannel `protobuf:"bytes,1,rep,name=channels,proto3,casttype=IdentifiedChannel" json:"channels"` Acknowledgements []PacketState `protobuf:"bytes,2,rep,name=acknowledgements,proto3" json:"acknowledgements"` Commitments []PacketState `protobuf:"bytes,3,rep,name=commitments,proto3" json:"commitments"` Receipts []PacketState `protobuf:"bytes,4,rep,name=receipts,proto3" json:"receipts"` SendSequences []PacketSequence `protobuf:"bytes,5,rep,name=send_sequences,json=sendSequences,proto3" json:"send_sequences" yaml:"send_sequences"` RecvSequences []PacketSequence `protobuf:"bytes,6,rep,name=recv_sequences,json=recvSequences,proto3" json:"recv_sequences" yaml:"recv_sequences"` AckSequences []PacketSequence `protobuf:"bytes,7,rep,name=ack_sequences,json=ackSequences,proto3" json:"ack_sequences" yaml:"ack_sequences"` // the sequence for the next generated channel identifier NextChannelSequence uint64 `` /* 150-byte string literal not displayed */ }
GenesisState defines the icp channel submodule's genesis state.
func DefaultGenesisState ¶
func DefaultGenesisState() GenesisState
DefaultGenesisState returns the icp channel submodule's default genesis state.
func NewGenesisState ¶
func NewGenesisState( channels []IdentifiedChannel, acks, receipts, commitments []PacketState, sendSeqs, recvSeqs, ackSeqs []PacketSequence, nextChannelSequence uint64, ) GenesisState
NewGenesisState creates a GenesisState instance.
func (*GenesisState) Descriptor ¶
func (*GenesisState) Descriptor() ([]byte, []int)
func (*GenesisState) GetAckSequences ¶
func (m *GenesisState) GetAckSequences() []PacketSequence
func (*GenesisState) GetAcknowledgements ¶
func (m *GenesisState) GetAcknowledgements() []PacketState
func (*GenesisState) GetChannels ¶
func (m *GenesisState) GetChannels() []IdentifiedChannel
func (*GenesisState) GetCommitments ¶
func (m *GenesisState) GetCommitments() []PacketState
func (*GenesisState) GetNextChannelSequence ¶
func (m *GenesisState) GetNextChannelSequence() uint64
func (*GenesisState) GetReceipts ¶
func (m *GenesisState) GetReceipts() []PacketState
func (*GenesisState) GetRecvSequences ¶
func (m *GenesisState) GetRecvSequences() []PacketSequence
func (*GenesisState) GetSendSequences ¶
func (m *GenesisState) GetSendSequences() []PacketSequence
func (*GenesisState) Marshal ¶
func (m *GenesisState) Marshal() (dAtA []byte, err error)
func (*GenesisState) MarshalToSizedBuffer ¶
func (m *GenesisState) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GenesisState) ProtoMessage ¶
func (*GenesisState) ProtoMessage()
func (*GenesisState) Reset ¶
func (m *GenesisState) Reset()
func (*GenesisState) Size ¶
func (m *GenesisState) Size() (n int)
func (*GenesisState) String ¶
func (m *GenesisState) String() string
func (*GenesisState) Unmarshal ¶
func (m *GenesisState) Unmarshal(dAtA []byte) error
func (GenesisState) Validate ¶
func (gs GenesisState) Validate() error
Validate performs basic genesis state validation returning an error upon any failure.
func (*GenesisState) XXX_DiscardUnknown ¶
func (m *GenesisState) XXX_DiscardUnknown()
func (*GenesisState) XXX_Marshal ¶
func (m *GenesisState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GenesisState) XXX_Merge ¶
func (m *GenesisState) XXX_Merge(src proto.Message)
func (*GenesisState) XXX_Size ¶
func (m *GenesisState) XXX_Size() int
func (*GenesisState) XXX_Unmarshal ¶
func (m *GenesisState) XXX_Unmarshal(b []byte) error
type IdentifiedChannel ¶
type IdentifiedChannel struct { // current state of the channel end State State `protobuf:"varint,1,opt,name=state,proto3,enum=icp.core.channel.v1.State" json:"state,omitempty"` // whether the channel is ordered or unordered Ordering Order `protobuf:"varint,2,opt,name=ordering,proto3,enum=icp.core.channel.v1.Order" json:"ordering,omitempty"` // counterparty channel end Counterparty Counterparty `protobuf:"bytes,3,opt,name=counterparty,proto3" json:"counterparty"` // list of connection identifiers, in order, along which packets sent on // this channel will travel ConnectionHops []string `` /* 126-byte string literal not displayed */ // opaque channel version, which is agreed upon during the handshake Version string `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"` // port identifier PortId string `protobuf:"bytes,6,opt,name=port_id,json=portId,proto3" json:"port_id,omitempty"` // channel identifier ChannelId string `protobuf:"bytes,7,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"` }
IdentifiedChannel defines a channel with additional port and channel identifier fields.
func NewIdentifiedChannel ¶
func NewIdentifiedChannel(portID, channelID string, ch Channel) IdentifiedChannel
NewIdentifiedChannel creates a new IdentifiedChannel instance
func (*IdentifiedChannel) Descriptor ¶
func (*IdentifiedChannel) Descriptor() ([]byte, []int)
func (*IdentifiedChannel) Marshal ¶
func (m *IdentifiedChannel) Marshal() (dAtA []byte, err error)
func (*IdentifiedChannel) MarshalTo ¶
func (m *IdentifiedChannel) MarshalTo(dAtA []byte) (int, error)
func (*IdentifiedChannel) MarshalToSizedBuffer ¶
func (m *IdentifiedChannel) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*IdentifiedChannel) ProtoMessage ¶
func (*IdentifiedChannel) ProtoMessage()
func (*IdentifiedChannel) Reset ¶
func (m *IdentifiedChannel) Reset()
func (*IdentifiedChannel) Size ¶
func (m *IdentifiedChannel) Size() (n int)
func (*IdentifiedChannel) String ¶
func (m *IdentifiedChannel) String() string
func (*IdentifiedChannel) Unmarshal ¶
func (m *IdentifiedChannel) Unmarshal(dAtA []byte) error
func (IdentifiedChannel) ValidateBasic ¶
func (ic IdentifiedChannel) ValidateBasic() error
ValidateBasic performs a basic validation of the identifiers and channel fields.
func (*IdentifiedChannel) XXX_DiscardUnknown ¶
func (m *IdentifiedChannel) XXX_DiscardUnknown()
func (*IdentifiedChannel) XXX_Marshal ¶
func (m *IdentifiedChannel) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*IdentifiedChannel) XXX_Merge ¶
func (m *IdentifiedChannel) XXX_Merge(src proto.Message)
func (*IdentifiedChannel) XXX_Size ¶
func (m *IdentifiedChannel) XXX_Size() int
func (*IdentifiedChannel) XXX_Unmarshal ¶
func (m *IdentifiedChannel) 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 ICP acknowledgement
func NewMsgAcknowledgement ¶
func NewMsgAcknowledgement( packet Packet, ack, proofAcked []byte, proofHeight clienttypes.Height, signer sdk.AccAddress, ) *MsgAcknowledgement
NewMsgAcknowledgement constructs a new MsgAcknowledgement nolint:interfacer
func (*MsgAcknowledgement) Descriptor ¶
func (*MsgAcknowledgement) Descriptor() ([]byte, []int)
func (MsgAcknowledgement) GetSignBytes ¶
func (msg MsgAcknowledgement) GetSignBytes() []byte
GetSignBytes implements sdk.Msg. The function will panic since it is used for amino transaction verification which ICP does not support.
func (MsgAcknowledgement) GetSigners ¶
func (msg MsgAcknowledgement) GetSigners() []sdk.AccAddress
GetSigners implements sdk.Msg
func (*MsgAcknowledgement) Marshal ¶
func (m *MsgAcknowledgement) Marshal() (dAtA []byte, err error)
func (*MsgAcknowledgement) MarshalTo ¶
func (m *MsgAcknowledgement) MarshalTo(dAtA []byte) (int, error)
func (*MsgAcknowledgement) MarshalToSizedBuffer ¶
func (m *MsgAcknowledgement) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgAcknowledgement) ProtoMessage ¶
func (*MsgAcknowledgement) ProtoMessage()
func (*MsgAcknowledgement) Reset ¶
func (m *MsgAcknowledgement) Reset()
func (MsgAcknowledgement) Route ¶
func (msg MsgAcknowledgement) Route() string
Route implements sdk.Msg
func (*MsgAcknowledgement) Size ¶
func (m *MsgAcknowledgement) Size() (n int)
func (*MsgAcknowledgement) String ¶
func (m *MsgAcknowledgement) String() string
func (MsgAcknowledgement) Type ¶
func (msg MsgAcknowledgement) Type() string
Type implements sdk.Msg
func (*MsgAcknowledgement) Unmarshal ¶
func (m *MsgAcknowledgement) Unmarshal(dAtA []byte) error
func (MsgAcknowledgement) ValidateBasic ¶
func (msg MsgAcknowledgement) ValidateBasic() error
ValidateBasic implements sdk.Msg
func (*MsgAcknowledgement) XXX_DiscardUnknown ¶
func (m *MsgAcknowledgement) XXX_DiscardUnknown()
func (*MsgAcknowledgement) XXX_Marshal ¶
func (m *MsgAcknowledgement) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgAcknowledgement) XXX_Merge ¶
func (m *MsgAcknowledgement) XXX_Merge(src proto.Message)
func (*MsgAcknowledgement) XXX_Size ¶
func (m *MsgAcknowledgement) XXX_Size() int
func (*MsgAcknowledgement) XXX_Unmarshal ¶
func (m *MsgAcknowledgement) XXX_Unmarshal(b []byte) error
type MsgAcknowledgementResponse ¶
type MsgAcknowledgementResponse struct { }
MsgAcknowledgementResponse defines the Msg/Acknowledgement response type.
func (*MsgAcknowledgementResponse) Descriptor ¶
func (*MsgAcknowledgementResponse) Descriptor() ([]byte, []int)
func (*MsgAcknowledgementResponse) Marshal ¶
func (m *MsgAcknowledgementResponse) Marshal() (dAtA []byte, err error)
func (*MsgAcknowledgementResponse) MarshalTo ¶
func (m *MsgAcknowledgementResponse) MarshalTo(dAtA []byte) (int, error)
func (*MsgAcknowledgementResponse) MarshalToSizedBuffer ¶
func (m *MsgAcknowledgementResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgAcknowledgementResponse) ProtoMessage ¶
func (*MsgAcknowledgementResponse) ProtoMessage()
func (*MsgAcknowledgementResponse) Reset ¶
func (m *MsgAcknowledgementResponse) Reset()
func (*MsgAcknowledgementResponse) Size ¶
func (m *MsgAcknowledgementResponse) Size() (n int)
func (*MsgAcknowledgementResponse) String ¶
func (m *MsgAcknowledgementResponse) String() string
func (*MsgAcknowledgementResponse) Unmarshal ¶
func (m *MsgAcknowledgementResponse) Unmarshal(dAtA []byte) error
func (*MsgAcknowledgementResponse) XXX_DiscardUnknown ¶
func (m *MsgAcknowledgementResponse) XXX_DiscardUnknown()
func (*MsgAcknowledgementResponse) XXX_Marshal ¶
func (m *MsgAcknowledgementResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgAcknowledgementResponse) XXX_Merge ¶
func (m *MsgAcknowledgementResponse) XXX_Merge(src proto.Message)
func (*MsgAcknowledgementResponse) XXX_Size ¶
func (m *MsgAcknowledgementResponse) XXX_Size() int
func (*MsgAcknowledgementResponse) XXX_Unmarshal ¶
func (m *MsgAcknowledgementResponse) XXX_Unmarshal(b []byte) error
type MsgChannelCloseConfirm ¶
type MsgChannelCloseConfirm struct { PortId string `protobuf:"bytes,1,opt,name=port_id,json=portId,proto3" json:"port_id,omitempty" yaml:"port_id"` ChannelId string `protobuf:"bytes,2,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty" yaml:"channel_id"` ProofInit []byte `protobuf:"bytes,3,opt,name=proof_init,json=proofInit,proto3" json:"proof_init,omitempty" yaml:"proof_init"` 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"` }
MsgChannelCloseConfirm defines a msg sent by a Relayer to Chain B to acknowledge the change of channel state to CLOSED on Chain A.
func NewMsgChannelCloseConfirm ¶
func NewMsgChannelCloseConfirm( portID, channelID string, proofInit []byte, proofHeight clienttypes.Height, signer sdk.AccAddress, ) *MsgChannelCloseConfirm
NewMsgChannelCloseConfirm creates a new MsgChannelCloseConfirm instance nolint:interfacer
func (*MsgChannelCloseConfirm) Descriptor ¶
func (*MsgChannelCloseConfirm) Descriptor() ([]byte, []int)
func (MsgChannelCloseConfirm) GetSignBytes ¶
func (msg MsgChannelCloseConfirm) GetSignBytes() []byte
GetSignBytes implements sdk.Msg. The function will panic since it is used for amino transaction verification which ICP does not support.
func (MsgChannelCloseConfirm) GetSigners ¶
func (msg MsgChannelCloseConfirm) GetSigners() []sdk.AccAddress
GetSigners implements sdk.Msg
func (*MsgChannelCloseConfirm) Marshal ¶
func (m *MsgChannelCloseConfirm) Marshal() (dAtA []byte, err error)
func (*MsgChannelCloseConfirm) MarshalTo ¶
func (m *MsgChannelCloseConfirm) MarshalTo(dAtA []byte) (int, error)
func (*MsgChannelCloseConfirm) MarshalToSizedBuffer ¶
func (m *MsgChannelCloseConfirm) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgChannelCloseConfirm) ProtoMessage ¶
func (*MsgChannelCloseConfirm) ProtoMessage()
func (*MsgChannelCloseConfirm) Reset ¶
func (m *MsgChannelCloseConfirm) Reset()
func (MsgChannelCloseConfirm) Route ¶
func (msg MsgChannelCloseConfirm) Route() string
Route implements sdk.Msg
func (*MsgChannelCloseConfirm) Size ¶
func (m *MsgChannelCloseConfirm) Size() (n int)
func (*MsgChannelCloseConfirm) String ¶
func (m *MsgChannelCloseConfirm) String() string
func (MsgChannelCloseConfirm) Type ¶
func (msg MsgChannelCloseConfirm) Type() string
Type implements sdk.Msg
func (*MsgChannelCloseConfirm) Unmarshal ¶
func (m *MsgChannelCloseConfirm) Unmarshal(dAtA []byte) error
func (MsgChannelCloseConfirm) ValidateBasic ¶
func (msg MsgChannelCloseConfirm) ValidateBasic() error
ValidateBasic implements sdk.Msg
func (*MsgChannelCloseConfirm) XXX_DiscardUnknown ¶
func (m *MsgChannelCloseConfirm) XXX_DiscardUnknown()
func (*MsgChannelCloseConfirm) XXX_Marshal ¶
func (m *MsgChannelCloseConfirm) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgChannelCloseConfirm) XXX_Merge ¶
func (m *MsgChannelCloseConfirm) XXX_Merge(src proto.Message)
func (*MsgChannelCloseConfirm) XXX_Size ¶
func (m *MsgChannelCloseConfirm) XXX_Size() int
func (*MsgChannelCloseConfirm) XXX_Unmarshal ¶
func (m *MsgChannelCloseConfirm) XXX_Unmarshal(b []byte) error
type MsgChannelCloseConfirmResponse ¶
type MsgChannelCloseConfirmResponse struct { }
MsgChannelCloseConfirmResponse defines the Msg/ChannelCloseConfirm response type.
func (*MsgChannelCloseConfirmResponse) Descriptor ¶
func (*MsgChannelCloseConfirmResponse) Descriptor() ([]byte, []int)
func (*MsgChannelCloseConfirmResponse) Marshal ¶
func (m *MsgChannelCloseConfirmResponse) Marshal() (dAtA []byte, err error)
func (*MsgChannelCloseConfirmResponse) MarshalTo ¶
func (m *MsgChannelCloseConfirmResponse) MarshalTo(dAtA []byte) (int, error)
func (*MsgChannelCloseConfirmResponse) MarshalToSizedBuffer ¶
func (m *MsgChannelCloseConfirmResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgChannelCloseConfirmResponse) ProtoMessage ¶
func (*MsgChannelCloseConfirmResponse) ProtoMessage()
func (*MsgChannelCloseConfirmResponse) Reset ¶
func (m *MsgChannelCloseConfirmResponse) Reset()
func (*MsgChannelCloseConfirmResponse) Size ¶
func (m *MsgChannelCloseConfirmResponse) Size() (n int)
func (*MsgChannelCloseConfirmResponse) String ¶
func (m *MsgChannelCloseConfirmResponse) String() string
func (*MsgChannelCloseConfirmResponse) Unmarshal ¶
func (m *MsgChannelCloseConfirmResponse) Unmarshal(dAtA []byte) error
func (*MsgChannelCloseConfirmResponse) XXX_DiscardUnknown ¶
func (m *MsgChannelCloseConfirmResponse) XXX_DiscardUnknown()
func (*MsgChannelCloseConfirmResponse) XXX_Marshal ¶
func (m *MsgChannelCloseConfirmResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgChannelCloseConfirmResponse) XXX_Merge ¶
func (m *MsgChannelCloseConfirmResponse) XXX_Merge(src proto.Message)
func (*MsgChannelCloseConfirmResponse) XXX_Size ¶
func (m *MsgChannelCloseConfirmResponse) XXX_Size() int
func (*MsgChannelCloseConfirmResponse) XXX_Unmarshal ¶
func (m *MsgChannelCloseConfirmResponse) XXX_Unmarshal(b []byte) error
type MsgChannelCloseInit ¶
type MsgChannelCloseInit struct { PortId string `protobuf:"bytes,1,opt,name=port_id,json=portId,proto3" json:"port_id,omitempty" yaml:"port_id"` ChannelId string `protobuf:"bytes,2,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty" yaml:"channel_id"` Signer string `protobuf:"bytes,3,opt,name=signer,proto3" json:"signer,omitempty"` }
MsgChannelCloseInit defines a msg sent by a Relayer to Chain A to close a channel with Chain B.
func NewMsgChannelCloseInit ¶
func NewMsgChannelCloseInit( portID string, channelID string, signer sdk.AccAddress, ) *MsgChannelCloseInit
NewMsgChannelCloseInit creates a new MsgChannelCloseInit instance nolint:interfacer
func (*MsgChannelCloseInit) Descriptor ¶
func (*MsgChannelCloseInit) Descriptor() ([]byte, []int)
func (MsgChannelCloseInit) GetSignBytes ¶
func (msg MsgChannelCloseInit) GetSignBytes() []byte
GetSignBytes implements sdk.Msg. The function will panic since it is used for amino transaction verification which ICP does not support.
func (MsgChannelCloseInit) GetSigners ¶
func (msg MsgChannelCloseInit) GetSigners() []sdk.AccAddress
GetSigners implements sdk.Msg
func (*MsgChannelCloseInit) Marshal ¶
func (m *MsgChannelCloseInit) Marshal() (dAtA []byte, err error)
func (*MsgChannelCloseInit) MarshalTo ¶
func (m *MsgChannelCloseInit) MarshalTo(dAtA []byte) (int, error)
func (*MsgChannelCloseInit) MarshalToSizedBuffer ¶
func (m *MsgChannelCloseInit) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgChannelCloseInit) ProtoMessage ¶
func (*MsgChannelCloseInit) ProtoMessage()
func (*MsgChannelCloseInit) Reset ¶
func (m *MsgChannelCloseInit) Reset()
func (MsgChannelCloseInit) Route ¶
func (msg MsgChannelCloseInit) Route() string
Route implements sdk.Msg
func (*MsgChannelCloseInit) Size ¶
func (m *MsgChannelCloseInit) Size() (n int)
func (*MsgChannelCloseInit) String ¶
func (m *MsgChannelCloseInit) String() string
func (MsgChannelCloseInit) Type ¶
func (msg MsgChannelCloseInit) Type() string
Type implements sdk.Msg
func (*MsgChannelCloseInit) Unmarshal ¶
func (m *MsgChannelCloseInit) Unmarshal(dAtA []byte) error
func (MsgChannelCloseInit) ValidateBasic ¶
func (msg MsgChannelCloseInit) ValidateBasic() error
ValidateBasic implements sdk.Msg
func (*MsgChannelCloseInit) XXX_DiscardUnknown ¶
func (m *MsgChannelCloseInit) XXX_DiscardUnknown()
func (*MsgChannelCloseInit) XXX_Marshal ¶
func (m *MsgChannelCloseInit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgChannelCloseInit) XXX_Merge ¶
func (m *MsgChannelCloseInit) XXX_Merge(src proto.Message)
func (*MsgChannelCloseInit) XXX_Size ¶
func (m *MsgChannelCloseInit) XXX_Size() int
func (*MsgChannelCloseInit) XXX_Unmarshal ¶
func (m *MsgChannelCloseInit) XXX_Unmarshal(b []byte) error
type MsgChannelCloseInitResponse ¶
type MsgChannelCloseInitResponse struct { }
MsgChannelCloseInitResponse defines the Msg/ChannelCloseInit response type.
func (*MsgChannelCloseInitResponse) Descriptor ¶
func (*MsgChannelCloseInitResponse) Descriptor() ([]byte, []int)
func (*MsgChannelCloseInitResponse) Marshal ¶
func (m *MsgChannelCloseInitResponse) Marshal() (dAtA []byte, err error)
func (*MsgChannelCloseInitResponse) MarshalTo ¶
func (m *MsgChannelCloseInitResponse) MarshalTo(dAtA []byte) (int, error)
func (*MsgChannelCloseInitResponse) MarshalToSizedBuffer ¶
func (m *MsgChannelCloseInitResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgChannelCloseInitResponse) ProtoMessage ¶
func (*MsgChannelCloseInitResponse) ProtoMessage()
func (*MsgChannelCloseInitResponse) Reset ¶
func (m *MsgChannelCloseInitResponse) Reset()
func (*MsgChannelCloseInitResponse) Size ¶
func (m *MsgChannelCloseInitResponse) Size() (n int)
func (*MsgChannelCloseInitResponse) String ¶
func (m *MsgChannelCloseInitResponse) String() string
func (*MsgChannelCloseInitResponse) Unmarshal ¶
func (m *MsgChannelCloseInitResponse) Unmarshal(dAtA []byte) error
func (*MsgChannelCloseInitResponse) XXX_DiscardUnknown ¶
func (m *MsgChannelCloseInitResponse) XXX_DiscardUnknown()
func (*MsgChannelCloseInitResponse) XXX_Marshal ¶
func (m *MsgChannelCloseInitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgChannelCloseInitResponse) XXX_Merge ¶
func (m *MsgChannelCloseInitResponse) XXX_Merge(src proto.Message)
func (*MsgChannelCloseInitResponse) XXX_Size ¶
func (m *MsgChannelCloseInitResponse) XXX_Size() int
func (*MsgChannelCloseInitResponse) XXX_Unmarshal ¶
func (m *MsgChannelCloseInitResponse) XXX_Unmarshal(b []byte) error
type MsgChannelOpenAck ¶
type MsgChannelOpenAck struct { PortId string `protobuf:"bytes,1,opt,name=port_id,json=portId,proto3" json:"port_id,omitempty" yaml:"port_id"` ChannelId string `protobuf:"bytes,2,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty" yaml:"channel_id"` CounterpartyChannelId string `` /* 157-byte string literal not displayed */ CounterpartyVersion string `` /* 146-byte string literal not displayed */ ProofTry []byte `protobuf:"bytes,5,opt,name=proof_try,json=proofTry,proto3" json:"proof_try,omitempty" yaml:"proof_try"` ProofHeight types.Height `protobuf:"bytes,6,opt,name=proof_height,json=proofHeight,proto3" json:"proof_height" yaml:"proof_height"` Signer string `protobuf:"bytes,7,opt,name=signer,proto3" json:"signer,omitempty"` }
MsgChannelOpenAck defines a msg sent by a Relayer to Chain A to acknowledge the change of channel state to TRYOPEN on Chain B.
func NewMsgChannelOpenAck ¶
func NewMsgChannelOpenAck( portID, channelID, counterpartyChannelID string, cpv string, proofTry []byte, proofHeight clienttypes.Height, signer sdk.AccAddress, ) *MsgChannelOpenAck
NewMsgChannelOpenAck creates a new MsgChannelOpenAck instance nolint:interfacer
func (*MsgChannelOpenAck) Descriptor ¶
func (*MsgChannelOpenAck) Descriptor() ([]byte, []int)
func (MsgChannelOpenAck) GetSignBytes ¶
func (msg MsgChannelOpenAck) GetSignBytes() []byte
GetSignBytes implements sdk.Msg. The function will panic since it is used for amino transaction verification which ICP does not support.
func (MsgChannelOpenAck) GetSigners ¶
func (msg MsgChannelOpenAck) GetSigners() []sdk.AccAddress
GetSigners implements sdk.Msg
func (*MsgChannelOpenAck) Marshal ¶
func (m *MsgChannelOpenAck) Marshal() (dAtA []byte, err error)
func (*MsgChannelOpenAck) MarshalTo ¶
func (m *MsgChannelOpenAck) MarshalTo(dAtA []byte) (int, error)
func (*MsgChannelOpenAck) MarshalToSizedBuffer ¶
func (m *MsgChannelOpenAck) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgChannelOpenAck) ProtoMessage ¶
func (*MsgChannelOpenAck) ProtoMessage()
func (*MsgChannelOpenAck) Reset ¶
func (m *MsgChannelOpenAck) Reset()
func (MsgChannelOpenAck) Route ¶
func (msg MsgChannelOpenAck) Route() string
Route implements sdk.Msg
func (*MsgChannelOpenAck) Size ¶
func (m *MsgChannelOpenAck) Size() (n int)
func (*MsgChannelOpenAck) String ¶
func (m *MsgChannelOpenAck) String() string
func (*MsgChannelOpenAck) Unmarshal ¶
func (m *MsgChannelOpenAck) Unmarshal(dAtA []byte) error
func (MsgChannelOpenAck) ValidateBasic ¶
func (msg MsgChannelOpenAck) ValidateBasic() error
ValidateBasic implements sdk.Msg
func (*MsgChannelOpenAck) XXX_DiscardUnknown ¶
func (m *MsgChannelOpenAck) XXX_DiscardUnknown()
func (*MsgChannelOpenAck) XXX_Marshal ¶
func (m *MsgChannelOpenAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgChannelOpenAck) XXX_Merge ¶
func (m *MsgChannelOpenAck) XXX_Merge(src proto.Message)
func (*MsgChannelOpenAck) XXX_Size ¶
func (m *MsgChannelOpenAck) XXX_Size() int
func (*MsgChannelOpenAck) XXX_Unmarshal ¶
func (m *MsgChannelOpenAck) XXX_Unmarshal(b []byte) error
type MsgChannelOpenAckResponse ¶
type MsgChannelOpenAckResponse struct { }
MsgChannelOpenAckResponse defines the Msg/ChannelOpenAck response type.
func (*MsgChannelOpenAckResponse) Descriptor ¶
func (*MsgChannelOpenAckResponse) Descriptor() ([]byte, []int)
func (*MsgChannelOpenAckResponse) Marshal ¶
func (m *MsgChannelOpenAckResponse) Marshal() (dAtA []byte, err error)
func (*MsgChannelOpenAckResponse) MarshalTo ¶
func (m *MsgChannelOpenAckResponse) MarshalTo(dAtA []byte) (int, error)
func (*MsgChannelOpenAckResponse) MarshalToSizedBuffer ¶
func (m *MsgChannelOpenAckResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgChannelOpenAckResponse) ProtoMessage ¶
func (*MsgChannelOpenAckResponse) ProtoMessage()
func (*MsgChannelOpenAckResponse) Reset ¶
func (m *MsgChannelOpenAckResponse) Reset()
func (*MsgChannelOpenAckResponse) Size ¶
func (m *MsgChannelOpenAckResponse) Size() (n int)
func (*MsgChannelOpenAckResponse) String ¶
func (m *MsgChannelOpenAckResponse) String() string
func (*MsgChannelOpenAckResponse) Unmarshal ¶
func (m *MsgChannelOpenAckResponse) Unmarshal(dAtA []byte) error
func (*MsgChannelOpenAckResponse) XXX_DiscardUnknown ¶
func (m *MsgChannelOpenAckResponse) XXX_DiscardUnknown()
func (*MsgChannelOpenAckResponse) XXX_Marshal ¶
func (m *MsgChannelOpenAckResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgChannelOpenAckResponse) XXX_Merge ¶
func (m *MsgChannelOpenAckResponse) XXX_Merge(src proto.Message)
func (*MsgChannelOpenAckResponse) XXX_Size ¶
func (m *MsgChannelOpenAckResponse) XXX_Size() int
func (*MsgChannelOpenAckResponse) XXX_Unmarshal ¶
func (m *MsgChannelOpenAckResponse) XXX_Unmarshal(b []byte) error
type MsgChannelOpenConfirm ¶
type MsgChannelOpenConfirm struct { PortId string `protobuf:"bytes,1,opt,name=port_id,json=portId,proto3" json:"port_id,omitempty" yaml:"port_id"` ChannelId string `protobuf:"bytes,2,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty" yaml:"channel_id"` ProofAck []byte `protobuf:"bytes,3,opt,name=proof_ack,json=proofAck,proto3" json:"proof_ack,omitempty" yaml:"proof_ack"` 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"` }
MsgChannelOpenConfirm defines a msg sent by a Relayer to Chain B to acknowledge the change of channel state to OPEN on Chain A.
func NewMsgChannelOpenConfirm ¶
func NewMsgChannelOpenConfirm( portID, channelID string, proofAck []byte, proofHeight clienttypes.Height, signer sdk.AccAddress, ) *MsgChannelOpenConfirm
NewMsgChannelOpenConfirm creates a new MsgChannelOpenConfirm instance nolint:interfacer
func (*MsgChannelOpenConfirm) Descriptor ¶
func (*MsgChannelOpenConfirm) Descriptor() ([]byte, []int)
func (MsgChannelOpenConfirm) GetSignBytes ¶
func (msg MsgChannelOpenConfirm) GetSignBytes() []byte
GetSignBytes implements sdk.Msg. The function will panic since it is used for amino transaction verification which ICP does not support.
func (MsgChannelOpenConfirm) GetSigners ¶
func (msg MsgChannelOpenConfirm) GetSigners() []sdk.AccAddress
GetSigners implements sdk.Msg
func (*MsgChannelOpenConfirm) Marshal ¶
func (m *MsgChannelOpenConfirm) Marshal() (dAtA []byte, err error)
func (*MsgChannelOpenConfirm) MarshalTo ¶
func (m *MsgChannelOpenConfirm) MarshalTo(dAtA []byte) (int, error)
func (*MsgChannelOpenConfirm) MarshalToSizedBuffer ¶
func (m *MsgChannelOpenConfirm) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgChannelOpenConfirm) ProtoMessage ¶
func (*MsgChannelOpenConfirm) ProtoMessage()
func (*MsgChannelOpenConfirm) Reset ¶
func (m *MsgChannelOpenConfirm) Reset()
func (MsgChannelOpenConfirm) Route ¶
func (msg MsgChannelOpenConfirm) Route() string
Route implements sdk.Msg
func (*MsgChannelOpenConfirm) Size ¶
func (m *MsgChannelOpenConfirm) Size() (n int)
func (*MsgChannelOpenConfirm) String ¶
func (m *MsgChannelOpenConfirm) String() string
func (MsgChannelOpenConfirm) Type ¶
func (msg MsgChannelOpenConfirm) Type() string
Type implements sdk.Msg
func (*MsgChannelOpenConfirm) Unmarshal ¶
func (m *MsgChannelOpenConfirm) Unmarshal(dAtA []byte) error
func (MsgChannelOpenConfirm) ValidateBasic ¶
func (msg MsgChannelOpenConfirm) ValidateBasic() error
ValidateBasic implements sdk.Msg
func (*MsgChannelOpenConfirm) XXX_DiscardUnknown ¶
func (m *MsgChannelOpenConfirm) XXX_DiscardUnknown()
func (*MsgChannelOpenConfirm) XXX_Marshal ¶
func (m *MsgChannelOpenConfirm) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgChannelOpenConfirm) XXX_Merge ¶
func (m *MsgChannelOpenConfirm) XXX_Merge(src proto.Message)
func (*MsgChannelOpenConfirm) XXX_Size ¶
func (m *MsgChannelOpenConfirm) XXX_Size() int
func (*MsgChannelOpenConfirm) XXX_Unmarshal ¶
func (m *MsgChannelOpenConfirm) XXX_Unmarshal(b []byte) error
type MsgChannelOpenConfirmResponse ¶
type MsgChannelOpenConfirmResponse struct { }
MsgChannelOpenConfirmResponse defines the Msg/ChannelOpenConfirm response type.
func (*MsgChannelOpenConfirmResponse) Descriptor ¶
func (*MsgChannelOpenConfirmResponse) Descriptor() ([]byte, []int)
func (*MsgChannelOpenConfirmResponse) Marshal ¶
func (m *MsgChannelOpenConfirmResponse) Marshal() (dAtA []byte, err error)
func (*MsgChannelOpenConfirmResponse) MarshalTo ¶
func (m *MsgChannelOpenConfirmResponse) MarshalTo(dAtA []byte) (int, error)
func (*MsgChannelOpenConfirmResponse) MarshalToSizedBuffer ¶
func (m *MsgChannelOpenConfirmResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgChannelOpenConfirmResponse) ProtoMessage ¶
func (*MsgChannelOpenConfirmResponse) ProtoMessage()
func (*MsgChannelOpenConfirmResponse) Reset ¶
func (m *MsgChannelOpenConfirmResponse) Reset()
func (*MsgChannelOpenConfirmResponse) Size ¶
func (m *MsgChannelOpenConfirmResponse) Size() (n int)
func (*MsgChannelOpenConfirmResponse) String ¶
func (m *MsgChannelOpenConfirmResponse) String() string
func (*MsgChannelOpenConfirmResponse) Unmarshal ¶
func (m *MsgChannelOpenConfirmResponse) Unmarshal(dAtA []byte) error
func (*MsgChannelOpenConfirmResponse) XXX_DiscardUnknown ¶
func (m *MsgChannelOpenConfirmResponse) XXX_DiscardUnknown()
func (*MsgChannelOpenConfirmResponse) XXX_Marshal ¶
func (m *MsgChannelOpenConfirmResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgChannelOpenConfirmResponse) XXX_Merge ¶
func (m *MsgChannelOpenConfirmResponse) XXX_Merge(src proto.Message)
func (*MsgChannelOpenConfirmResponse) XXX_Size ¶
func (m *MsgChannelOpenConfirmResponse) XXX_Size() int
func (*MsgChannelOpenConfirmResponse) XXX_Unmarshal ¶
func (m *MsgChannelOpenConfirmResponse) XXX_Unmarshal(b []byte) error
type MsgChannelOpenInit ¶
type MsgChannelOpenInit struct { PortId string `protobuf:"bytes,1,opt,name=port_id,json=portId,proto3" json:"port_id,omitempty" yaml:"port_id"` Channel Channel `protobuf:"bytes,2,opt,name=channel,proto3" json:"channel"` Signer string `protobuf:"bytes,3,opt,name=signer,proto3" json:"signer,omitempty"` }
MsgChannelOpenInit defines an sdk.Msg to initialize a channel handshake. It is called by a relayer on Chain A.
func NewMsgChannelOpenInit ¶
func NewMsgChannelOpenInit( portID, version string, channelOrder Order, connectionHops []string, counterpartyPortID string, signer sdk.AccAddress, ) *MsgChannelOpenInit
NewMsgChannelOpenInit creates a new MsgChannelOpenInit. It sets the counterparty channel identifier to be empty. nolint:interfacer
func (*MsgChannelOpenInit) Descriptor ¶
func (*MsgChannelOpenInit) Descriptor() ([]byte, []int)
func (MsgChannelOpenInit) GetSignBytes ¶
func (msg MsgChannelOpenInit) GetSignBytes() []byte
GetSignBytes implements sdk.Msg. The function will panic since it is used for amino transaction verification which ICP does not support.
func (MsgChannelOpenInit) GetSigners ¶
func (msg MsgChannelOpenInit) GetSigners() []sdk.AccAddress
GetSigners implements sdk.Msg
func (*MsgChannelOpenInit) Marshal ¶
func (m *MsgChannelOpenInit) Marshal() (dAtA []byte, err error)
func (*MsgChannelOpenInit) MarshalTo ¶
func (m *MsgChannelOpenInit) MarshalTo(dAtA []byte) (int, error)
func (*MsgChannelOpenInit) MarshalToSizedBuffer ¶
func (m *MsgChannelOpenInit) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgChannelOpenInit) ProtoMessage ¶
func (*MsgChannelOpenInit) ProtoMessage()
func (*MsgChannelOpenInit) Reset ¶
func (m *MsgChannelOpenInit) Reset()
func (MsgChannelOpenInit) Route ¶
func (msg MsgChannelOpenInit) Route() string
Route implements sdk.Msg
func (*MsgChannelOpenInit) Size ¶
func (m *MsgChannelOpenInit) Size() (n int)
func (*MsgChannelOpenInit) String ¶
func (m *MsgChannelOpenInit) String() string
func (MsgChannelOpenInit) Type ¶
func (msg MsgChannelOpenInit) Type() string
Type implements sdk.Msg
func (*MsgChannelOpenInit) Unmarshal ¶
func (m *MsgChannelOpenInit) Unmarshal(dAtA []byte) error
func (MsgChannelOpenInit) ValidateBasic ¶
func (msg MsgChannelOpenInit) ValidateBasic() error
ValidateBasic implements sdk.Msg
func (*MsgChannelOpenInit) XXX_DiscardUnknown ¶
func (m *MsgChannelOpenInit) XXX_DiscardUnknown()
func (*MsgChannelOpenInit) XXX_Marshal ¶
func (m *MsgChannelOpenInit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgChannelOpenInit) XXX_Merge ¶
func (m *MsgChannelOpenInit) XXX_Merge(src proto.Message)
func (*MsgChannelOpenInit) XXX_Size ¶
func (m *MsgChannelOpenInit) XXX_Size() int
func (*MsgChannelOpenInit) XXX_Unmarshal ¶
func (m *MsgChannelOpenInit) XXX_Unmarshal(b []byte) error
type MsgChannelOpenInitResponse ¶
type MsgChannelOpenInitResponse struct { }
MsgChannelOpenInitResponse defines the Msg/ChannelOpenInit response type.
func (*MsgChannelOpenInitResponse) Descriptor ¶
func (*MsgChannelOpenInitResponse) Descriptor() ([]byte, []int)
func (*MsgChannelOpenInitResponse) Marshal ¶
func (m *MsgChannelOpenInitResponse) Marshal() (dAtA []byte, err error)
func (*MsgChannelOpenInitResponse) MarshalTo ¶
func (m *MsgChannelOpenInitResponse) MarshalTo(dAtA []byte) (int, error)
func (*MsgChannelOpenInitResponse) MarshalToSizedBuffer ¶
func (m *MsgChannelOpenInitResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgChannelOpenInitResponse) ProtoMessage ¶
func (*MsgChannelOpenInitResponse) ProtoMessage()
func (*MsgChannelOpenInitResponse) Reset ¶
func (m *MsgChannelOpenInitResponse) Reset()
func (*MsgChannelOpenInitResponse) Size ¶
func (m *MsgChannelOpenInitResponse) Size() (n int)
func (*MsgChannelOpenInitResponse) String ¶
func (m *MsgChannelOpenInitResponse) String() string
func (*MsgChannelOpenInitResponse) Unmarshal ¶
func (m *MsgChannelOpenInitResponse) Unmarshal(dAtA []byte) error
func (*MsgChannelOpenInitResponse) XXX_DiscardUnknown ¶
func (m *MsgChannelOpenInitResponse) XXX_DiscardUnknown()
func (*MsgChannelOpenInitResponse) XXX_Marshal ¶
func (m *MsgChannelOpenInitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgChannelOpenInitResponse) XXX_Merge ¶
func (m *MsgChannelOpenInitResponse) XXX_Merge(src proto.Message)
func (*MsgChannelOpenInitResponse) XXX_Size ¶
func (m *MsgChannelOpenInitResponse) XXX_Size() int
func (*MsgChannelOpenInitResponse) XXX_Unmarshal ¶
func (m *MsgChannelOpenInitResponse) XXX_Unmarshal(b []byte) error
type MsgChannelOpenTry ¶
type MsgChannelOpenTry struct { PortId string `protobuf:"bytes,1,opt,name=port_id,json=portId,proto3" json:"port_id,omitempty" yaml:"port_id"` // in the case of crossing hello's, when both chains call OpenInit, we need the channel identifier // of the previous channel in state INIT PreviousChannelId string `` /* 141-byte string literal not displayed */ Channel Channel `protobuf:"bytes,3,opt,name=channel,proto3" json:"channel"` CounterpartyVersion string `` /* 146-byte string literal not displayed */ ProofInit []byte `protobuf:"bytes,5,opt,name=proof_init,json=proofInit,proto3" json:"proof_init,omitempty" yaml:"proof_init"` ProofHeight types.Height `protobuf:"bytes,6,opt,name=proof_height,json=proofHeight,proto3" json:"proof_height" yaml:"proof_height"` Signer string `protobuf:"bytes,7,opt,name=signer,proto3" json:"signer,omitempty"` }
MsgChannelOpenInit defines a msg sent by a Relayer to try to open a channel on Chain B.
func NewMsgChannelOpenTry ¶
func NewMsgChannelOpenTry( portID, previousChannelID, version string, channelOrder Order, connectionHops []string, counterpartyPortID, counterpartyChannelID, counterpartyVersion string, proofInit []byte, proofHeight clienttypes.Height, signer sdk.AccAddress, ) *MsgChannelOpenTry
NewMsgChannelOpenTry creates a new MsgChannelOpenTry instance nolint:interfacer
func (*MsgChannelOpenTry) Descriptor ¶
func (*MsgChannelOpenTry) Descriptor() ([]byte, []int)
func (MsgChannelOpenTry) GetSignBytes ¶
func (msg MsgChannelOpenTry) GetSignBytes() []byte
GetSignBytes implements sdk.Msg. The function will panic since it is used for amino transaction verification which ICP does not support.
func (MsgChannelOpenTry) GetSigners ¶
func (msg MsgChannelOpenTry) GetSigners() []sdk.AccAddress
GetSigners implements sdk.Msg
func (*MsgChannelOpenTry) Marshal ¶
func (m *MsgChannelOpenTry) Marshal() (dAtA []byte, err error)
func (*MsgChannelOpenTry) MarshalTo ¶
func (m *MsgChannelOpenTry) MarshalTo(dAtA []byte) (int, error)
func (*MsgChannelOpenTry) MarshalToSizedBuffer ¶
func (m *MsgChannelOpenTry) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgChannelOpenTry) ProtoMessage ¶
func (*MsgChannelOpenTry) ProtoMessage()
func (*MsgChannelOpenTry) Reset ¶
func (m *MsgChannelOpenTry) Reset()
func (MsgChannelOpenTry) Route ¶
func (msg MsgChannelOpenTry) Route() string
Route implements sdk.Msg
func (*MsgChannelOpenTry) Size ¶
func (m *MsgChannelOpenTry) Size() (n int)
func (*MsgChannelOpenTry) String ¶
func (m *MsgChannelOpenTry) String() string
func (*MsgChannelOpenTry) Unmarshal ¶
func (m *MsgChannelOpenTry) Unmarshal(dAtA []byte) error
func (MsgChannelOpenTry) ValidateBasic ¶
func (msg MsgChannelOpenTry) ValidateBasic() error
ValidateBasic implements sdk.Msg
func (*MsgChannelOpenTry) XXX_DiscardUnknown ¶
func (m *MsgChannelOpenTry) XXX_DiscardUnknown()
func (*MsgChannelOpenTry) XXX_Marshal ¶
func (m *MsgChannelOpenTry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgChannelOpenTry) XXX_Merge ¶
func (m *MsgChannelOpenTry) XXX_Merge(src proto.Message)
func (*MsgChannelOpenTry) XXX_Size ¶
func (m *MsgChannelOpenTry) XXX_Size() int
func (*MsgChannelOpenTry) XXX_Unmarshal ¶
func (m *MsgChannelOpenTry) XXX_Unmarshal(b []byte) error
type MsgChannelOpenTryResponse ¶
type MsgChannelOpenTryResponse struct { }
MsgChannelOpenTryResponse defines the Msg/ChannelOpenTry response type.
func (*MsgChannelOpenTryResponse) Descriptor ¶
func (*MsgChannelOpenTryResponse) Descriptor() ([]byte, []int)
func (*MsgChannelOpenTryResponse) Marshal ¶
func (m *MsgChannelOpenTryResponse) Marshal() (dAtA []byte, err error)
func (*MsgChannelOpenTryResponse) MarshalTo ¶
func (m *MsgChannelOpenTryResponse) MarshalTo(dAtA []byte) (int, error)
func (*MsgChannelOpenTryResponse) MarshalToSizedBuffer ¶
func (m *MsgChannelOpenTryResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgChannelOpenTryResponse) ProtoMessage ¶
func (*MsgChannelOpenTryResponse) ProtoMessage()
func (*MsgChannelOpenTryResponse) Reset ¶
func (m *MsgChannelOpenTryResponse) Reset()
func (*MsgChannelOpenTryResponse) Size ¶
func (m *MsgChannelOpenTryResponse) Size() (n int)
func (*MsgChannelOpenTryResponse) String ¶
func (m *MsgChannelOpenTryResponse) String() string
func (*MsgChannelOpenTryResponse) Unmarshal ¶
func (m *MsgChannelOpenTryResponse) Unmarshal(dAtA []byte) error
func (*MsgChannelOpenTryResponse) XXX_DiscardUnknown ¶
func (m *MsgChannelOpenTryResponse) XXX_DiscardUnknown()
func (*MsgChannelOpenTryResponse) XXX_Marshal ¶
func (m *MsgChannelOpenTryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgChannelOpenTryResponse) XXX_Merge ¶
func (m *MsgChannelOpenTryResponse) XXX_Merge(src proto.Message)
func (*MsgChannelOpenTryResponse) XXX_Size ¶
func (m *MsgChannelOpenTryResponse) XXX_Size() int
func (*MsgChannelOpenTryResponse) XXX_Unmarshal ¶
func (m *MsgChannelOpenTryResponse) XXX_Unmarshal(b []byte) error
type MsgClient ¶
type MsgClient interface { // ChannelOpenInit defines a rpc handler method for MsgChannelOpenInit. ChannelOpenInit(ctx context.Context, in *MsgChannelOpenInit, opts ...grpc.CallOption) (*MsgChannelOpenInitResponse, error) // ChannelOpenTry defines a rpc handler method for MsgChannelOpenTry. ChannelOpenTry(ctx context.Context, in *MsgChannelOpenTry, opts ...grpc.CallOption) (*MsgChannelOpenTryResponse, error) // ChannelOpenAck defines a rpc handler method for MsgChannelOpenAck. ChannelOpenAck(ctx context.Context, in *MsgChannelOpenAck, opts ...grpc.CallOption) (*MsgChannelOpenAckResponse, error) // ChannelOpenConfirm defines a rpc handler method for MsgChannelOpenConfirm. ChannelOpenConfirm(ctx context.Context, in *MsgChannelOpenConfirm, opts ...grpc.CallOption) (*MsgChannelOpenConfirmResponse, error) // ChannelCloseInit defines a rpc handler method for MsgChannelCloseInit. ChannelCloseInit(ctx context.Context, in *MsgChannelCloseInit, opts ...grpc.CallOption) (*MsgChannelCloseInitResponse, error) // ChannelCloseConfirm defines a rpc handler method for MsgChannelCloseConfirm. ChannelCloseConfirm(ctx context.Context, in *MsgChannelCloseConfirm, opts ...grpc.CallOption) (*MsgChannelCloseConfirmResponse, error) // RecvPacket defines a rpc handler method for MsgRecvPacket. RecvPacket(ctx context.Context, in *MsgRecvPacket, opts ...grpc.CallOption) (*MsgRecvPacketResponse, error) // Timeout defines a rpc handler method for MsgTimeout. Timeout(ctx context.Context, in *MsgTimeout, opts ...grpc.CallOption) (*MsgTimeoutResponse, error) // TimeoutOnClose defines a rpc handler method for MsgTimeoutOnClose. TimeoutOnClose(ctx context.Context, in *MsgTimeoutOnClose, opts ...grpc.CallOption) (*MsgTimeoutOnCloseResponse, error) // Acknowledgement defines a rpc handler method for MsgAcknowledgement. Acknowledgement(ctx context.Context, in *MsgAcknowledgement, opts ...grpc.CallOption) (*MsgAcknowledgementResponse, 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 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 ICP packet
func NewMsgRecvPacket ¶
func NewMsgRecvPacket( packet Packet, proofCommitment []byte, proofHeight clienttypes.Height, signer sdk.AccAddress, ) *MsgRecvPacket
NewMsgRecvPacket constructs new MsgRecvPacket nolint:interfacer
func (*MsgRecvPacket) Descriptor ¶
func (*MsgRecvPacket) Descriptor() ([]byte, []int)
func (MsgRecvPacket) GetDataSignBytes ¶
func (msg MsgRecvPacket) GetDataSignBytes() []byte
GetDataSignBytes returns the base64-encoded bytes used for the data field when signing the packet.
func (MsgRecvPacket) GetSignBytes ¶
func (msg MsgRecvPacket) GetSignBytes() []byte
GetSignBytes implements sdk.Msg. The function will panic since it is used for amino transaction verification which ICP does not support.
func (MsgRecvPacket) GetSigners ¶
func (msg MsgRecvPacket) GetSigners() []sdk.AccAddress
GetSigners implements sdk.Msg
func (*MsgRecvPacket) Marshal ¶
func (m *MsgRecvPacket) Marshal() (dAtA []byte, err error)
func (*MsgRecvPacket) MarshalToSizedBuffer ¶
func (m *MsgRecvPacket) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgRecvPacket) ProtoMessage ¶
func (*MsgRecvPacket) ProtoMessage()
func (*MsgRecvPacket) Reset ¶
func (m *MsgRecvPacket) Reset()
func (*MsgRecvPacket) Size ¶
func (m *MsgRecvPacket) Size() (n int)
func (*MsgRecvPacket) String ¶
func (m *MsgRecvPacket) String() string
func (*MsgRecvPacket) Unmarshal ¶
func (m *MsgRecvPacket) Unmarshal(dAtA []byte) error
func (MsgRecvPacket) ValidateBasic ¶
func (msg MsgRecvPacket) ValidateBasic() error
ValidateBasic implements sdk.Msg
func (*MsgRecvPacket) XXX_DiscardUnknown ¶
func (m *MsgRecvPacket) XXX_DiscardUnknown()
func (*MsgRecvPacket) XXX_Marshal ¶
func (m *MsgRecvPacket) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgRecvPacket) XXX_Merge ¶
func (m *MsgRecvPacket) XXX_Merge(src proto.Message)
func (*MsgRecvPacket) XXX_Size ¶
func (m *MsgRecvPacket) XXX_Size() int
func (*MsgRecvPacket) XXX_Unmarshal ¶
func (m *MsgRecvPacket) XXX_Unmarshal(b []byte) error
type MsgRecvPacketResponse ¶
type MsgRecvPacketResponse struct { }
MsgRecvPacketResponse defines the Msg/RecvPacket response type.
func (*MsgRecvPacketResponse) Descriptor ¶
func (*MsgRecvPacketResponse) Descriptor() ([]byte, []int)
func (*MsgRecvPacketResponse) Marshal ¶
func (m *MsgRecvPacketResponse) Marshal() (dAtA []byte, err error)
func (*MsgRecvPacketResponse) MarshalTo ¶
func (m *MsgRecvPacketResponse) MarshalTo(dAtA []byte) (int, error)
func (*MsgRecvPacketResponse) MarshalToSizedBuffer ¶
func (m *MsgRecvPacketResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgRecvPacketResponse) ProtoMessage ¶
func (*MsgRecvPacketResponse) ProtoMessage()
func (*MsgRecvPacketResponse) Reset ¶
func (m *MsgRecvPacketResponse) Reset()
func (*MsgRecvPacketResponse) Size ¶
func (m *MsgRecvPacketResponse) Size() (n int)
func (*MsgRecvPacketResponse) String ¶
func (m *MsgRecvPacketResponse) String() string
func (*MsgRecvPacketResponse) Unmarshal ¶
func (m *MsgRecvPacketResponse) Unmarshal(dAtA []byte) error
func (*MsgRecvPacketResponse) XXX_DiscardUnknown ¶
func (m *MsgRecvPacketResponse) XXX_DiscardUnknown()
func (*MsgRecvPacketResponse) XXX_Marshal ¶
func (m *MsgRecvPacketResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgRecvPacketResponse) XXX_Merge ¶
func (m *MsgRecvPacketResponse) XXX_Merge(src proto.Message)
func (*MsgRecvPacketResponse) XXX_Size ¶
func (m *MsgRecvPacketResponse) XXX_Size() int
func (*MsgRecvPacketResponse) XXX_Unmarshal ¶
func (m *MsgRecvPacketResponse) XXX_Unmarshal(b []byte) error
type MsgServer ¶
type MsgServer interface { // ChannelOpenInit defines a rpc handler method for MsgChannelOpenInit. ChannelOpenInit(context.Context, *MsgChannelOpenInit) (*MsgChannelOpenInitResponse, error) // ChannelOpenTry defines a rpc handler method for MsgChannelOpenTry. ChannelOpenTry(context.Context, *MsgChannelOpenTry) (*MsgChannelOpenTryResponse, error) // ChannelOpenAck defines a rpc handler method for MsgChannelOpenAck. ChannelOpenAck(context.Context, *MsgChannelOpenAck) (*MsgChannelOpenAckResponse, error) // ChannelOpenConfirm defines a rpc handler method for MsgChannelOpenConfirm. ChannelOpenConfirm(context.Context, *MsgChannelOpenConfirm) (*MsgChannelOpenConfirmResponse, error) // ChannelCloseInit defines a rpc handler method for MsgChannelCloseInit. ChannelCloseInit(context.Context, *MsgChannelCloseInit) (*MsgChannelCloseInitResponse, error) // ChannelCloseConfirm defines a rpc handler method for MsgChannelCloseConfirm. ChannelCloseConfirm(context.Context, *MsgChannelCloseConfirm) (*MsgChannelCloseConfirmResponse, error) // RecvPacket defines a rpc handler method for MsgRecvPacket. RecvPacket(context.Context, *MsgRecvPacket) (*MsgRecvPacketResponse, error) // Timeout defines a rpc handler method for MsgTimeout. Timeout(context.Context, *MsgTimeout) (*MsgTimeoutResponse, error) // TimeoutOnClose defines a rpc handler method for MsgTimeoutOnClose. TimeoutOnClose(context.Context, *MsgTimeoutOnClose) (*MsgTimeoutOnCloseResponse, error) // Acknowledgement defines a rpc handler method for MsgAcknowledgement. Acknowledgement(context.Context, *MsgAcknowledgement) (*MsgAcknowledgementResponse, error) }
MsgServer is the server API for Msg service.
type MsgTimeout ¶
type MsgTimeout struct { Packet Packet `protobuf:"bytes,1,opt,name=packet,proto3" json:"packet"` ProofUnreceived []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"` NextSequenceRecv uint64 `` /* 138-byte string literal not displayed */ Signer string `protobuf:"bytes,5,opt,name=signer,proto3" json:"signer,omitempty"` }
MsgTimeout receives timed-out packet
func NewMsgTimeout ¶
func NewMsgTimeout( packet Packet, nextSequenceRecv uint64, proofUnreceived []byte, proofHeight clienttypes.Height, signer sdk.AccAddress, ) *MsgTimeout
NewMsgTimeout constructs new MsgTimeout nolint:interfacer
func (*MsgTimeout) Descriptor ¶
func (*MsgTimeout) Descriptor() ([]byte, []int)
func (MsgTimeout) GetSignBytes ¶
func (msg MsgTimeout) GetSignBytes() []byte
GetSignBytes implements sdk.Msg. The function will panic since it is used for amino transaction verification which ICP does not support.
func (MsgTimeout) GetSigners ¶
func (msg MsgTimeout) GetSigners() []sdk.AccAddress
GetSigners implements sdk.Msg
func (*MsgTimeout) Marshal ¶
func (m *MsgTimeout) Marshal() (dAtA []byte, err error)
func (*MsgTimeout) MarshalToSizedBuffer ¶
func (m *MsgTimeout) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgTimeout) ProtoMessage ¶
func (*MsgTimeout) ProtoMessage()
func (*MsgTimeout) Reset ¶
func (m *MsgTimeout) Reset()
func (*MsgTimeout) Size ¶
func (m *MsgTimeout) Size() (n int)
func (*MsgTimeout) String ¶
func (m *MsgTimeout) String() string
func (*MsgTimeout) Unmarshal ¶
func (m *MsgTimeout) Unmarshal(dAtA []byte) error
func (MsgTimeout) ValidateBasic ¶
func (msg MsgTimeout) ValidateBasic() error
ValidateBasic implements sdk.Msg
func (*MsgTimeout) XXX_DiscardUnknown ¶
func (m *MsgTimeout) XXX_DiscardUnknown()
func (*MsgTimeout) XXX_Marshal ¶
func (m *MsgTimeout) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgTimeout) XXX_Merge ¶
func (m *MsgTimeout) XXX_Merge(src proto.Message)
func (*MsgTimeout) XXX_Size ¶
func (m *MsgTimeout) XXX_Size() int
func (*MsgTimeout) XXX_Unmarshal ¶
func (m *MsgTimeout) XXX_Unmarshal(b []byte) error
type MsgTimeoutOnClose ¶
type MsgTimeoutOnClose struct { Packet Packet `protobuf:"bytes,1,opt,name=packet,proto3" json:"packet"` ProofUnreceived []byte `` /* 130-byte string literal not displayed */ ProofClose []byte `protobuf:"bytes,3,opt,name=proof_close,json=proofClose,proto3" json:"proof_close,omitempty" yaml:"proof_close"` ProofHeight types.Height `protobuf:"bytes,4,opt,name=proof_height,json=proofHeight,proto3" json:"proof_height" yaml:"proof_height"` NextSequenceRecv uint64 `` /* 138-byte string literal not displayed */ Signer string `protobuf:"bytes,6,opt,name=signer,proto3" json:"signer,omitempty"` }
MsgTimeoutOnClose timed-out packet upon counterparty channel closure.
func NewMsgTimeoutOnClose ¶
func NewMsgTimeoutOnClose( packet Packet, nextSequenceRecv uint64, proofUnreceived, proofClose []byte, proofHeight clienttypes.Height, signer sdk.AccAddress, ) *MsgTimeoutOnClose
NewMsgTimeoutOnClose constructs new MsgTimeoutOnClose nolint:interfacer
func (*MsgTimeoutOnClose) Descriptor ¶
func (*MsgTimeoutOnClose) Descriptor() ([]byte, []int)
func (MsgTimeoutOnClose) GetSignBytes ¶
func (msg MsgTimeoutOnClose) GetSignBytes() []byte
GetSignBytes implements sdk.Msg. The function will panic since it is used for amino transaction verification which ICP does not support.
func (MsgTimeoutOnClose) GetSigners ¶
func (msg MsgTimeoutOnClose) GetSigners() []sdk.AccAddress
GetSigners implements sdk.Msg
func (*MsgTimeoutOnClose) Marshal ¶
func (m *MsgTimeoutOnClose) Marshal() (dAtA []byte, err error)
func (*MsgTimeoutOnClose) MarshalTo ¶
func (m *MsgTimeoutOnClose) MarshalTo(dAtA []byte) (int, error)
func (*MsgTimeoutOnClose) MarshalToSizedBuffer ¶
func (m *MsgTimeoutOnClose) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgTimeoutOnClose) ProtoMessage ¶
func (*MsgTimeoutOnClose) ProtoMessage()
func (*MsgTimeoutOnClose) Reset ¶
func (m *MsgTimeoutOnClose) Reset()
func (MsgTimeoutOnClose) Route ¶
func (msg MsgTimeoutOnClose) Route() string
Route implements sdk.Msg
func (*MsgTimeoutOnClose) Size ¶
func (m *MsgTimeoutOnClose) Size() (n int)
func (*MsgTimeoutOnClose) String ¶
func (m *MsgTimeoutOnClose) String() string
func (*MsgTimeoutOnClose) Unmarshal ¶
func (m *MsgTimeoutOnClose) Unmarshal(dAtA []byte) error
func (MsgTimeoutOnClose) ValidateBasic ¶
func (msg MsgTimeoutOnClose) ValidateBasic() error
ValidateBasic implements sdk.Msg
func (*MsgTimeoutOnClose) XXX_DiscardUnknown ¶
func (m *MsgTimeoutOnClose) XXX_DiscardUnknown()
func (*MsgTimeoutOnClose) XXX_Marshal ¶
func (m *MsgTimeoutOnClose) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgTimeoutOnClose) XXX_Merge ¶
func (m *MsgTimeoutOnClose) XXX_Merge(src proto.Message)
func (*MsgTimeoutOnClose) XXX_Size ¶
func (m *MsgTimeoutOnClose) XXX_Size() int
func (*MsgTimeoutOnClose) XXX_Unmarshal ¶
func (m *MsgTimeoutOnClose) XXX_Unmarshal(b []byte) error
type MsgTimeoutOnCloseResponse ¶
type MsgTimeoutOnCloseResponse struct { }
MsgTimeoutOnCloseResponse defines the Msg/TimeoutOnClose response type.
func (*MsgTimeoutOnCloseResponse) Descriptor ¶
func (*MsgTimeoutOnCloseResponse) Descriptor() ([]byte, []int)
func (*MsgTimeoutOnCloseResponse) Marshal ¶
func (m *MsgTimeoutOnCloseResponse) Marshal() (dAtA []byte, err error)
func (*MsgTimeoutOnCloseResponse) MarshalTo ¶
func (m *MsgTimeoutOnCloseResponse) MarshalTo(dAtA []byte) (int, error)
func (*MsgTimeoutOnCloseResponse) MarshalToSizedBuffer ¶
func (m *MsgTimeoutOnCloseResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgTimeoutOnCloseResponse) ProtoMessage ¶
func (*MsgTimeoutOnCloseResponse) ProtoMessage()
func (*MsgTimeoutOnCloseResponse) Reset ¶
func (m *MsgTimeoutOnCloseResponse) Reset()
func (*MsgTimeoutOnCloseResponse) Size ¶
func (m *MsgTimeoutOnCloseResponse) Size() (n int)
func (*MsgTimeoutOnCloseResponse) String ¶
func (m *MsgTimeoutOnCloseResponse) String() string
func (*MsgTimeoutOnCloseResponse) Unmarshal ¶
func (m *MsgTimeoutOnCloseResponse) Unmarshal(dAtA []byte) error
func (*MsgTimeoutOnCloseResponse) XXX_DiscardUnknown ¶
func (m *MsgTimeoutOnCloseResponse) XXX_DiscardUnknown()
func (*MsgTimeoutOnCloseResponse) XXX_Marshal ¶
func (m *MsgTimeoutOnCloseResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgTimeoutOnCloseResponse) XXX_Merge ¶
func (m *MsgTimeoutOnCloseResponse) XXX_Merge(src proto.Message)
func (*MsgTimeoutOnCloseResponse) XXX_Size ¶
func (m *MsgTimeoutOnCloseResponse) XXX_Size() int
func (*MsgTimeoutOnCloseResponse) XXX_Unmarshal ¶
func (m *MsgTimeoutOnCloseResponse) XXX_Unmarshal(b []byte) error
type MsgTimeoutResponse ¶
type MsgTimeoutResponse struct { }
MsgTimeoutResponse defines the Msg/Timeout response type.
func (*MsgTimeoutResponse) Descriptor ¶
func (*MsgTimeoutResponse) Descriptor() ([]byte, []int)
func (*MsgTimeoutResponse) Marshal ¶
func (m *MsgTimeoutResponse) Marshal() (dAtA []byte, err error)
func (*MsgTimeoutResponse) MarshalTo ¶
func (m *MsgTimeoutResponse) MarshalTo(dAtA []byte) (int, error)
func (*MsgTimeoutResponse) MarshalToSizedBuffer ¶
func (m *MsgTimeoutResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgTimeoutResponse) ProtoMessage ¶
func (*MsgTimeoutResponse) ProtoMessage()
func (*MsgTimeoutResponse) Reset ¶
func (m *MsgTimeoutResponse) Reset()
func (*MsgTimeoutResponse) Size ¶
func (m *MsgTimeoutResponse) Size() (n int)
func (*MsgTimeoutResponse) String ¶
func (m *MsgTimeoutResponse) String() string
func (*MsgTimeoutResponse) Unmarshal ¶
func (m *MsgTimeoutResponse) Unmarshal(dAtA []byte) error
func (*MsgTimeoutResponse) XXX_DiscardUnknown ¶
func (m *MsgTimeoutResponse) XXX_DiscardUnknown()
func (*MsgTimeoutResponse) XXX_Marshal ¶
func (m *MsgTimeoutResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgTimeoutResponse) XXX_Merge ¶
func (m *MsgTimeoutResponse) XXX_Merge(src proto.Message)
func (*MsgTimeoutResponse) XXX_Size ¶
func (m *MsgTimeoutResponse) XXX_Size() int
func (*MsgTimeoutResponse) XXX_Unmarshal ¶
func (m *MsgTimeoutResponse) XXX_Unmarshal(b []byte) error
type Order ¶
type Order int32
Order defines if a channel is ORDERED or UNORDERED
func (Order) EnumDescriptor ¶
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. SourcePort string `protobuf:"bytes,2,opt,name=source_port,json=sourcePort,proto3" json:"source_port,omitempty" yaml:"source_port"` // identifies the channel end on the sending chain. SourceChannel string `protobuf:"bytes,3,opt,name=source_channel,json=sourceChannel,proto3" json:"source_channel,omitempty" yaml:"source_channel"` // identifies the port on the receiving chain. DestinationPort string `` /* 130-byte string literal not displayed */ // identifies the channel end on the receiving chain. DestinationChannel string `` /* 142-byte string literal not displayed */ // actual opaque bytes transferred directly to the application module Data []byte `protobuf:"bytes,6,opt,name=data,proto3" json:"data,omitempty"` // block height after which the packet times out TimeoutHeight types.Height `protobuf:"bytes,7,opt,name=timeout_height,json=timeoutHeight,proto3" json:"timeout_height" yaml:"timeout_height"` // block timestamp (in nanoseconds) after which the packet times out TimeoutTimestamp uint64 `` /* 135-byte string literal not displayed */ }
Packet defines a type that carries data across different chains through ICP
func NewPacket ¶
func NewPacket( data []byte, sequence uint64, sourcePort, sourceChannel, destinationPort, destinationChannel string, timeoutHeight clienttypes.Height, timeoutTimestamp uint64, ) Packet
NewPacket creates a new Packet instance. It panics if the provided packet data interface is not registered.
func (*Packet) Descriptor ¶
func (Packet) GetDestChannel ¶
GetDestChannel implements PacketI interface
func (Packet) GetDestPort ¶
GetDestPort implements PacketI interface
func (Packet) GetSequence ¶
GetSequence implements PacketI interface
func (Packet) GetSourceChannel ¶
GetSourceChannel implements PacketI interface
func (Packet) GetSourcePort ¶
GetSourcePort implements PacketI interface
func (Packet) GetTimeoutHeight ¶
GetTimeoutHeight implements PacketI interface
func (Packet) GetTimeoutTimestamp ¶
GetTimeoutTimestamp 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 { PortId string `protobuf:"bytes,1,opt,name=port_id,json=portId,proto3" json:"port_id,omitempty" yaml:"port_id"` ChannelId string `protobuf:"bytes,2,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty" yaml:"channel_id"` 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(portID, channelID string, seq uint64) PacketSequence
NewPacketSequence creates a new PacketSequences instance.
func (*PacketSequence) Descriptor ¶
func (*PacketSequence) Descriptor() ([]byte, []int)
func (*PacketSequence) GetChannelId ¶
func (m *PacketSequence) GetChannelId() string
func (*PacketSequence) GetPortId ¶
func (m *PacketSequence) GetPortId() string
func (*PacketSequence) GetSequence ¶
func (m *PacketSequence) GetSequence() uint64
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 { // channel port identifier. PortId string `protobuf:"bytes,1,opt,name=port_id,json=portId,proto3" json:"port_id,omitempty" yaml:"port_id"` // channel unique identifier. ChannelId string `protobuf:"bytes,2,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty" yaml:"channel_id"` // 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(portID, channelID 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 PortKeeper ¶
type PortKeeper interface {
Authenticate(ctx sdk.Context, key *capabilitytypes.Capability, portID string) bool
}
PortKeeper expected account ICP port keeper
type QueryChannelClientStateRequest ¶
type QueryChannelClientStateRequest struct { // port unique identifier PortId string `protobuf:"bytes,1,opt,name=port_id,json=portId,proto3" json:"port_id,omitempty"` // channel unique identifier ChannelId string `protobuf:"bytes,2,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"` }
QueryChannelClientStateRequest is the request type for the Query/ClientState RPC method
func (*QueryChannelClientStateRequest) Descriptor ¶
func (*QueryChannelClientStateRequest) Descriptor() ([]byte, []int)
func (*QueryChannelClientStateRequest) GetChannelId ¶
func (m *QueryChannelClientStateRequest) GetChannelId() string
func (*QueryChannelClientStateRequest) GetPortId ¶
func (m *QueryChannelClientStateRequest) GetPortId() string
func (*QueryChannelClientStateRequest) Marshal ¶
func (m *QueryChannelClientStateRequest) Marshal() (dAtA []byte, err error)
func (*QueryChannelClientStateRequest) MarshalTo ¶
func (m *QueryChannelClientStateRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryChannelClientStateRequest) MarshalToSizedBuffer ¶
func (m *QueryChannelClientStateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryChannelClientStateRequest) ProtoMessage ¶
func (*QueryChannelClientStateRequest) ProtoMessage()
func (*QueryChannelClientStateRequest) Reset ¶
func (m *QueryChannelClientStateRequest) Reset()
func (*QueryChannelClientStateRequest) Size ¶
func (m *QueryChannelClientStateRequest) Size() (n int)
func (*QueryChannelClientStateRequest) String ¶
func (m *QueryChannelClientStateRequest) String() string
func (*QueryChannelClientStateRequest) Unmarshal ¶
func (m *QueryChannelClientStateRequest) Unmarshal(dAtA []byte) error
func (*QueryChannelClientStateRequest) XXX_DiscardUnknown ¶
func (m *QueryChannelClientStateRequest) XXX_DiscardUnknown()
func (*QueryChannelClientStateRequest) XXX_Marshal ¶
func (m *QueryChannelClientStateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryChannelClientStateRequest) XXX_Merge ¶
func (m *QueryChannelClientStateRequest) XXX_Merge(src proto.Message)
func (*QueryChannelClientStateRequest) XXX_Size ¶
func (m *QueryChannelClientStateRequest) XXX_Size() int
func (*QueryChannelClientStateRequest) XXX_Unmarshal ¶
func (m *QueryChannelClientStateRequest) XXX_Unmarshal(b []byte) error
type QueryChannelClientStateResponse ¶
type QueryChannelClientStateResponse struct { // client state associated with the channel IdentifiedClientState *types.IdentifiedClientState `` /* 126-byte string literal not displayed */ // 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"` }
QueryChannelClientStateResponse is the Response type for the Query/QueryChannelClientState RPC method
func NewQueryChannelClientStateResponse ¶
func NewQueryChannelClientStateResponse(identifiedClientState clienttypes.IdentifiedClientState, proof []byte, height clienttypes.Height) *QueryChannelClientStateResponse
NewQueryChannelClientStateResponse creates a newQueryChannelClientStateResponse instance
func (*QueryChannelClientStateResponse) Descriptor ¶
func (*QueryChannelClientStateResponse) Descriptor() ([]byte, []int)
func (*QueryChannelClientStateResponse) GetIdentifiedClientState ¶
func (m *QueryChannelClientStateResponse) GetIdentifiedClientState() *types.IdentifiedClientState
func (*QueryChannelClientStateResponse) GetProof ¶
func (m *QueryChannelClientStateResponse) GetProof() []byte
func (*QueryChannelClientStateResponse) GetProofHeight ¶
func (m *QueryChannelClientStateResponse) GetProofHeight() types.Height
func (*QueryChannelClientStateResponse) Marshal ¶
func (m *QueryChannelClientStateResponse) Marshal() (dAtA []byte, err error)
func (*QueryChannelClientStateResponse) MarshalTo ¶
func (m *QueryChannelClientStateResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryChannelClientStateResponse) MarshalToSizedBuffer ¶
func (m *QueryChannelClientStateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryChannelClientStateResponse) ProtoMessage ¶
func (*QueryChannelClientStateResponse) ProtoMessage()
func (*QueryChannelClientStateResponse) Reset ¶
func (m *QueryChannelClientStateResponse) Reset()
func (*QueryChannelClientStateResponse) Size ¶
func (m *QueryChannelClientStateResponse) Size() (n int)
func (*QueryChannelClientStateResponse) String ¶
func (m *QueryChannelClientStateResponse) String() string
func (*QueryChannelClientStateResponse) Unmarshal ¶
func (m *QueryChannelClientStateResponse) Unmarshal(dAtA []byte) error
func (QueryChannelClientStateResponse) UnpackInterfaces ¶
func (qccsr QueryChannelClientStateResponse) UnpackInterfaces(unpacker codectypes.AnyUnpacker) error
UnpackInterfaces implements UnpackInterfacesMesssage.UnpackInterfaces
func (*QueryChannelClientStateResponse) XXX_DiscardUnknown ¶
func (m *QueryChannelClientStateResponse) XXX_DiscardUnknown()
func (*QueryChannelClientStateResponse) XXX_Marshal ¶
func (m *QueryChannelClientStateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryChannelClientStateResponse) XXX_Merge ¶
func (m *QueryChannelClientStateResponse) XXX_Merge(src proto.Message)
func (*QueryChannelClientStateResponse) XXX_Size ¶
func (m *QueryChannelClientStateResponse) XXX_Size() int
func (*QueryChannelClientStateResponse) XXX_Unmarshal ¶
func (m *QueryChannelClientStateResponse) XXX_Unmarshal(b []byte) error
type QueryChannelConsensusStateRequest ¶
type QueryChannelConsensusStateRequest struct { // port unique identifier PortId string `protobuf:"bytes,1,opt,name=port_id,json=portId,proto3" json:"port_id,omitempty"` // channel unique identifier ChannelId string `protobuf:"bytes,2,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"` // revision number of the consensus state RevisionNumber uint64 `protobuf:"varint,3,opt,name=revision_number,json=revisionNumber,proto3" json:"revision_number,omitempty"` // revision height of the consensus state RevisionHeight uint64 `protobuf:"varint,4,opt,name=revision_height,json=revisionHeight,proto3" json:"revision_height,omitempty"` }
QueryChannelConsensusStateRequest is the request type for the Query/ConsensusState RPC method
func (*QueryChannelConsensusStateRequest) Descriptor ¶
func (*QueryChannelConsensusStateRequest) Descriptor() ([]byte, []int)
func (*QueryChannelConsensusStateRequest) GetChannelId ¶
func (m *QueryChannelConsensusStateRequest) GetChannelId() string
func (*QueryChannelConsensusStateRequest) GetPortId ¶
func (m *QueryChannelConsensusStateRequest) GetPortId() string
func (*QueryChannelConsensusStateRequest) GetRevisionHeight ¶
func (m *QueryChannelConsensusStateRequest) GetRevisionHeight() uint64
func (*QueryChannelConsensusStateRequest) GetRevisionNumber ¶
func (m *QueryChannelConsensusStateRequest) GetRevisionNumber() uint64
func (*QueryChannelConsensusStateRequest) Marshal ¶
func (m *QueryChannelConsensusStateRequest) Marshal() (dAtA []byte, err error)
func (*QueryChannelConsensusStateRequest) MarshalTo ¶
func (m *QueryChannelConsensusStateRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryChannelConsensusStateRequest) MarshalToSizedBuffer ¶
func (m *QueryChannelConsensusStateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryChannelConsensusStateRequest) ProtoMessage ¶
func (*QueryChannelConsensusStateRequest) ProtoMessage()
func (*QueryChannelConsensusStateRequest) Reset ¶
func (m *QueryChannelConsensusStateRequest) Reset()
func (*QueryChannelConsensusStateRequest) Size ¶
func (m *QueryChannelConsensusStateRequest) Size() (n int)
func (*QueryChannelConsensusStateRequest) String ¶
func (m *QueryChannelConsensusStateRequest) String() string
func (*QueryChannelConsensusStateRequest) Unmarshal ¶
func (m *QueryChannelConsensusStateRequest) Unmarshal(dAtA []byte) error
func (*QueryChannelConsensusStateRequest) XXX_DiscardUnknown ¶
func (m *QueryChannelConsensusStateRequest) XXX_DiscardUnknown()
func (*QueryChannelConsensusStateRequest) XXX_Marshal ¶
func (m *QueryChannelConsensusStateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryChannelConsensusStateRequest) XXX_Merge ¶
func (m *QueryChannelConsensusStateRequest) XXX_Merge(src proto.Message)
func (*QueryChannelConsensusStateRequest) XXX_Size ¶
func (m *QueryChannelConsensusStateRequest) XXX_Size() int
func (*QueryChannelConsensusStateRequest) XXX_Unmarshal ¶
func (m *QueryChannelConsensusStateRequest) XXX_Unmarshal(b []byte) error
type QueryChannelConsensusStateResponse ¶
type QueryChannelConsensusStateResponse struct { // consensus state associated with the channel ConsensusState *types1.Any `protobuf:"bytes,1,opt,name=consensus_state,json=consensusState,proto3" json:"consensus_state,omitempty"` // client ID associated with the consensus state ClientId string `protobuf:"bytes,2,opt,name=client_id,json=clientId,proto3" json:"client_id,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"` }
QueryChannelClientStateResponse is the Response type for the Query/QueryChannelClientState RPC method
func NewQueryChannelConsensusStateResponse ¶
func NewQueryChannelConsensusStateResponse(clientID string, anyConsensusState *codectypes.Any, consensusStateHeight exported.Height, proof []byte, height clienttypes.Height) *QueryChannelConsensusStateResponse
NewQueryChannelConsensusStateResponse creates a newQueryChannelConsensusStateResponse instance
func (*QueryChannelConsensusStateResponse) Descriptor ¶
func (*QueryChannelConsensusStateResponse) Descriptor() ([]byte, []int)
func (*QueryChannelConsensusStateResponse) GetClientId ¶
func (m *QueryChannelConsensusStateResponse) GetClientId() string
func (*QueryChannelConsensusStateResponse) GetConsensusState ¶
func (m *QueryChannelConsensusStateResponse) GetConsensusState() *types1.Any
func (*QueryChannelConsensusStateResponse) GetProof ¶
func (m *QueryChannelConsensusStateResponse) GetProof() []byte
func (*QueryChannelConsensusStateResponse) GetProofHeight ¶
func (m *QueryChannelConsensusStateResponse) GetProofHeight() types.Height
func (*QueryChannelConsensusStateResponse) Marshal ¶
func (m *QueryChannelConsensusStateResponse) Marshal() (dAtA []byte, err error)
func (*QueryChannelConsensusStateResponse) MarshalTo ¶
func (m *QueryChannelConsensusStateResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryChannelConsensusStateResponse) MarshalToSizedBuffer ¶
func (m *QueryChannelConsensusStateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryChannelConsensusStateResponse) ProtoMessage ¶
func (*QueryChannelConsensusStateResponse) ProtoMessage()
func (*QueryChannelConsensusStateResponse) Reset ¶
func (m *QueryChannelConsensusStateResponse) Reset()
func (*QueryChannelConsensusStateResponse) Size ¶
func (m *QueryChannelConsensusStateResponse) Size() (n int)
func (*QueryChannelConsensusStateResponse) String ¶
func (m *QueryChannelConsensusStateResponse) String() string
func (*QueryChannelConsensusStateResponse) Unmarshal ¶
func (m *QueryChannelConsensusStateResponse) Unmarshal(dAtA []byte) error
func (QueryChannelConsensusStateResponse) UnpackInterfaces ¶
func (qccsr QueryChannelConsensusStateResponse) UnpackInterfaces(unpacker codectypes.AnyUnpacker) error
UnpackInterfaces implements UnpackInterfacesMesssage.UnpackInterfaces
func (*QueryChannelConsensusStateResponse) XXX_DiscardUnknown ¶
func (m *QueryChannelConsensusStateResponse) XXX_DiscardUnknown()
func (*QueryChannelConsensusStateResponse) XXX_Marshal ¶
func (m *QueryChannelConsensusStateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryChannelConsensusStateResponse) XXX_Merge ¶
func (m *QueryChannelConsensusStateResponse) XXX_Merge(src proto.Message)
func (*QueryChannelConsensusStateResponse) XXX_Size ¶
func (m *QueryChannelConsensusStateResponse) XXX_Size() int
func (*QueryChannelConsensusStateResponse) XXX_Unmarshal ¶
func (m *QueryChannelConsensusStateResponse) XXX_Unmarshal(b []byte) error
type QueryChannelRequest ¶
type QueryChannelRequest struct { // port unique identifier PortId string `protobuf:"bytes,1,opt,name=port_id,json=portId,proto3" json:"port_id,omitempty"` // channel unique identifier ChannelId string `protobuf:"bytes,2,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"` }
QueryChannelRequest is the request type for the Query/Channel RPC method
func (*QueryChannelRequest) Descriptor ¶
func (*QueryChannelRequest) Descriptor() ([]byte, []int)
func (*QueryChannelRequest) GetChannelId ¶
func (m *QueryChannelRequest) GetChannelId() string
func (*QueryChannelRequest) GetPortId ¶
func (m *QueryChannelRequest) GetPortId() string
func (*QueryChannelRequest) Marshal ¶
func (m *QueryChannelRequest) Marshal() (dAtA []byte, err error)
func (*QueryChannelRequest) MarshalTo ¶
func (m *QueryChannelRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryChannelRequest) MarshalToSizedBuffer ¶
func (m *QueryChannelRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryChannelRequest) ProtoMessage ¶
func (*QueryChannelRequest) ProtoMessage()
func (*QueryChannelRequest) Reset ¶
func (m *QueryChannelRequest) Reset()
func (*QueryChannelRequest) Size ¶
func (m *QueryChannelRequest) Size() (n int)
func (*QueryChannelRequest) String ¶
func (m *QueryChannelRequest) String() string
func (*QueryChannelRequest) Unmarshal ¶
func (m *QueryChannelRequest) Unmarshal(dAtA []byte) error
func (*QueryChannelRequest) XXX_DiscardUnknown ¶
func (m *QueryChannelRequest) XXX_DiscardUnknown()
func (*QueryChannelRequest) XXX_Marshal ¶
func (m *QueryChannelRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryChannelRequest) XXX_Merge ¶
func (m *QueryChannelRequest) XXX_Merge(src proto.Message)
func (*QueryChannelRequest) XXX_Size ¶
func (m *QueryChannelRequest) XXX_Size() int
func (*QueryChannelRequest) XXX_Unmarshal ¶
func (m *QueryChannelRequest) XXX_Unmarshal(b []byte) error
type QueryChannelResponse ¶
type QueryChannelResponse struct { // channel associated with the request identifiers Channel *Channel `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"` // merkle proof of existence Proof []byte `protobuf:"bytes,2,opt,name=proof,proto3" json:"proof,omitempty"` // height at which the proof was retrieved ProofHeight types.Height `protobuf:"bytes,3,opt,name=proof_height,json=proofHeight,proto3" json:"proof_height"` }
QueryChannelResponse is the response type for the Query/Channel RPC method. Besides the Channel end, it includes a proof and the height from which the proof was retrieved.
func NewQueryChannelResponse ¶
func NewQueryChannelResponse(channel Channel, proof []byte, height clienttypes.Height) *QueryChannelResponse
NewQueryChannelResponse creates a new QueryChannelResponse instance
func (*QueryChannelResponse) Descriptor ¶
func (*QueryChannelResponse) Descriptor() ([]byte, []int)
func (*QueryChannelResponse) GetChannel ¶
func (m *QueryChannelResponse) GetChannel() *Channel
func (*QueryChannelResponse) GetProof ¶
func (m *QueryChannelResponse) GetProof() []byte
func (*QueryChannelResponse) GetProofHeight ¶
func (m *QueryChannelResponse) GetProofHeight() types.Height
func (*QueryChannelResponse) Marshal ¶
func (m *QueryChannelResponse) Marshal() (dAtA []byte, err error)
func (*QueryChannelResponse) MarshalTo ¶
func (m *QueryChannelResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryChannelResponse) MarshalToSizedBuffer ¶
func (m *QueryChannelResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryChannelResponse) ProtoMessage ¶
func (*QueryChannelResponse) ProtoMessage()
func (*QueryChannelResponse) Reset ¶
func (m *QueryChannelResponse) Reset()
func (*QueryChannelResponse) Size ¶
func (m *QueryChannelResponse) Size() (n int)
func (*QueryChannelResponse) String ¶
func (m *QueryChannelResponse) String() string
func (*QueryChannelResponse) Unmarshal ¶
func (m *QueryChannelResponse) Unmarshal(dAtA []byte) error
func (*QueryChannelResponse) XXX_DiscardUnknown ¶
func (m *QueryChannelResponse) XXX_DiscardUnknown()
func (*QueryChannelResponse) XXX_Marshal ¶
func (m *QueryChannelResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryChannelResponse) XXX_Merge ¶
func (m *QueryChannelResponse) XXX_Merge(src proto.Message)
func (*QueryChannelResponse) XXX_Size ¶
func (m *QueryChannelResponse) XXX_Size() int
func (*QueryChannelResponse) XXX_Unmarshal ¶
func (m *QueryChannelResponse) XXX_Unmarshal(b []byte) error
type QueryChannelsRequest ¶
type QueryChannelsRequest struct { // pagination request Pagination *query.PageRequest `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"` }
QueryChannelsRequest is the request type for the Query/Channels RPC method
func (*QueryChannelsRequest) Descriptor ¶
func (*QueryChannelsRequest) Descriptor() ([]byte, []int)
func (*QueryChannelsRequest) GetPagination ¶
func (m *QueryChannelsRequest) GetPagination() *query.PageRequest
func (*QueryChannelsRequest) Marshal ¶
func (m *QueryChannelsRequest) Marshal() (dAtA []byte, err error)
func (*QueryChannelsRequest) MarshalTo ¶
func (m *QueryChannelsRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryChannelsRequest) MarshalToSizedBuffer ¶
func (m *QueryChannelsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryChannelsRequest) ProtoMessage ¶
func (*QueryChannelsRequest) ProtoMessage()
func (*QueryChannelsRequest) Reset ¶
func (m *QueryChannelsRequest) Reset()
func (*QueryChannelsRequest) Size ¶
func (m *QueryChannelsRequest) Size() (n int)
func (*QueryChannelsRequest) String ¶
func (m *QueryChannelsRequest) String() string
func (*QueryChannelsRequest) Unmarshal ¶
func (m *QueryChannelsRequest) Unmarshal(dAtA []byte) error
func (*QueryChannelsRequest) XXX_DiscardUnknown ¶
func (m *QueryChannelsRequest) XXX_DiscardUnknown()
func (*QueryChannelsRequest) XXX_Marshal ¶
func (m *QueryChannelsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryChannelsRequest) XXX_Merge ¶
func (m *QueryChannelsRequest) XXX_Merge(src proto.Message)
func (*QueryChannelsRequest) XXX_Size ¶
func (m *QueryChannelsRequest) XXX_Size() int
func (*QueryChannelsRequest) XXX_Unmarshal ¶
func (m *QueryChannelsRequest) XXX_Unmarshal(b []byte) error
type QueryChannelsResponse ¶
type QueryChannelsResponse struct { // list of stored channels of the chain. Channels []*IdentifiedChannel `protobuf:"bytes,1,rep,name=channels,proto3" json:"channels,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"` }
QueryChannelsResponse is the response type for the Query/Channels RPC method.
func (*QueryChannelsResponse) Descriptor ¶
func (*QueryChannelsResponse) Descriptor() ([]byte, []int)
func (*QueryChannelsResponse) GetChannels ¶
func (m *QueryChannelsResponse) GetChannels() []*IdentifiedChannel
func (*QueryChannelsResponse) GetHeight ¶
func (m *QueryChannelsResponse) GetHeight() types.Height
func (*QueryChannelsResponse) GetPagination ¶
func (m *QueryChannelsResponse) GetPagination() *query.PageResponse
func (*QueryChannelsResponse) Marshal ¶
func (m *QueryChannelsResponse) Marshal() (dAtA []byte, err error)
func (*QueryChannelsResponse) MarshalTo ¶
func (m *QueryChannelsResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryChannelsResponse) MarshalToSizedBuffer ¶
func (m *QueryChannelsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryChannelsResponse) ProtoMessage ¶
func (*QueryChannelsResponse) ProtoMessage()
func (*QueryChannelsResponse) Reset ¶
func (m *QueryChannelsResponse) Reset()
func (*QueryChannelsResponse) Size ¶
func (m *QueryChannelsResponse) Size() (n int)
func (*QueryChannelsResponse) String ¶
func (m *QueryChannelsResponse) String() string
func (*QueryChannelsResponse) Unmarshal ¶
func (m *QueryChannelsResponse) Unmarshal(dAtA []byte) error
func (*QueryChannelsResponse) XXX_DiscardUnknown ¶
func (m *QueryChannelsResponse) XXX_DiscardUnknown()
func (*QueryChannelsResponse) XXX_Marshal ¶
func (m *QueryChannelsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryChannelsResponse) XXX_Merge ¶
func (m *QueryChannelsResponse) XXX_Merge(src proto.Message)
func (*QueryChannelsResponse) XXX_Size ¶
func (m *QueryChannelsResponse) XXX_Size() int
func (*QueryChannelsResponse) XXX_Unmarshal ¶
func (m *QueryChannelsResponse) XXX_Unmarshal(b []byte) error
type QueryClient ¶
type QueryClient interface { // Channel queries an ICP Channel. Channel(ctx context.Context, in *QueryChannelRequest, opts ...grpc.CallOption) (*QueryChannelResponse, error) // Channels queries all the ICP channels of a chain. Channels(ctx context.Context, in *QueryChannelsRequest, opts ...grpc.CallOption) (*QueryChannelsResponse, error) // ConnectionChannels queries all the channels associated with a connection // end. ConnectionChannels(ctx context.Context, in *QueryConnectionChannelsRequest, opts ...grpc.CallOption) (*QueryConnectionChannelsResponse, error) // ChannelClientState queries for the client state for the channel associated // with the provided channel identifiers. ChannelClientState(ctx context.Context, in *QueryChannelClientStateRequest, opts ...grpc.CallOption) (*QueryChannelClientStateResponse, error) // ChannelConsensusState queries for the consensus state for the channel // associated with the provided channel identifiers. ChannelConsensusState(ctx context.Context, in *QueryChannelConsensusStateRequest, opts ...grpc.CallOption) (*QueryChannelConsensusStateResponse, error) // 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 // with a channel. 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 // with a channel. PacketAcknowledgements(ctx context.Context, in *QueryPacketAcknowledgementsRequest, opts ...grpc.CallOption) (*QueryPacketAcknowledgementsResponse, error) // UnreceivedPackets returns all the unreceived ICP packets associated with a // channel and sequences. UnreceivedPackets(ctx context.Context, in *QueryUnreceivedPacketsRequest, opts ...grpc.CallOption) (*QueryUnreceivedPacketsResponse, error) // UnreceivedAcks returns all the unreceived ICP acknowledgements associated with a // channel and sequences. UnreceivedAcks(ctx context.Context, in *QueryUnreceivedAcksRequest, opts ...grpc.CallOption) (*QueryUnreceivedAcksResponse, error) // NextSequenceReceive returns the next receive sequence for a given channel. NextSequenceReceive(ctx context.Context, in *QueryNextSequenceReceiveRequest, opts ...grpc.CallOption) (*QueryNextSequenceReceiveResponse, error) }
QueryClient is the client API for Query service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewQueryClient ¶
func NewQueryClient(cc grpc1.ClientConn) QueryClient
type QueryConnectionChannelsRequest ¶
type QueryConnectionChannelsRequest struct { // connection unique identifier Connection string `protobuf:"bytes,1,opt,name=connection,proto3" json:"connection,omitempty"` // pagination request Pagination *query.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"` }
QueryConnectionChannelsRequest is the request type for the Query/QueryConnectionChannels RPC method
func (*QueryConnectionChannelsRequest) Descriptor ¶
func (*QueryConnectionChannelsRequest) Descriptor() ([]byte, []int)
func (*QueryConnectionChannelsRequest) GetConnection ¶
func (m *QueryConnectionChannelsRequest) GetConnection() string
func (*QueryConnectionChannelsRequest) GetPagination ¶
func (m *QueryConnectionChannelsRequest) GetPagination() *query.PageRequest
func (*QueryConnectionChannelsRequest) Marshal ¶
func (m *QueryConnectionChannelsRequest) Marshal() (dAtA []byte, err error)
func (*QueryConnectionChannelsRequest) MarshalTo ¶
func (m *QueryConnectionChannelsRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryConnectionChannelsRequest) MarshalToSizedBuffer ¶
func (m *QueryConnectionChannelsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryConnectionChannelsRequest) ProtoMessage ¶
func (*QueryConnectionChannelsRequest) ProtoMessage()
func (*QueryConnectionChannelsRequest) Reset ¶
func (m *QueryConnectionChannelsRequest) Reset()
func (*QueryConnectionChannelsRequest) Size ¶
func (m *QueryConnectionChannelsRequest) Size() (n int)
func (*QueryConnectionChannelsRequest) String ¶
func (m *QueryConnectionChannelsRequest) String() string
func (*QueryConnectionChannelsRequest) Unmarshal ¶
func (m *QueryConnectionChannelsRequest) Unmarshal(dAtA []byte) error
func (*QueryConnectionChannelsRequest) XXX_DiscardUnknown ¶
func (m *QueryConnectionChannelsRequest) XXX_DiscardUnknown()
func (*QueryConnectionChannelsRequest) XXX_Marshal ¶
func (m *QueryConnectionChannelsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryConnectionChannelsRequest) XXX_Merge ¶
func (m *QueryConnectionChannelsRequest) XXX_Merge(src proto.Message)
func (*QueryConnectionChannelsRequest) XXX_Size ¶
func (m *QueryConnectionChannelsRequest) XXX_Size() int
func (*QueryConnectionChannelsRequest) XXX_Unmarshal ¶
func (m *QueryConnectionChannelsRequest) XXX_Unmarshal(b []byte) error
type QueryConnectionChannelsResponse ¶
type QueryConnectionChannelsResponse struct { // list of channels associated with a connection. Channels []*IdentifiedChannel `protobuf:"bytes,1,rep,name=channels,proto3" json:"channels,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"` }
QueryConnectionChannelsResponse is the Response type for the Query/QueryConnectionChannels RPC method
func (*QueryConnectionChannelsResponse) Descriptor ¶
func (*QueryConnectionChannelsResponse) Descriptor() ([]byte, []int)
func (*QueryConnectionChannelsResponse) GetChannels ¶
func (m *QueryConnectionChannelsResponse) GetChannels() []*IdentifiedChannel
func (*QueryConnectionChannelsResponse) GetHeight ¶
func (m *QueryConnectionChannelsResponse) GetHeight() types.Height
func (*QueryConnectionChannelsResponse) GetPagination ¶
func (m *QueryConnectionChannelsResponse) GetPagination() *query.PageResponse
func (*QueryConnectionChannelsResponse) Marshal ¶
func (m *QueryConnectionChannelsResponse) Marshal() (dAtA []byte, err error)
func (*QueryConnectionChannelsResponse) MarshalTo ¶
func (m *QueryConnectionChannelsResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryConnectionChannelsResponse) MarshalToSizedBuffer ¶
func (m *QueryConnectionChannelsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryConnectionChannelsResponse) ProtoMessage ¶
func (*QueryConnectionChannelsResponse) ProtoMessage()
func (*QueryConnectionChannelsResponse) Reset ¶
func (m *QueryConnectionChannelsResponse) Reset()
func (*QueryConnectionChannelsResponse) Size ¶
func (m *QueryConnectionChannelsResponse) Size() (n int)
func (*QueryConnectionChannelsResponse) String ¶
func (m *QueryConnectionChannelsResponse) String() string
func (*QueryConnectionChannelsResponse) Unmarshal ¶
func (m *QueryConnectionChannelsResponse) Unmarshal(dAtA []byte) error
func (*QueryConnectionChannelsResponse) XXX_DiscardUnknown ¶
func (m *QueryConnectionChannelsResponse) XXX_DiscardUnknown()
func (*QueryConnectionChannelsResponse) XXX_Marshal ¶
func (m *QueryConnectionChannelsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryConnectionChannelsResponse) XXX_Merge ¶
func (m *QueryConnectionChannelsResponse) XXX_Merge(src proto.Message)
func (*QueryConnectionChannelsResponse) XXX_Size ¶
func (m *QueryConnectionChannelsResponse) XXX_Size() int
func (*QueryConnectionChannelsResponse) XXX_Unmarshal ¶
func (m *QueryConnectionChannelsResponse) XXX_Unmarshal(b []byte) error
type QueryNextSequenceReceiveRequest ¶
type QueryNextSequenceReceiveRequest struct { // port unique identifier PortId string `protobuf:"bytes,1,opt,name=port_id,json=portId,proto3" json:"port_id,omitempty"` // channel unique identifier ChannelId string `protobuf:"bytes,2,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"` }
QueryNextSequenceReceiveRequest is the request type for the Query/QueryNextSequenceReceiveRequest RPC method
func (*QueryNextSequenceReceiveRequest) Descriptor ¶
func (*QueryNextSequenceReceiveRequest) Descriptor() ([]byte, []int)
func (*QueryNextSequenceReceiveRequest) GetChannelId ¶
func (m *QueryNextSequenceReceiveRequest) GetChannelId() string
func (*QueryNextSequenceReceiveRequest) GetPortId ¶
func (m *QueryNextSequenceReceiveRequest) GetPortId() string
func (*QueryNextSequenceReceiveRequest) Marshal ¶
func (m *QueryNextSequenceReceiveRequest) Marshal() (dAtA []byte, err error)
func (*QueryNextSequenceReceiveRequest) MarshalTo ¶
func (m *QueryNextSequenceReceiveRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryNextSequenceReceiveRequest) MarshalToSizedBuffer ¶
func (m *QueryNextSequenceReceiveRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryNextSequenceReceiveRequest) ProtoMessage ¶
func (*QueryNextSequenceReceiveRequest) ProtoMessage()
func (*QueryNextSequenceReceiveRequest) Reset ¶
func (m *QueryNextSequenceReceiveRequest) Reset()
func (*QueryNextSequenceReceiveRequest) Size ¶
func (m *QueryNextSequenceReceiveRequest) Size() (n int)
func (*QueryNextSequenceReceiveRequest) String ¶
func (m *QueryNextSequenceReceiveRequest) String() string
func (*QueryNextSequenceReceiveRequest) Unmarshal ¶
func (m *QueryNextSequenceReceiveRequest) Unmarshal(dAtA []byte) error
func (*QueryNextSequenceReceiveRequest) XXX_DiscardUnknown ¶
func (m *QueryNextSequenceReceiveRequest) XXX_DiscardUnknown()
func (*QueryNextSequenceReceiveRequest) XXX_Marshal ¶
func (m *QueryNextSequenceReceiveRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryNextSequenceReceiveRequest) XXX_Merge ¶
func (m *QueryNextSequenceReceiveRequest) XXX_Merge(src proto.Message)
func (*QueryNextSequenceReceiveRequest) XXX_Size ¶
func (m *QueryNextSequenceReceiveRequest) XXX_Size() int
func (*QueryNextSequenceReceiveRequest) XXX_Unmarshal ¶
func (m *QueryNextSequenceReceiveRequest) XXX_Unmarshal(b []byte) error
type QueryNextSequenceReceiveResponse ¶
type QueryNextSequenceReceiveResponse struct { // next sequence receive number NextSequenceReceive uint64 `protobuf:"varint,1,opt,name=next_sequence_receive,json=nextSequenceReceive,proto3" json:"next_sequence_receive,omitempty"` // merkle proof of existence Proof []byte `protobuf:"bytes,2,opt,name=proof,proto3" json:"proof,omitempty"` // height at which the proof was retrieved ProofHeight types.Height `protobuf:"bytes,3,opt,name=proof_height,json=proofHeight,proto3" json:"proof_height"` }
QuerySequenceResponse is the request type for the Query/QueryNextSequenceReceiveResponse RPC method
func NewQueryNextSequenceReceiveResponse ¶
func NewQueryNextSequenceReceiveResponse( sequence uint64, proof []byte, height clienttypes.Height, ) *QueryNextSequenceReceiveResponse
NewQueryNextSequenceReceiveResponse creates a new QueryNextSequenceReceiveResponse instance
func (*QueryNextSequenceReceiveResponse) Descriptor ¶
func (*QueryNextSequenceReceiveResponse) Descriptor() ([]byte, []int)
func (*QueryNextSequenceReceiveResponse) GetNextSequenceReceive ¶
func (m *QueryNextSequenceReceiveResponse) GetNextSequenceReceive() uint64
func (*QueryNextSequenceReceiveResponse) GetProof ¶
func (m *QueryNextSequenceReceiveResponse) GetProof() []byte
func (*QueryNextSequenceReceiveResponse) GetProofHeight ¶
func (m *QueryNextSequenceReceiveResponse) GetProofHeight() types.Height
func (*QueryNextSequenceReceiveResponse) Marshal ¶
func (m *QueryNextSequenceReceiveResponse) Marshal() (dAtA []byte, err error)
func (*QueryNextSequenceReceiveResponse) MarshalTo ¶
func (m *QueryNextSequenceReceiveResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryNextSequenceReceiveResponse) MarshalToSizedBuffer ¶
func (m *QueryNextSequenceReceiveResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryNextSequenceReceiveResponse) ProtoMessage ¶
func (*QueryNextSequenceReceiveResponse) ProtoMessage()
func (*QueryNextSequenceReceiveResponse) Reset ¶
func (m *QueryNextSequenceReceiveResponse) Reset()
func (*QueryNextSequenceReceiveResponse) Size ¶
func (m *QueryNextSequenceReceiveResponse) Size() (n int)
func (*QueryNextSequenceReceiveResponse) String ¶
func (m *QueryNextSequenceReceiveResponse) String() string
func (*QueryNextSequenceReceiveResponse) Unmarshal ¶
func (m *QueryNextSequenceReceiveResponse) Unmarshal(dAtA []byte) error
func (*QueryNextSequenceReceiveResponse) XXX_DiscardUnknown ¶
func (m *QueryNextSequenceReceiveResponse) XXX_DiscardUnknown()
func (*QueryNextSequenceReceiveResponse) XXX_Marshal ¶
func (m *QueryNextSequenceReceiveResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryNextSequenceReceiveResponse) XXX_Merge ¶
func (m *QueryNextSequenceReceiveResponse) XXX_Merge(src proto.Message)
func (*QueryNextSequenceReceiveResponse) XXX_Size ¶
func (m *QueryNextSequenceReceiveResponse) XXX_Size() int
func (*QueryNextSequenceReceiveResponse) XXX_Unmarshal ¶
func (m *QueryNextSequenceReceiveResponse) XXX_Unmarshal(b []byte) error
type QueryPacketAcknowledgementRequest ¶
type QueryPacketAcknowledgementRequest struct { // port unique identifier PortId string `protobuf:"bytes,1,opt,name=port_id,json=portId,proto3" json:"port_id,omitempty"` // channel unique identifier ChannelId string `protobuf:"bytes,2,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"` // packet sequence Sequence uint64 `protobuf:"varint,3,opt,name=sequence,proto3" json:"sequence,omitempty"` }
QueryPacketAcknowledgementRequest is the request type for the Query/PacketAcknowledgement RPC method
func (*QueryPacketAcknowledgementRequest) Descriptor ¶
func (*QueryPacketAcknowledgementRequest) Descriptor() ([]byte, []int)
func (*QueryPacketAcknowledgementRequest) GetChannelId ¶
func (m *QueryPacketAcknowledgementRequest) GetChannelId() string
func (*QueryPacketAcknowledgementRequest) GetPortId ¶
func (m *QueryPacketAcknowledgementRequest) GetPortId() string
func (*QueryPacketAcknowledgementRequest) GetSequence ¶
func (m *QueryPacketAcknowledgementRequest) GetSequence() uint64
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 { // port unique identifier PortId string `protobuf:"bytes,1,opt,name=port_id,json=portId,proto3" json:"port_id,omitempty"` // channel unique identifier ChannelId string `protobuf:"bytes,2,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"` // pagination request 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) GetChannelId ¶
func (m *QueryPacketAcknowledgementsRequest) GetChannelId() string
func (*QueryPacketAcknowledgementsRequest) GetPagination ¶
func (m *QueryPacketAcknowledgementsRequest) GetPagination() *query.PageRequest
func (*QueryPacketAcknowledgementsRequest) GetPortId ¶
func (m *QueryPacketAcknowledgementsRequest) GetPortId() 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 { // port unique identifier PortId string `protobuf:"bytes,1,opt,name=port_id,json=portId,proto3" json:"port_id,omitempty"` // channel unique identifier ChannelId string `protobuf:"bytes,2,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"` // packet sequence Sequence uint64 `protobuf:"varint,3,opt,name=sequence,proto3" json:"sequence,omitempty"` }
QueryPacketCommitmentRequest is the request type for the Query/PacketCommitment RPC method
func (*QueryPacketCommitmentRequest) Descriptor ¶
func (*QueryPacketCommitmentRequest) Descriptor() ([]byte, []int)
func (*QueryPacketCommitmentRequest) GetChannelId ¶
func (m *QueryPacketCommitmentRequest) GetChannelId() string
func (*QueryPacketCommitmentRequest) GetPortId ¶
func (m *QueryPacketCommitmentRequest) GetPortId() string
func (*QueryPacketCommitmentRequest) GetSequence ¶
func (m *QueryPacketCommitmentRequest) GetSequence() uint64
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 { // port unique identifier PortId string `protobuf:"bytes,1,opt,name=port_id,json=portId,proto3" json:"port_id,omitempty"` // channel unique identifier ChannelId string `protobuf:"bytes,2,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"` // pagination request 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) GetChannelId ¶
func (m *QueryPacketCommitmentsRequest) GetChannelId() string
func (*QueryPacketCommitmentsRequest) GetPagination ¶
func (m *QueryPacketCommitmentsRequest) GetPagination() *query.PageRequest
func (*QueryPacketCommitmentsRequest) GetPortId ¶
func (m *QueryPacketCommitmentsRequest) GetPortId() 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 { // port unique identifier PortId string `protobuf:"bytes,1,opt,name=port_id,json=portId,proto3" json:"port_id,omitempty"` // channel unique identifier ChannelId string `protobuf:"bytes,2,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"` // packet sequence Sequence uint64 `protobuf:"varint,3,opt,name=sequence,proto3" json:"sequence,omitempty"` }
QueryPacketReceiptRequest is the request type for the Query/PacketReceipt RPC method
func (*QueryPacketReceiptRequest) Descriptor ¶
func (*QueryPacketReceiptRequest) Descriptor() ([]byte, []int)
func (*QueryPacketReceiptRequest) GetChannelId ¶
func (m *QueryPacketReceiptRequest) GetChannelId() string
func (*QueryPacketReceiptRequest) GetPortId ¶
func (m *QueryPacketReceiptRequest) GetPortId() string
func (*QueryPacketReceiptRequest) GetSequence ¶
func (m *QueryPacketReceiptRequest) GetSequence() uint64
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 { // Channel queries an ICP Channel. Channel(context.Context, *QueryChannelRequest) (*QueryChannelResponse, error) // Channels queries all the ICP channels of a chain. Channels(context.Context, *QueryChannelsRequest) (*QueryChannelsResponse, error) // ConnectionChannels queries all the channels associated with a connection // end. ConnectionChannels(context.Context, *QueryConnectionChannelsRequest) (*QueryConnectionChannelsResponse, error) // ChannelClientState queries for the client state for the channel associated // with the provided channel identifiers. ChannelClientState(context.Context, *QueryChannelClientStateRequest) (*QueryChannelClientStateResponse, error) // ChannelConsensusState queries for the consensus state for the channel // associated with the provided channel identifiers. ChannelConsensusState(context.Context, *QueryChannelConsensusStateRequest) (*QueryChannelConsensusStateResponse, error) // PacketCommitment queries a stored packet commitment hash. PacketCommitment(context.Context, *QueryPacketCommitmentRequest) (*QueryPacketCommitmentResponse, error) // PacketCommitments returns all the packet commitments hashes associated // with a channel. 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 // with a channel. PacketAcknowledgements(context.Context, *QueryPacketAcknowledgementsRequest) (*QueryPacketAcknowledgementsResponse, error) // UnreceivedPackets returns all the unreceived ICP packets associated with a // channel and sequences. UnreceivedPackets(context.Context, *QueryUnreceivedPacketsRequest) (*QueryUnreceivedPacketsResponse, error) // UnreceivedAcks returns all the unreceived ICP acknowledgements associated with a // channel and sequences. UnreceivedAcks(context.Context, *QueryUnreceivedAcksRequest) (*QueryUnreceivedAcksResponse, error) // NextSequenceReceive returns the next receive sequence for a given channel. NextSequenceReceive(context.Context, *QueryNextSequenceReceiveRequest) (*QueryNextSequenceReceiveResponse, error) }
QueryServer is the server API for Query service.
type QueryUnreceivedAcksRequest ¶
type QueryUnreceivedAcksRequest struct { // port unique identifier PortId string `protobuf:"bytes,1,opt,name=port_id,json=portId,proto3" json:"port_id,omitempty"` // channel unique identifier ChannelId string `protobuf:"bytes,2,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"` // list of 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) GetChannelId ¶
func (m *QueryUnreceivedAcksRequest) GetChannelId() string
func (*QueryUnreceivedAcksRequest) GetPacketAckSequences ¶
func (m *QueryUnreceivedAcksRequest) GetPacketAckSequences() []uint64
func (*QueryUnreceivedAcksRequest) GetPortId ¶
func (m *QueryUnreceivedAcksRequest) GetPortId() 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 { // port unique identifier PortId string `protobuf:"bytes,1,opt,name=port_id,json=portId,proto3" json:"port_id,omitempty"` // channel unique identifier ChannelId string `protobuf:"bytes,2,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"` // list of packet sequences 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) GetChannelId ¶
func (m *QueryUnreceivedPacketsRequest) GetChannelId() string
func (*QueryUnreceivedPacketsRequest) GetPacketCommitmentSequences ¶
func (m *QueryUnreceivedPacketsRequest) GetPacketCommitmentSequences() []uint64
func (*QueryUnreceivedPacketsRequest) GetPortId ¶
func (m *QueryUnreceivedPacketsRequest) GetPortId() 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 State ¶
type State int32
State defines if a channel is in one of the following states: CLOSED, INIT, TRYOPEN, OPEN or UNINITIALIZED.
const ( // Default State UNINITIALIZED State = 0 // A channel has just started the opening handshake. INIT State = 1 // A channel has acknowledged the handshake step on the counterparty chain. TRYOPEN State = 2 // A channel has completed the handshake. Open channels are // ready to send and receive packets. OPEN State = 3 // A channel has been closed and can no longer be used to send or receive // packets. CLOSED State = 4 )
func (State) EnumDescriptor ¶
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) ChannelCloseConfirm ¶
func (*UnimplementedMsgServer) ChannelCloseConfirm(ctx context.Context, req *MsgChannelCloseConfirm) (*MsgChannelCloseConfirmResponse, error)
func (*UnimplementedMsgServer) ChannelCloseInit ¶
func (*UnimplementedMsgServer) ChannelCloseInit(ctx context.Context, req *MsgChannelCloseInit) (*MsgChannelCloseInitResponse, error)
func (*UnimplementedMsgServer) ChannelOpenAck ¶
func (*UnimplementedMsgServer) ChannelOpenAck(ctx context.Context, req *MsgChannelOpenAck) (*MsgChannelOpenAckResponse, error)
func (*UnimplementedMsgServer) ChannelOpenConfirm ¶
func (*UnimplementedMsgServer) ChannelOpenConfirm(ctx context.Context, req *MsgChannelOpenConfirm) (*MsgChannelOpenConfirmResponse, error)
func (*UnimplementedMsgServer) ChannelOpenInit ¶
func (*UnimplementedMsgServer) ChannelOpenInit(ctx context.Context, req *MsgChannelOpenInit) (*MsgChannelOpenInitResponse, error)
func (*UnimplementedMsgServer) ChannelOpenTry ¶
func (*UnimplementedMsgServer) ChannelOpenTry(ctx context.Context, req *MsgChannelOpenTry) (*MsgChannelOpenTryResponse, error)
func (*UnimplementedMsgServer) RecvPacket ¶
func (*UnimplementedMsgServer) RecvPacket(ctx context.Context, req *MsgRecvPacket) (*MsgRecvPacketResponse, error)
func (*UnimplementedMsgServer) Timeout ¶
func (*UnimplementedMsgServer) Timeout(ctx context.Context, req *MsgTimeout) (*MsgTimeoutResponse, error)
func (*UnimplementedMsgServer) TimeoutOnClose ¶
func (*UnimplementedMsgServer) TimeoutOnClose(ctx context.Context, req *MsgTimeoutOnClose) (*MsgTimeoutOnCloseResponse, error)
type UnimplementedQueryServer ¶
type UnimplementedQueryServer struct { }
UnimplementedQueryServer can be embedded to have forward compatible implementations.
func (*UnimplementedQueryServer) Channel ¶
func (*UnimplementedQueryServer) Channel(ctx context.Context, req *QueryChannelRequest) (*QueryChannelResponse, error)
func (*UnimplementedQueryServer) ChannelClientState ¶
func (*UnimplementedQueryServer) ChannelClientState(ctx context.Context, req *QueryChannelClientStateRequest) (*QueryChannelClientStateResponse, error)
func (*UnimplementedQueryServer) ChannelConsensusState ¶
func (*UnimplementedQueryServer) ChannelConsensusState(ctx context.Context, req *QueryChannelConsensusStateRequest) (*QueryChannelConsensusStateResponse, error)
func (*UnimplementedQueryServer) Channels ¶
func (*UnimplementedQueryServer) Channels(ctx context.Context, req *QueryChannelsRequest) (*QueryChannelsResponse, error)
func (*UnimplementedQueryServer) ConnectionChannels ¶
func (*UnimplementedQueryServer) ConnectionChannels(ctx context.Context, req *QueryConnectionChannelsRequest) (*QueryConnectionChannelsResponse, error)
func (*UnimplementedQueryServer) NextSequenceReceive ¶
func (*UnimplementedQueryServer) NextSequenceReceive(ctx context.Context, req *QueryNextSequenceReceiveRequest) (*QueryNextSequenceReceiveResponse, error)
func (*UnimplementedQueryServer) PacketAcknowledgement ¶
func (*UnimplementedQueryServer) PacketAcknowledgement(ctx context.Context, req *QueryPacketAcknowledgementRequest) (*QueryPacketAcknowledgementResponse, error)
func (*UnimplementedQueryServer) PacketAcknowledgements ¶
func (*UnimplementedQueryServer) PacketAcknowledgements(ctx context.Context, req *QueryPacketAcknowledgementsRequest) (*QueryPacketAcknowledgementsResponse, error)
func (*UnimplementedQueryServer) PacketCommitment ¶
func (*UnimplementedQueryServer) PacketCommitment(ctx context.Context, req *QueryPacketCommitmentRequest) (*QueryPacketCommitmentResponse, error)
func (*UnimplementedQueryServer) PacketCommitments ¶
func (*UnimplementedQueryServer) PacketCommitments(ctx context.Context, req *QueryPacketCommitmentsRequest) (*QueryPacketCommitmentsResponse, error)
func (*UnimplementedQueryServer) PacketReceipt ¶
func (*UnimplementedQueryServer) PacketReceipt(ctx context.Context, req *QueryPacketReceiptRequest) (*QueryPacketReceiptResponse, error)
func (*UnimplementedQueryServer) UnreceivedAcks ¶
func (*UnimplementedQueryServer) UnreceivedAcks(ctx context.Context, req *QueryUnreceivedAcksRequest) (*QueryUnreceivedAcksResponse, error)
func (*UnimplementedQueryServer) UnreceivedPackets ¶
func (*UnimplementedQueryServer) UnreceivedPackets(ctx context.Context, req *QueryUnreceivedPacketsRequest) (*QueryUnreceivedPacketsResponse, error)