types

package
v2.5.0 Latest Latest
Warning

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

Go to latest
Published: Nov 7, 2022 License: MIT Imports: 36 Imported by: 24

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source
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"
	EventTypeTimeoutPacketOnClose = "timeout_on_close_packet"

	// NOTE: DEPRECATED in favor of AttributeKeyDataHex
	AttributeKeyData = "packet_data"
	// NOTE: DEPRECATED in favor of AttributeKeyAckHex
	AttributeKeyAck = "packet_ack"

	AttributeKeyDataHex          = "packet_data_hex"
	AttributeKeyAckHex           = "packet_ack_hex"
	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"
)

IBC channel events

View Source
const (
	// SubModuleName defines the IBC channels name
	SubModuleName = "channel"

	// 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

	// 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

View Source
var (
	ErrInvalidLengthChannel        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowChannel          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupChannel = fmt.Errorf("proto: unexpected end of group")
)
View Source
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")
	ErrAcknowledgementExists     = sdkerrors.Register(SubModuleName, 17, "acknowledgement for packet already exists")
	ErrInvalidChannelIdentifier  = sdkerrors.Register(SubModuleName, 18, "invalid channel identifier")

	// packets already relayed errors
	ErrPacketReceived           = sdkerrors.Register(SubModuleName, 19, "packet already received")
	ErrPacketCommitmentNotFound = sdkerrors.Register(SubModuleName, 20, "packet commitment not found") // may occur for already received acknowledgements or timeouts and in rare cases for packets never sent

	// ORDERED channel error
	ErrPacketSequenceOutOfOrder = sdkerrors.Register(SubModuleName, 21, "packet sequence is out of order")

	// Antehandler error
	ErrRedundantTx = sdkerrors.Register(SubModuleName, 22, "packet messages are redundant")

	// Perform a no-op on the current Msg
	ErrNoOpMsg = sdkerrors.Register(SubModuleName, 23, "message is redundant, no-op will be performed")
)

IBC channel sentinel errors

View Source
var (
	EventTypeChannelOpenInit     = "channel_open_init"
	EventTypeChannelOpenTry      = "channel_open_try"
	EventTypeChannelOpenAck      = "channel_open_ack"
	EventTypeChannelOpenConfirm  = "channel_open_confirm"
	EventTypeChannelCloseInit    = "channel_close_init"
	EventTypeChannelCloseConfirm = "channel_close_confirm"
	EventTypeChannelClosed       = "channel_close"

	AttributeValueCategory = fmt.Sprintf("%s_%s", host.ModuleName, SubModuleName)
)

IBC channel events vars

View Source
var (
	ErrInvalidLengthGenesis        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGenesis          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGenesis = fmt.Errorf("proto: unexpected end of group")
)
View Source
var (
	ErrInvalidLengthQuery        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQuery          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group")
)
View Source
var (
	ErrInvalidLengthTx        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTx          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTx = fmt.Errorf("proto: unexpected end of group")
)
View Source
var 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}

View Source
var Order_name = map[int32]string{
	0: "ORDER_NONE_UNSPECIFIED",
	1: "ORDER_UNORDERED",
	2: "ORDER_ORDERED",
}
View Source
var Order_value = map[string]int32{
	"ORDER_NONE_UNSPECIFIED": 0,
	"ORDER_UNORDERED":        1,
	"ORDER_ORDERED":          2,
}
View Source
var State_name = map[int32]string{
	0: "STATE_UNINITIALIZED_UNSPECIFIED",
	1: "STATE_INIT",
	2: "STATE_TRYOPEN",
	3: "STATE_OPEN",
	4: "STATE_CLOSED",
}
View Source
var State_value = map[string]int32{
	"STATE_UNINITIALIZED_UNSPECIFIED": 0,
	"STATE_INIT":                      1,
	"STATE_TRYOPEN":                   2,
	"STATE_OPEN":                      3,
	"STATE_CLOSED":                    4,
}

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

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

Functions

func CommitAcknowledgement

