Documentation ¶
Index ¶
- Constants
- Variables
- func CommitAcknowledgement(data []byte) []byte
- func CommitPacket(packet exported.PacketI) []byte
- func RegisterCodec(cdc *codec.Codec)
- func RegisterInterfaces(registry cdctypes.InterfaceRegistry)
- type Channel
- func (*Channel) Descriptor() ([]byte, []int)
- func (ch Channel) GetConnectionHops() []string
- func (ch Channel) GetCounterparty() exported.CounterpartyI
- 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 ChannelResponse
- 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
- type IdentifiedChannel
- type MsgAcknowledgement
- func (*MsgAcknowledgement) Descriptor() ([]byte, []int)
- func (m *MsgAcknowledgement) GetAcknowledgement() []byte
- func (m *MsgAcknowledgement) GetPacket() Packet
- func (m *MsgAcknowledgement) GetProof() types.MerkleProof
- func (m *MsgAcknowledgement) GetProofHeight() uint64
- func (msg MsgAcknowledgement) GetSignBytes() []byte
- func (m *MsgAcknowledgement) GetSigner() github_com_cosmos_cosmos_sdk_types.AccAddress
- 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 MsgChannelCloseConfirm
- func (*MsgChannelCloseConfirm) Descriptor() ([]byte, []int)
- func (m *MsgChannelCloseConfirm) GetChannelID() string
- func (m *MsgChannelCloseConfirm) GetPortID() string
- func (m *MsgChannelCloseConfirm) GetProofHeight() uint64
- func (m *MsgChannelCloseConfirm) GetProofInit() types.MerkleProof
- func (msg MsgChannelCloseConfirm) GetSignBytes() []byte
- func (m *MsgChannelCloseConfirm) GetSigner() github_com_cosmos_cosmos_sdk_types.AccAddress
- 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 MsgChannelCloseInit
- func (*MsgChannelCloseInit) Descriptor() ([]byte, []int)
- func (m *MsgChannelCloseInit) GetChannelID() string
- func (m *MsgChannelCloseInit) GetPortID() string
- func (msg MsgChannelCloseInit) GetSignBytes() []byte
- func (m *MsgChannelCloseInit) GetSigner() github_com_cosmos_cosmos_sdk_types.AccAddress
- 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 MsgChannelOpenAck
- func (*MsgChannelOpenAck) Descriptor() ([]byte, []int)
- func (m *MsgChannelOpenAck) GetChannelID() string
- func (m *MsgChannelOpenAck) GetCounterpartyVersion() string
- func (m *MsgChannelOpenAck) GetPortID() string
- func (m *MsgChannelOpenAck) GetProofHeight() uint64
- func (m *MsgChannelOpenAck) GetProofTry() types.MerkleProof
- func (msg MsgChannelOpenAck) GetSignBytes() []byte
- func (m *MsgChannelOpenAck) GetSigner() github_com_cosmos_cosmos_sdk_types.AccAddress
- 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 MsgChannelOpenConfirm
- func (*MsgChannelOpenConfirm) Descriptor() ([]byte, []int)
- func (m *MsgChannelOpenConfirm) GetChannelID() string
- func (m *MsgChannelOpenConfirm) GetPortID() string
- func (m *MsgChannelOpenConfirm) GetProofAck() types.MerkleProof
- func (m *MsgChannelOpenConfirm) GetProofHeight() uint64
- func (msg MsgChannelOpenConfirm) GetSignBytes() []byte
- func (m *MsgChannelOpenConfirm) GetSigner() github_com_cosmos_cosmos_sdk_types.AccAddress
- 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 MsgChannelOpenInit
- func (*MsgChannelOpenInit) Descriptor() ([]byte, []int)
- func (m *MsgChannelOpenInit) GetChannel() Channel
- func (m *MsgChannelOpenInit) GetChannelID() string
- func (m *MsgChannelOpenInit) GetPortID() string
- func (msg MsgChannelOpenInit) GetSignBytes() []byte
- func (m *MsgChannelOpenInit) GetSigner() github_com_cosmos_cosmos_sdk_types.AccAddress
- 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 MsgChannelOpenTry
- func (*MsgChannelOpenTry) Descriptor() ([]byte, []int)
- func (m *MsgChannelOpenTry) GetChannel() Channel
- func (m *MsgChannelOpenTry) GetChannelID() string
- func (m *MsgChannelOpenTry) GetCounterpartyVersion() string
- func (m *MsgChannelOpenTry) GetPortID() string
- func (m *MsgChannelOpenTry) GetProofHeight() uint64
- func (m *MsgChannelOpenTry) GetProofInit() types.MerkleProof
- func (msg MsgChannelOpenTry) GetSignBytes() []byte
- func (m *MsgChannelOpenTry) GetSigner() github_com_cosmos_cosmos_sdk_types.AccAddress
- 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 MsgPacket
- func (*MsgPacket) Descriptor() ([]byte, []int)
- func (msg MsgPacket) GetDataSignBytes() []byte
- func (m *MsgPacket) GetPacket() Packet
- func (m *MsgPacket) GetProof() types.MerkleProof
- func (m *MsgPacket) GetProofHeight() uint64
- func (msg MsgPacket) GetSignBytes() []byte
- func (m *MsgPacket) GetSigner() github_com_cosmos_cosmos_sdk_types.AccAddress
- func (msg MsgPacket) GetSigners() []sdk.AccAddress
- func (m *MsgPacket) Marshal() (dAtA []byte, err error)
- func (m *MsgPacket) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgPacket) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgPacket) ProtoMessage()
- func (m *MsgPacket) Reset()
- func (msg MsgPacket) Route() string
- func (m *MsgPacket) Size() (n int)
- func (m *MsgPacket) String() string
- func (msg MsgPacket) Type() string
- func (m *MsgPacket) Unmarshal(dAtA []byte) error
- func (msg MsgPacket) ValidateBasic() error
- func (m *MsgPacket) XXX_DiscardUnknown()
- func (m *MsgPacket) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgPacket) XXX_Merge(src proto.Message)
- func (m *MsgPacket) XXX_Size() int
- func (m *MsgPacket) XXX_Unmarshal(b []byte) error
- type MsgTimeout
- func (*MsgTimeout) Descriptor() ([]byte, []int)
- func (m *MsgTimeout) GetNextSequenceRecv() uint64
- func (m *MsgTimeout) GetPacket() Packet
- func (m *MsgTimeout) GetProof() types.MerkleProof
- func (m *MsgTimeout) GetProofHeight() uint64
- func (msg MsgTimeout) GetSignBytes() []byte
- func (m *MsgTimeout) GetSigner() github_com_cosmos_cosmos_sdk_types.AccAddress
- 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 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() uint64
- 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 PacketAckCommitment
- type PacketResponse
- type PacketSequence
- type PortKeeper
- type QueryAllChannelsParams
- type QueryConnectionChannelsParams
- type RecvResponse
- type State
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" EventTypeAcknowledgePacket = "acknowledge_packet" EventTypeCleanupPacket = "cleanup_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" )
IBC channel events
const ( // SubModuleName defines the IBC channels name SubModuleName = "channels" // StoreKey is the store key string for IBC channels StoreKey = SubModuleName // RouterKey is the message route for IBC channels RouterKey = SubModuleName // QuerierRoute is the querier route for IBC channels QuerierRoute = SubModuleName )
const ( QueryAllChannels = "channels" QueryChannel = "channel" QueryConnectionChannels = "connection-channels" )
query routes supported by the IBC channel Querier
Variables ¶
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") ErrInvalidPacket = sdkerrors.Register(SubModuleName, 12, "invalid packet") ErrPacketTimeout = sdkerrors.Register(SubModuleName, 13, "packet timeout") ErrTooManyConnectionHops = sdkerrors.Register(SubModuleName, 14, "too many connection hops") ErrAcknowledgementTooLong = sdkerrors.Register(SubModuleName, 15, "acknowledgement too long") )
IBC 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) )
IBC channel events vars
var ( ErrInvalidLengthTypes = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowTypes = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupTypes = fmt.Errorf("proto: unexpected end of group") )
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 references the global x/ibc/04-channel module codec. Note, the codec should // ONLY be used in certain instances of tests and for JSON encoding as Amino is // still used for that purpose. // // The actual codec used for serialization should be provided to x/ibc/04-channel and // defined at the application level. SubModuleCdc = codec.NewHybridCodec(amino, cdctypes.NewInterfaceRegistry()) )
Functions ¶
func CommitAcknowledgement ¶
CommitAcknowledgement returns the hash of commitment bytes
func CommitPacket ¶
CommitPacket return the hash of commitment bytes TODO: no specification for packet commitment currently, make it spec compatible once we have it
func RegisterCodec ¶
RegisterCodec registers the necessary x/ibc/04-channel interfaces and concrete types on the provided Amino codec. These types are used for Amino JSON serialization.
func RegisterInterfaces ¶
func RegisterInterfaces(registry cdctypes.InterfaceRegistry)
RegisterInterfaces register the ibc channel submodule interfaces to protobuf Any.
Types ¶
type Channel ¶
type Channel struct { // current state of the channel end State State `protobuf:"varint,1,opt,name=state,proto3,enum=cosmos_sdk.x.ibc.channel.v1.State" json:"state,omitempty"` // whether the channel is ordered or unordered Ordering Order `protobuf:"varint,2,opt,name=ordering,proto3,enum=cosmos_sdk.x.ibc.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.CounterpartyI
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 ChannelResponse ¶
type ChannelResponse struct { Channel IdentifiedChannel `json:"channel" yaml:"channel"` Proof commitmenttypes.MerkleProof `json:"proof,omitempty" yaml:"proof,omitempty"` ProofPath commitmenttypes.MerklePath `json:"proof_path,omitempty" yaml:"proof_path,omitempty"` ProofHeight uint64 `json:"proof_height,omitempty" yaml:"proof_height,omitempty"` }
ChannelResponse defines the client query response for a channel which also includes a proof,its path and the height from which the proof was retrieved.
func NewChannelResponse ¶
func NewChannelResponse( portID, channelID string, channel Channel, proof *merkle.Proof, height int64, ) ChannelResponse
NewChannelResponse creates a new ChannelResponse instance
type ClientKeeper ¶
type ClientKeeper interface {
GetClientState(ctx sdk.Context, clientID string) (clientexported.ClientState, bool)
}
ClientKeeper expected account IBC client keeper
type ConnectionKeeper ¶
type ConnectionKeeper interface { GetConnection(ctx sdk.Context, connectionID string) (connectiontypes.ConnectionEnd, bool) GetTimestampAtHeight( ctx sdk.Context, connection connectiontypes.ConnectionEnd, height uint64, ) (uint64, error) VerifyChannelState( ctx sdk.Context, connection connectionexported.ConnectionI, height uint64, proof commitmentexported.Proof, portID, channelID string, channel exported.ChannelI, ) error VerifyPacketCommitment( ctx sdk.Context, connection connectionexported.ConnectionI, height uint64, proof commitmentexported.Proof, portID, channelID string, sequence uint64, commitmentBytes []byte, ) error VerifyPacketAcknowledgement( ctx sdk.Context, connection connectionexported.ConnectionI, height uint64, proof commitmentexported.Proof, portID, channelID string, sequence uint64, acknowledgement []byte, ) error VerifyPacketAcknowledgementAbsence( ctx sdk.Context, connection connectionexported.ConnectionI, height uint64, proof commitmentexported.Proof, portID, channelID string, sequence uint64, ) error VerifyNextSequenceRecv( ctx sdk.Context, connection connectionexported.ConnectionI, height uint64, proof commitmentexported.Proof, portID, channelID string, nextSequenceRecv uint64, ) error }
ConnectionKeeper expected account IBC 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 CounterpartyI interface
func (Counterparty) GetPortID ¶
func (c Counterparty) GetPortID() string
GetPortID implements CounterpartyI 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 `json:"channels" yaml:"channels"` Acknowledgements []PacketAckCommitment `json:"acknowledgements" yaml:"acknowledgements"` Commitments []PacketAckCommitment `json:"commitments" yaml:"commitments"` SendSequences []PacketSequence `json:"send_sequences" yaml:"send_sequences"` RecvSequences []PacketSequence `json:"recv_sequences" yaml:"recv_sequences"` }
GenesisState defines the ibc channel submodule's genesis state.
func DefaultGenesisState ¶
func DefaultGenesisState() GenesisState
DefaultGenesisState returns the ibc channel submodule's default genesis state.
func NewGenesisState ¶
func NewGenesisState( channels []IdentifiedChannel, acks, commitments []PacketAckCommitment, sendSeqs, recvSeqs []PacketSequence, ) GenesisState
NewGenesisState creates a GenesisState instance.
func (GenesisState) Validate ¶
func (gs GenesisState) Validate() error
Validate performs basic genesis state validation returning an error upon any failure.
type IdentifiedChannel ¶
type IdentifiedChannel struct { ID string `json:"id" yaml:"id"` PortID string `json:"port_id" yaml:"port_id"` State State `json:"state" yaml:"state"` Ordering Order `json:"ordering" yaml:"ordering"` Counterparty Counterparty `json:"counterparty" yaml:"counterparty"` ConnectionHops []string `json:"connection_hops" yaml:"connection_hops"` Version string `json:"version" yaml:"version "` }
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) ValidateBasic ¶
func (ic IdentifiedChannel) ValidateBasic() error
ValidateBasic performs a basic validation of the identifiers and channel fields.
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"` Proof types.MerkleProof `protobuf:"bytes,3,opt,name=proof,proto3" json:"proof"` ProofHeight uint64 `protobuf:"varint,4,opt,name=proof_height,json=proofHeight,proto3" json:"proof_height,omitempty" yaml:"proof_height"` Signer github_com_cosmos_cosmos_sdk_types.AccAddress `protobuf:"bytes,5,opt,name=signer,proto3,casttype=github.com/cosmos/cosmos-sdk/types.AccAddress" json:"signer,omitempty"` }
MsgAcknowledgement receives incoming IBC acknowledgement
func NewMsgAcknowledgement ¶
func NewMsgAcknowledgement( packet Packet, ack []byte, proof commitmenttypes.MerkleProof, proofHeight uint64, signer sdk.AccAddress) MsgAcknowledgement
NewMsgAcknowledgement constructs a new MsgAcknowledgement
func (*MsgAcknowledgement) Descriptor ¶
func (*MsgAcknowledgement) Descriptor() ([]byte, []int)
func (*MsgAcknowledgement) GetAcknowledgement ¶
func (m *MsgAcknowledgement) GetAcknowledgement() []byte
func (*MsgAcknowledgement) GetPacket ¶
func (m *MsgAcknowledgement) GetPacket() Packet
func (*MsgAcknowledgement) GetProof ¶
func (m *MsgAcknowledgement) GetProof() types.MerkleProof
func (*MsgAcknowledgement) GetProofHeight ¶
func (m *MsgAcknowledgement) GetProofHeight() uint64
func (MsgAcknowledgement) GetSignBytes ¶
func (msg MsgAcknowledgement) GetSignBytes() []byte
GetSignBytes implements sdk.Msg
func (*MsgAcknowledgement) GetSigner ¶
func (m *MsgAcknowledgement) GetSigner() github_com_cosmos_cosmos_sdk_types.AccAddress
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 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 types.MerkleProof `protobuf:"bytes,3,opt,name=proof_init,json=proofInit,proto3" json:"proof_init" yaml:"proof_init"` ProofHeight uint64 `protobuf:"varint,4,opt,name=proof_height,json=proofHeight,proto3" json:"proof_height,omitempty" yaml:"proof_height"` Signer github_com_cosmos_cosmos_sdk_types.AccAddress `protobuf:"bytes,5,opt,name=signer,proto3,casttype=github.com/cosmos/cosmos-sdk/types.AccAddress" 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 commitmenttypes.MerkleProof, proofHeight uint64, signer sdk.AccAddress, ) MsgChannelCloseConfirm
NewMsgChannelCloseConfirm creates a new MsgChannelCloseConfirm instance
func (*MsgChannelCloseConfirm) Descriptor ¶
func (*MsgChannelCloseConfirm) Descriptor() ([]byte, []int)
func (*MsgChannelCloseConfirm) GetChannelID ¶
func (m *MsgChannelCloseConfirm) GetChannelID() string
func (*MsgChannelCloseConfirm) GetPortID ¶
func (m *MsgChannelCloseConfirm) GetPortID() string
func (*MsgChannelCloseConfirm) GetProofHeight ¶
func (m *MsgChannelCloseConfirm) GetProofHeight() uint64
func (*MsgChannelCloseConfirm) GetProofInit ¶
func (m *MsgChannelCloseConfirm) GetProofInit() types.MerkleProof
func (MsgChannelCloseConfirm) GetSignBytes ¶
func (msg MsgChannelCloseConfirm) GetSignBytes() []byte
GetSignBytes implements sdk.Msg
func (*MsgChannelCloseConfirm) GetSigner ¶
func (m *MsgChannelCloseConfirm) GetSigner() github_com_cosmos_cosmos_sdk_types.AccAddress
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 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 github_com_cosmos_cosmos_sdk_types.AccAddress `protobuf:"bytes,3,opt,name=signer,proto3,casttype=github.com/cosmos/cosmos-sdk/types.AccAddress" json:"signer,omitempty"` }
MsgChannelOpenConfirm 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
func (*MsgChannelCloseInit) Descriptor ¶
func (*MsgChannelCloseInit) Descriptor() ([]byte, []int)
func (*MsgChannelCloseInit) GetChannelID ¶
func (m *MsgChannelCloseInit) GetChannelID() string
func (*MsgChannelCloseInit) GetPortID ¶
func (m *MsgChannelCloseInit) GetPortID() string
func (MsgChannelCloseInit) GetSignBytes ¶
func (msg MsgChannelCloseInit) GetSignBytes() []byte
GetSignBytes implements sdk.Msg
func (*MsgChannelCloseInit) GetSigner ¶
func (m *MsgChannelCloseInit) GetSigner() github_com_cosmos_cosmos_sdk_types.AccAddress
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 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"` CounterpartyVersion string `` /* 146-byte string literal not displayed */ ProofTry types.MerkleProof `protobuf:"bytes,4,opt,name=proof_try,json=proofTry,proto3" json:"proof_try" yaml:"proof_try"` ProofHeight uint64 `protobuf:"varint,5,opt,name=proof_height,json=proofHeight,proto3" json:"proof_height,omitempty" yaml:"proof_height"` Signer github_com_cosmos_cosmos_sdk_types.AccAddress `protobuf:"bytes,6,opt,name=signer,proto3,casttype=github.com/cosmos/cosmos-sdk/types.AccAddress" 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 string, cpv string, proofTry commitmenttypes.MerkleProof, proofHeight uint64, signer sdk.AccAddress, ) MsgChannelOpenAck
NewMsgChannelOpenAck creates a new MsgChannelOpenAck instance
func (*MsgChannelOpenAck) Descriptor ¶
func (*MsgChannelOpenAck) Descriptor() ([]byte, []int)
func (*MsgChannelOpenAck) GetChannelID ¶
func (m *MsgChannelOpenAck) GetChannelID() string
func (*MsgChannelOpenAck) GetCounterpartyVersion ¶
func (m *MsgChannelOpenAck) GetCounterpartyVersion() string
func (*MsgChannelOpenAck) GetPortID ¶
func (m *MsgChannelOpenAck) GetPortID() string
func (*MsgChannelOpenAck) GetProofHeight ¶
func (m *MsgChannelOpenAck) GetProofHeight() uint64
func (*MsgChannelOpenAck) GetProofTry ¶
func (m *MsgChannelOpenAck) GetProofTry() types.MerkleProof
func (MsgChannelOpenAck) GetSignBytes ¶
func (msg MsgChannelOpenAck) GetSignBytes() []byte
GetSignBytes implements sdk.Msg
func (*MsgChannelOpenAck) GetSigner ¶
func (m *MsgChannelOpenAck) GetSigner() github_com_cosmos_cosmos_sdk_types.AccAddress
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 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 types.MerkleProof `protobuf:"bytes,3,opt,name=proof_ack,json=proofAck,proto3" json:"proof_ack" yaml:"proof_ack"` ProofHeight uint64 `protobuf:"varint,4,opt,name=proof_height,json=proofHeight,proto3" json:"proof_height,omitempty" yaml:"proof_height"` Signer github_com_cosmos_cosmos_sdk_types.AccAddress `protobuf:"bytes,5,opt,name=signer,proto3,casttype=github.com/cosmos/cosmos-sdk/types.AccAddress" 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 commitmenttypes.MerkleProof, proofHeight uint64, signer sdk.AccAddress, ) MsgChannelOpenConfirm
NewMsgChannelOpenConfirm creates a new MsgChannelOpenConfirm instance
func (*MsgChannelOpenConfirm) Descriptor ¶
func (*MsgChannelOpenConfirm) Descriptor() ([]byte, []int)
func (*MsgChannelOpenConfirm) GetChannelID ¶
func (m *MsgChannelOpenConfirm) GetChannelID() string
func (*MsgChannelOpenConfirm) GetPortID ¶
func (m *MsgChannelOpenConfirm) GetPortID() string
func (*MsgChannelOpenConfirm) GetProofAck ¶
func (m *MsgChannelOpenConfirm) GetProofAck() types.MerkleProof
func (*MsgChannelOpenConfirm) GetProofHeight ¶
func (m *MsgChannelOpenConfirm) GetProofHeight() uint64
func (MsgChannelOpenConfirm) GetSignBytes ¶
func (msg MsgChannelOpenConfirm) GetSignBytes() []byte
GetSignBytes implements sdk.Msg
func (*MsgChannelOpenConfirm) GetSigner ¶
func (m *MsgChannelOpenConfirm) GetSigner() github_com_cosmos_cosmos_sdk_types.AccAddress
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 MsgChannelOpenInit ¶
type MsgChannelOpenInit 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"` Channel Channel `protobuf:"bytes,3,opt,name=channel,proto3" json:"channel"` Signer github_com_cosmos_cosmos_sdk_types.AccAddress `protobuf:"bytes,4,opt,name=signer,proto3,casttype=github.com/cosmos/cosmos-sdk/types.AccAddress" 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, channelID string, version string, channelOrder Order, connectionHops []string, counterpartyPortID, counterpartyChannelID string, signer sdk.AccAddress, ) MsgChannelOpenInit
NewMsgChannelOpenInit creates a new MsgChannelCloseInit MsgChannelOpenInit
func (*MsgChannelOpenInit) Descriptor ¶
func (*MsgChannelOpenInit) Descriptor() ([]byte, []int)
func (*MsgChannelOpenInit) GetChannel ¶
func (m *MsgChannelOpenInit) GetChannel() Channel
func (*MsgChannelOpenInit) GetChannelID ¶
func (m *MsgChannelOpenInit) GetChannelID() string
func (*MsgChannelOpenInit) GetPortID ¶
func (m *MsgChannelOpenInit) GetPortID() string
func (MsgChannelOpenInit) GetSignBytes ¶
func (msg MsgChannelOpenInit) GetSignBytes() []byte
GetSignBytes implements sdk.Msg
func (*MsgChannelOpenInit) GetSigner ¶
func (m *MsgChannelOpenInit) GetSigner() github_com_cosmos_cosmos_sdk_types.AccAddress
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 MsgChannelOpenTry ¶
type MsgChannelOpenTry 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"` Channel Channel `protobuf:"bytes,3,opt,name=channel,proto3" json:"channel"` CounterpartyVersion string `` /* 146-byte string literal not displayed */ ProofInit types.MerkleProof `protobuf:"bytes,5,opt,name=proof_init,json=proofInit,proto3" json:"proof_init" yaml:"proof_init"` ProofHeight uint64 `protobuf:"varint,6,opt,name=proof_height,json=proofHeight,proto3" json:"proof_height,omitempty" yaml:"proof_height"` Signer github_com_cosmos_cosmos_sdk_types.AccAddress `protobuf:"bytes,7,opt,name=signer,proto3,casttype=github.com/cosmos/cosmos-sdk/types.AccAddress" 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, channelID, version string, channelOrder Order, connectionHops []string, counterpartyPortID, counterpartyChannelID, counterpartyVersion string, proofInit commitmenttypes.MerkleProof, proofHeight uint64, signer sdk.AccAddress, ) MsgChannelOpenTry
NewMsgChannelOpenTry creates a new MsgChannelOpenTry instance
func (*MsgChannelOpenTry) Descriptor ¶
func (*MsgChannelOpenTry) Descriptor() ([]byte, []int)
func (*MsgChannelOpenTry) GetChannel ¶
func (m *MsgChannelOpenTry) GetChannel() Channel
func (*MsgChannelOpenTry) GetChannelID ¶
func (m *MsgChannelOpenTry) GetChannelID() string
func (*MsgChannelOpenTry) GetCounterpartyVersion ¶
func (m *MsgChannelOpenTry) GetCounterpartyVersion() string
func (*MsgChannelOpenTry) GetPortID ¶
func (m *MsgChannelOpenTry) GetPortID() string
func (*MsgChannelOpenTry) GetProofHeight ¶
func (m *MsgChannelOpenTry) GetProofHeight() uint64
func (*MsgChannelOpenTry) GetProofInit ¶
func (m *MsgChannelOpenTry) GetProofInit() types.MerkleProof
func (MsgChannelOpenTry) GetSignBytes ¶
func (msg MsgChannelOpenTry) GetSignBytes() []byte
GetSignBytes implements sdk.Msg
func (*MsgChannelOpenTry) GetSigner ¶
func (m *MsgChannelOpenTry) GetSigner() github_com_cosmos_cosmos_sdk_types.AccAddress
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 MsgPacket ¶
type MsgPacket struct { Packet Packet `protobuf:"bytes,1,opt,name=packet,proto3" json:"packet"` Proof types.MerkleProof `protobuf:"bytes,2,opt,name=proof,proto3" json:"proof"` ProofHeight uint64 `protobuf:"varint,3,opt,name=proof_height,json=proofHeight,proto3" json:"proof_height,omitempty" yaml:"proof_height"` Signer github_com_cosmos_cosmos_sdk_types.AccAddress `protobuf:"bytes,4,opt,name=signer,proto3,casttype=github.com/cosmos/cosmos-sdk/types.AccAddress" json:"signer,omitempty"` }
MsgPacket receives incoming IBC packet
func NewMsgPacket ¶
func NewMsgPacket( packet Packet, proof commitmenttypes.MerkleProof, proofHeight uint64, signer sdk.AccAddress, ) MsgPacket
NewMsgPacket constructs new MsgPacket
func (*MsgPacket) Descriptor ¶
func (MsgPacket) GetDataSignBytes ¶
GetDataSignBytes returns the base64-encoded bytes used for the data field when signing the packet.
func (*MsgPacket) GetProof ¶
func (m *MsgPacket) GetProof() types.MerkleProof
func (*MsgPacket) GetProofHeight ¶
func (MsgPacket) GetSignBytes ¶
GetSignBytes implements sdk.Msg
func (*MsgPacket) GetSigner ¶
func (m *MsgPacket) GetSigner() github_com_cosmos_cosmos_sdk_types.AccAddress
func (MsgPacket) GetSigners ¶
func (msg MsgPacket) GetSigners() []sdk.AccAddress
GetSigners implements sdk.Msg
func (*MsgPacket) MarshalToSizedBuffer ¶
func (*MsgPacket) ProtoMessage ¶
func (*MsgPacket) ProtoMessage()
func (MsgPacket) ValidateBasic ¶
ValidateBasic implements sdk.Msg
func (*MsgPacket) XXX_DiscardUnknown ¶
func (m *MsgPacket) XXX_DiscardUnknown()
func (*MsgPacket) XXX_Marshal ¶
func (*MsgPacket) XXX_Unmarshal ¶
type MsgTimeout ¶
type MsgTimeout struct { Packet Packet `protobuf:"bytes,1,opt,name=packet,proto3" json:"packet"` Proof types.MerkleProof `protobuf:"bytes,2,opt,name=proof,proto3" json:"proof"` ProofHeight uint64 `protobuf:"varint,3,opt,name=proof_height,json=proofHeight,proto3" json:"proof_height,omitempty" yaml:"proof_height"` NextSequenceRecv uint64 `` /* 138-byte string literal not displayed */ Signer github_com_cosmos_cosmos_sdk_types.AccAddress `protobuf:"bytes,5,opt,name=signer,proto3,casttype=github.com/cosmos/cosmos-sdk/types.AccAddress" json:"signer,omitempty"` }
MsgTimeout receives timed-out packet
func NewMsgTimeout ¶
func NewMsgTimeout( packet Packet, nextSequenceRecv uint64, proof commitmenttypes.MerkleProof, proofHeight uint64, signer sdk.AccAddress, ) MsgTimeout
NewMsgTimeout constructs new MsgTimeout
func (*MsgTimeout) Descriptor ¶
func (*MsgTimeout) Descriptor() ([]byte, []int)
func (*MsgTimeout) GetNextSequenceRecv ¶
func (m *MsgTimeout) GetNextSequenceRecv() uint64
func (*MsgTimeout) GetPacket ¶
func (m *MsgTimeout) GetPacket() Packet
func (*MsgTimeout) GetProof ¶
func (m *MsgTimeout) GetProof() types.MerkleProof
func (*MsgTimeout) GetProofHeight ¶
func (m *MsgTimeout) GetProofHeight() uint64
func (MsgTimeout) GetSignBytes ¶
func (msg MsgTimeout) GetSignBytes() []byte
GetSignBytes implements sdk.Msg
func (*MsgTimeout) GetSigner ¶
func (m *MsgTimeout) GetSigner() github_com_cosmos_cosmos_sdk_types.AccAddress
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 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 uint64 `protobuf:"varint,7,opt,name=timeout_height,json=timeoutHeight,proto3" json:"timeout_height,omitempty" 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 IBC
func NewPacket ¶
func NewPacket( data []byte, sequence uint64, sourcePort, sourceChannel, destinationPort, destinationChannel string, timeoutHeight uint64, 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 PacketAckCommitment ¶
type PacketAckCommitment struct { PortID string `json:"port_id" yaml:"port_id"` ChannelID string `json:"channel_id" yaml:"channel_id"` Sequence uint64 `json:"sequence" yaml:"sequence"` Hash []byte `json:"hash" yaml:"hash"` }
PacketAckCommitment defines the genesis type necessary to retrieve and store acknowlegements.
func NewPacketAckCommitment ¶
func NewPacketAckCommitment(portID, channelID string, seq uint64, hash []byte) PacketAckCommitment
NewPacketAckCommitment creates a new PacketAckCommitment instance.
func (PacketAckCommitment) Validate ¶
func (pa PacketAckCommitment) Validate() error
Validate performs basic validation of fields returning an error upon any failure.
type PacketResponse ¶
type PacketResponse struct { Packet Packet `json:"packet" yaml:"packet"` Proof commitmenttypes.MerkleProof `json:"proof,omitempty" yaml:"proof,omitempty"` ProofPath commitmenttypes.MerklePath `json:"proof_path,omitempty" yaml:"proof_path,omitempty"` ProofHeight uint64 `json:"proof_height,omitempty" yaml:"proof_height,omitempty"` }
PacketResponse defines the client query response for a packet which also includes a proof, its path and the height form which the proof was retrieved
func NewPacketResponse ¶
func NewPacketResponse( portID, channelID string, sequence uint64, packet Packet, proof *merkle.Proof, height int64, ) PacketResponse
NewPacketResponse creates a new PacketResponswe instance
type PacketSequence ¶
type PacketSequence struct { PortID string `json:"port_id" yaml:"port_id"` ChannelID string `json:"channel_id" yaml:"channel_id"` Sequence uint64 `json:"sequence" yaml:"sequence"` }
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) Validate ¶
func (ps PacketSequence) Validate() error
Validate performs basic validation of fields returning an error upon any failure.
type PortKeeper ¶
type PortKeeper interface {
Authenticate(ctx sdk.Context, key *capability.Capability, portID string) bool
}
PortKeeper expected account IBC port keeper
type QueryAllChannelsParams ¶
type QueryAllChannelsParams struct { Page int `json:"page" yaml:"page"` Limit int `json:"limit" yaml:"limit"` }
QueryAllChannelsParams defines the parameters necessary for querying for all channels.
func NewQueryAllChannelsParams ¶
func NewQueryAllChannelsParams(page, limit int) QueryAllChannelsParams
NewQueryAllChannelsParams creates a new QueryAllChannelsParams instance.
type QueryConnectionChannelsParams ¶
type QueryConnectionChannelsParams struct { Connection string `json:"connection" yaml:"connection"` Page int `json:"page" yaml:"page"` Limit int `json:"limit" yaml:"limit"` }
QueryConnectionChannelsParams defines the parameters necessary for querying for all channels associated with a given connection.
func NewQueryConnectionChannelsParams ¶
func NewQueryConnectionChannelsParams(connection string, page, limit int) QueryConnectionChannelsParams
NewQueryConnectionChannelsParams creates a new QueryConnectionChannelsParams instance.
type RecvResponse ¶
type RecvResponse struct { NextSequenceRecv uint64 `json:"next_sequence_recv" yaml:"next_sequence_recv"` Proof commitmenttypes.MerkleProof `json:"proof,omitempty" yaml:"proof,omitempty"` ProofPath commitmenttypes.MerklePath `json:"proof_path,omitempty" yaml:"proof_path,omitempty"` ProofHeight uint64 `json:"proof_height,omitempty" yaml:"proof_height,omitempty"` }
RecvResponse defines the client query response for the next receive sequence number which also includes a proof, its path and the height form which the proof was retrieved
func NewRecvResponse ¶
func NewRecvResponse( portID, channelID string, sequenceRecv uint64, proof *merkle.Proof, height int64, ) RecvResponse
NewRecvResponse creates a new RecvResponse instance
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 )