func CommitAcknowledgement(data []byte) []byte

CommitAcknowledgement returns the hash of commitment bytes

func CommitPacket

func CommitPacket(cdc codec.BinaryCodec, 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

func FormatChannelIdentifier(sequence uint64) string

FormatChannelIdentifier returns the channel identifier with the sequence appended. This is a SDK specific format not enforced by IBC protocol.

func IsValidChannelID

func IsValidChannelID(channelID string) bool

IsValidChannelID checks if a channelID is valid and can be parsed to the channel identifier format.

func ParseChannelSequence

func ParseChannelSequence(channelID string) (uint64, error)

ParseChannelSequence parses the channel sequence from the channel identifier.

func RegisterInterfaces

func RegisterInterfaces(registry codectypes.InterfaceRegistry)

RegisterInterfaces register the ibc channel submodule interfaces to protobuf Any.

func RegisterMsgServer

func RegisterMsgServer(s grpc1.Server, srv MsgServer)

func RegisterQueryHandler

func RegisterQueryHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterQueryHandler registers the http handlers for service Query to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterQueryHandlerClient

func RegisterQueryHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryClient) error

RegisterQueryHandlerClient registers the http handlers for service Query to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "QueryClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "QueryClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "QueryClient" to call the correct interceptors.

func RegisterQueryHandlerFromEndpoint

func RegisterQueryHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterQueryHandlerFromEndpoint is same as RegisterQueryHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterQueryHandlerServer

func RegisterQueryHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryServer) error

RegisterQueryHandlerServer registers the http handlers for service Query to "mux". UnaryRPC :call QueryServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features (such as grpc.SendHeader, etc) to stop working. Consider using RegisterQueryHandlerFromEndpoint instead.

func RegisterQueryServer

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

Types

type Acknowledgement

type Acknowledgement struct {
	// response contains either a result or an error and must be non-empty
	//
	// Types that are valid to be assigned to Response:
	//	*Acknowledgement_Result
	//	*Acknowledgement_Error
	Response isAcknowledgement_Response `protobuf_oneof:"response"`
}

Acknowledgement is the recommended acknowledgement format to be used by app-specific protocols. NOTE: The field numbers 21 and 22 were explicitly chosen to avoid accidental conflicts with other protobuf message formats used for acknowledgements. The first byte of any message with this format will be the non-ASCII values `0xaa` (result) or `0xb2` (error). Implemented as defined by ICS: https://github.com/cosmos/ibc/tree/master/spec/core/ics-004-channel-and-packet-semantics#acknowledgement-envelope

func NewErrorAcknowledgement

func NewErrorAcknowledgement(err string) Acknowledgement

NewErrorAcknowledgement returns a new instance of Acknowledgement using an Acknowledgement_Error type in the Response field. NOTE: Acknowledgements are written into state and thus, changes made to error strings included in packet acknowledgements risk an app hash divergence when nodes in a network are running different patch versions of software.

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

func (ack Acknowledgement) Acknowledgement() []byte

Acknowledgement implements the Acknowledgement interface. It returns the acknowledgement serialised using JSON.

func (*Acknowledgement) Descriptor

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

func (*Acknowledgement) GetError

func (m *Acknowledgement) GetError() string

func (*Acknowledgement) GetResponse

func (m *Acknowledgement) GetResponse() isAcknowledgement_Response

func (*Acknowledgement) GetResult

func (m *Acknowledgement) GetResult() []byte

func (*Acknowledgement) Marshal

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

func (*Acknowledgement) MarshalTo

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

func (*Acknowledgement) MarshalToSizedBuffer

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

func (*Acknowledgement) ProtoMessage

func (*Acknowledgement) ProtoMessage()

func (*Acknowledgement) Reset

func (m *Acknowledgement) Reset()

func (*Acknowledgement) Size

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

func (*Acknowledgement) String

func (m *Acknowledgement) String() string

func (Acknowledgement) Success

func (ack Acknowledgement) Success() bool

Success implements the Acknowledgement interface. The acknowledgement is considered successful if it is a ResultAcknowledgement. Otherwise it is considered a failed acknowledgement.

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=ibc.core.channel.v1.State" json:"state,omitempty"`
	// whether the channel is ordered or unordered
	Ordering Order `protobuf:"varint,2,opt,name=ordering,proto3,enum=ibc.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) Descriptor() ([]byte, []int)

func (Channel) GetConnectionHops

func (ch Channel) GetConnectionHops() []string

GetConnectionHops implements Channel interface.

func (Channel) GetCounterparty

func (ch Channel) GetCounterparty() exported.CounterpartyChannelI

GetCounterparty implements Channel interface.

func (Channel) GetOrdering

func (ch Channel) GetOrdering() int32

GetOrdering implements Channel interface.

func (Channel) GetState

func (ch Channel) GetState() int32

GetState implements Channel interface.

func (Channel) GetVersion

func (ch Channel) GetVersion() string

GetVersion implements Channel interface.

func (*Channel) Marshal

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

func (*Channel) MarshalTo

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

func (*Channel) MarshalToSizedBuffer

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

func (*Channel) ProtoMessage

func (*Channel) ProtoMessage()

func (*Channel) Reset

func (m *Channel) Reset()

func (*Channel) Size

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

func (*Channel) String

func (m *Channel) String() string

func (*Channel) Unmarshal

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

func (Channel) ValidateBasic

func (ch Channel) ValidateBasic() error

ValidateBasic performs a basic validation of the channel fields

func (*Channel) XXX_DiscardUnknown

func (m *Channel) XXX_DiscardUnknown()

func (*Channel) XXX_Marshal

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

func (*Channel) XXX_Merge

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

func (*Channel) XXX_Size

func (m *Channel) XXX_Size() int

func (*Channel) XXX_Unmarshal

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

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)
	ClientStore(ctx sdk.Context, clientID string) sdk.KVStore
}

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

func (m *Counterparty) MarshalTo(dAtA []byte) (int, 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 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, 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) MarshalTo

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

func (*GenesisState) MarshalToSizedBuffer

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

func (*GenesisState) ProtoMessage

func (*GenesisState) ProtoMessage()

func (*GenesisState) Reset

func (m *GenesisState) Reset()

func (*GenesisState) Size

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

func (*GenesisState) String

func (m *GenesisState) String() string

func (*GenesisState) Unmarshal

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

func (GenesisState) Validate

func (gs GenesisState) Validate() error

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

func (*GenesisState) XXX_DiscardUnknown

func (m *GenesisState) XXX_DiscardUnknown()

func (*GenesisState) XXX_Marshal

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

func (*GenesisState) XXX_Merge

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

func (*GenesisState) XXX_Size

func (m *GenesisState) XXX_Size() int

func (*GenesisState) XXX_Unmarshal

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

type IdentifiedChannel

type IdentifiedChannel struct {
	// current state of the channel end
	State State `protobuf:"varint,1,opt,name=state,proto3,enum=ibc.core.channel.v1.State" json:"state,omitempty"`
	// whether the channel is ordered or unordered
	Ordering Order `protobuf:"varint,2,opt,name=ordering,proto3,enum=ibc.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 IBC acknowledgement

func NewMsgAcknowledgement

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

NewMsgAcknowledgement constructs a new MsgAcknowledgement nolint:interfacer

func (*MsgAcknowledgement) Descriptor

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

func (MsgAcknowledgement) GetSigners

func (msg MsgAcknowledgement) GetSigners() []sdk.AccAddress

GetSigners implements sdk.Msg

func (*MsgAcknowledgement) Marshal

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

func (*MsgAcknowledgement) MarshalTo

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

func (*MsgAcknowledgement) MarshalToSizedBuffer

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

func (*MsgAcknowledgement) ProtoMessage

func (*MsgAcknowledgement) ProtoMessage()

func (*MsgAcknowledgement) Reset

func (m *MsgAcknowledgement) Reset()

func (*MsgAcknowledgement) Size

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

func (*MsgAcknowledgement) String

func (m *MsgAcknowledgement) String() string

func (*MsgAcknowledgement) Unmarshal

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

func (MsgAcknowledgement) ValidateBasic

func (msg MsgAcknowledgement) ValidateBasic() error

ValidateBasic implements sdk.Msg

func (*MsgAcknowledgement) XXX_DiscardUnknown

func (m *MsgAcknowledgement) XXX_DiscardUnknown()

func (*MsgAcknowledgement) XXX_Marshal

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

func (*MsgAcknowledgement) XXX_Merge

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

func (*MsgAcknowledgement) XXX_Size

func (m *MsgAcknowledgement) XXX_Size() int

func (*MsgAcknowledgement) XXX_Unmarshal

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

type MsgAcknowledgementResponse

type MsgAcknowledgementResponse struct {
}

MsgAcknowledgementResponse defines the Msg/Acknowledgement response type.

func (*MsgAcknowledgementResponse) Descriptor

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

func (*MsgAcknowledgementResponse) Marshal

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

func (*MsgAcknowledgementResponse) MarshalTo

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

func (*MsgAcknowledgementResponse) MarshalToSizedBuffer

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

func (*MsgAcknowledgementResponse) ProtoMessage

func (*MsgAcknowledgementResponse) ProtoMessage()

func (*MsgAcknowledgementResponse) Reset

func (m *MsgAcknowledgementResponse) Reset()

func (*MsgAcknowledgementResponse) Size

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

func (*MsgAcknowledgementResponse) String

func (m *MsgAcknowledgementResponse) String() string

func (*MsgAcknowledgementResponse) Unmarshal

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

func (*MsgAcknowledgementResponse) XXX_DiscardUnknown

func (m *MsgAcknowledgementResponse) XXX_DiscardUnknown()

func (*MsgAcknowledgementResponse) XXX_Marshal

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

func (*MsgAcknowledgementResponse) XXX_Merge

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

func (*MsgAcknowledgementResponse) XXX_Size

func (m *MsgAcknowledgementResponse) XXX_Size() int

func (*MsgAcknowledgementResponse) XXX_Unmarshal

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

type 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 string,
) *MsgChannelCloseConfirm

NewMsgChannelCloseConfirm creates a new MsgChannelCloseConfirm instance nolint:interfacer

func (*MsgChannelCloseConfirm) Descriptor

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

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

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

func (*MsgChannelCloseConfirm) String

func (m *MsgChannelCloseConfirm) String() string

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 (*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 string,
) *MsgChannelCloseInit

NewMsgChannelCloseInit creates a new MsgChannelCloseInit instance nolint:interfacer

func (*MsgChannelCloseInit) Descriptor

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

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

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

func (*MsgChannelCloseInit) String

func (m *MsgChannelCloseInit) String() string

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 string,
) *MsgChannelOpenAck

NewMsgChannelOpenAck creates a new MsgChannelOpenAck instance nolint:interfacer

func (*MsgChannelOpenAck) Descriptor

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

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) 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 string,
) *MsgChannelOpenConfirm

NewMsgChannelOpenConfirm creates a new MsgChannelOpenConfirm instance nolint:interfacer

func (*MsgChannelOpenConfirm) Descriptor

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

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

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

func (*MsgChannelOpenConfirm) String

func (m *MsgChannelOpenConfirm) String() string

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 (*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 string,
) *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) 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) Size

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

func (*MsgChannelOpenInit) String

func (m *MsgChannelOpenInit) String() string

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 string,
) *MsgChannelOpenTry

NewMsgChannelOpenTry creates a new MsgChannelOpenTry instance nolint:interfacer

func (*MsgChannelOpenTry) Descriptor

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

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) 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 IBC packet

func NewMsgRecvPacket

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

NewMsgRecvPacket constructs new MsgRecvPacket nolint:interfacer

func (*MsgRecvPacket) Descriptor

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

func (MsgRecvPacket) GetDataSignBytes

func (msg MsgRecvPacket) GetDataSignBytes() []byte

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

func (MsgRecvPacket) GetSigners

func (msg MsgRecvPacket) GetSigners() []sdk.AccAddress

GetSigners implements sdk.Msg

func (*MsgRecvPacket) Marshal

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

func (*MsgRecvPacket) MarshalTo

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

func (*MsgRecvPacket) MarshalToSizedBuffer

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

func (*MsgRecvPacket) ProtoMessage

func (*MsgRecvPacket) ProtoMessage()

func (*MsgRecvPacket) Reset

func (m *MsgRecvPacket) Reset()

func (*MsgRecvPacket) Size

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

func (*MsgRecvPacket) String

func (m *MsgRecvPacket) String() string

func (*MsgRecvPacket) Unmarshal

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

func (MsgRecvPacket) ValidateBasic

func (msg MsgRecvPacket) ValidateBasic() error

ValidateBasic implements sdk.Msg

func (*MsgRecvPacket) XXX_DiscardUnknown

func (m *MsgRecvPacket) XXX_DiscardUnknown()

func (*MsgRecvPacket) XXX_Marshal

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

func (*MsgRecvPacket) XXX_Merge

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

func (*MsgRecvPacket) XXX_Size

func (m *MsgRecvPacket) XXX_Size() int

func (*MsgRecvPacket) XXX_Unmarshal

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

type MsgRecvPacketResponse

type MsgRecvPacketResponse struct {
}

MsgRecvPacketResponse defines the Msg/RecvPacket response type.

func (*MsgRecvPacketResponse) Descriptor

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

func (*MsgRecvPacketResponse) Marshal

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

func (*MsgRecvPacketResponse) MarshalTo

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

func (*MsgRecvPacketResponse) MarshalToSizedBuffer

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

func (*MsgRecvPacketResponse) ProtoMessage

func (*MsgRecvPacketResponse) ProtoMessage()

func (*MsgRecvPacketResponse) Reset

func (m *MsgRecvPacketResponse) Reset()

func (*MsgRecvPacketResponse) Size

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

func (*MsgRecvPacketResponse) String

func (m *MsgRecvPacketResponse) String() string

func (*MsgRecvPacketResponse) Unmarshal

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

func (*MsgRecvPacketResponse) XXX_DiscardUnknown

func (m *MsgRecvPacketResponse) XXX_DiscardUnknown()

func (*MsgRecvPacketResponse) XXX_Marshal

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

func (*MsgRecvPacketResponse) XXX_Merge

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

func (*MsgRecvPacketResponse) XXX_Size

func (m *MsgRecvPacketResponse) XXX_Size() int

func (*MsgRecvPacketResponse) XXX_Unmarshal

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

type MsgServer

type MsgServer interface {
	// 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 string,
) *MsgTimeout

NewMsgTimeout constructs new MsgTimeout nolint:interfacer

func (*MsgTimeout) Descriptor

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

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

func (m *MsgTimeout) MarshalTo(dAtA []byte) (int, 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 string,
) *MsgTimeoutOnClose

NewMsgTimeoutOnClose constructs new MsgTimeoutOnClose nolint:interfacer

func (*MsgTimeoutOnClose) Descriptor

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

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

const (
	// zero-value for channel ordering
	NONE Order = 0
	// packets can be delivered in any order, which may differ from the order in
	// which they were sent.
	UNORDERED Order = 1
	// packets are delivered exactly in the order which they were sent
	ORDERED Order = 2
)

func (Order) EnumDescriptor

func (Order) EnumDescriptor() ([]byte, []int)

func (Order) String

func (x Order) String() string

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 IBC

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) Descriptor() ([]byte, []int)

func (Packet) GetData

func (p Packet) GetData() []byte

GetData implements PacketI interface

func (Packet) GetDestChannel

func (p Packet) GetDestChannel() string

GetDestChannel implements PacketI interface

func (Packet) GetDestPort

func (p Packet) GetDestPort() string

GetDestPort implements PacketI interface

func (Packet) GetSequence

func (p Packet) GetSequence() uint64

GetSequence implements PacketI interface

func (Packet) GetSourceChannel

func (p Packet) GetSourceChannel() string

GetSourceChannel implements PacketI interface

func (Packet) GetSourcePort

func (p Packet) GetSourcePort() string

GetSourcePort implements PacketI interface

func (Packet) GetTimeoutHeight

func (p Packet) GetTimeoutHeight() exported.Height

GetTimeoutHeight implements PacketI interface

func (Packet) GetTimeoutTimestamp

func (p Packet) GetTimeoutTimestamp() uint64

GetTimeoutTimestamp implements PacketI interface

func (*Packet) Marshal

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

func (*Packet) MarshalTo

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

func (*Packet) MarshalToSizedBuffer

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

func (*Packet) ProtoMessage

func (*Packet) ProtoMessage()

func (*Packet) Reset

func (m *Packet) Reset()

func (*Packet) Size

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

func (*Packet) String

func (m *Packet) String() string

func (*Packet) Unmarshal

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

func (Packet) ValidateBasic

func (p Packet) ValidateBasic() error

ValidateBasic implements PacketI interface

func (*Packet) XXX_DiscardUnknown

func (m *Packet) XXX_DiscardUnknown()

func (*Packet) XXX_Marshal

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

func (*Packet) XXX_Merge

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

func (*Packet) XXX_Size

func (m *Packet) XXX_Size() int

func (*Packet) XXX_Unmarshal

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

type PacketSequence

type PacketSequence struct {
	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) MarshalTo

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

func (*PacketSequence) MarshalToSizedBuffer

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

func (*PacketSequence) ProtoMessage

func (*PacketSequence) ProtoMessage()

func (*PacketSequence) Reset

func (m *PacketSequence) Reset()

func (*PacketSequence) Size

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

func (*PacketSequence) String

func (m *PacketSequence) String() string

func (*PacketSequence) Unmarshal

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

func (PacketSequence) Validate

func (ps PacketSequence) Validate() error

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

func (*PacketSequence) XXX_DiscardUnknown

func (m *PacketSequence) XXX_DiscardUnknown()

func (*PacketSequence) XXX_Marshal

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

func (*PacketSequence) XXX_Merge

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

func (*PacketSequence) XXX_Size

func (m *PacketSequence) XXX_Size() int

func (*PacketSequence) XXX_Unmarshal

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

type PacketState

type PacketState struct {
	// 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) MarshalTo

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

func (*PacketState) MarshalToSizedBuffer

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

func (*PacketState) ProtoMessage

func (*PacketState) ProtoMessage()

func (*PacketState) Reset

func (m *PacketState) Reset()

func (*PacketState) Size

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

func (*PacketState) String

func (m *PacketState) String() string

func (*PacketState) Unmarshal

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

func (PacketState) Validate

func (pa PacketState) Validate() error

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

func (*PacketState) XXX_DiscardUnknown

func (m *PacketState) XXX_DiscardUnknown()

func (*PacketState) XXX_Marshal

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

func (*PacketState) XXX_Merge

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

func (*PacketState) XXX_Size

func (m *PacketState) XXX_Size() int

func (*PacketState) XXX_Unmarshal

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

type PortKeeper

type PortKeeper interface {
	Authenticate(ctx sdk.Context, key *capabilitytypes.Capability, portID string) bool
}

PortKeeper expected account IBC 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 (*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 (*QueryChannelClientStateResponse) Size

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

func (*QueryChannelClientStateResponse) 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 (*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 (*QueryChannelConsensusStateRequest) Size

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

func (*QueryChannelConsensusStateRequest) 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 (*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 (*QueryChannelConsensusStateResponse) Size

func (*QueryChannelConsensusStateResponse) 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 (*QueryChannelConsensusStateResponse) XXX_Size

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