Versions in this module Expand all Collapse all v3 v3.3.3 Apr 19, 2023 Changes in this version + func EmitAcknowledgePacketEvent(ctx sdk.Context, packet exported.PacketI, channel types.Channel) + func EmitChannelCloseConfirmEvent(ctx sdk.Context, portID string, channelID string, channel types.Channel) + func EmitChannelCloseInitEvent(ctx sdk.Context, portID string, channelID string, channel types.Channel) + func EmitChannelClosedEvent(ctx sdk.Context, packet exported.PacketI, channel types.Channel) + func EmitChannelOpenAckEvent(ctx sdk.Context, portID string, channelID string, channel types.Channel) + func EmitChannelOpenConfirmEvent(ctx sdk.Context, portID string, channelID string, channel types.Channel) + func EmitChannelOpenInitEvent(ctx sdk.Context, portID string, channelID string, channel types.Channel) + func EmitChannelOpenTryEvent(ctx sdk.Context, portID string, channelID string, channel types.Channel) + func EmitRecvPacketEvent(ctx sdk.Context, packet exported.PacketI, channel types.Channel) + func EmitSendPacketEvent(ctx sdk.Context, packet exported.PacketI, channel types.Channel, ...) + func EmitTimeoutPacketEvent(ctx sdk.Context, packet exported.PacketI, channel types.Channel) + func EmitWriteAcknowledgementEvent(ctx sdk.Context, packet exported.PacketI, channel types.Channel, ...) + type Keeper struct + func NewKeeper(cdc codec.BinaryCodec, key sdk.StoreKey, clientKeeper types.ClientKeeper, ...) Keeper + func (k Keeper) AcknowledgePacket(ctx sdk.Context, chanCap *capabilitytypes.Capability, packet exported.PacketI, ...) error + func (k Keeper) ChanCloseConfirm(ctx sdk.Context, portID, channelID string, chanCap *capabilitytypes.Capability, ...) error + func (k Keeper) ChanCloseInit(ctx sdk.Context, portID, channelID string, chanCap *capabilitytypes.Capability) error + func (k Keeper) ChanOpenAck(ctx sdk.Context, portID, channelID string, chanCap *capabilitytypes.Capability, ...) error + func (k Keeper) ChanOpenConfirm(ctx sdk.Context, portID, channelID string, chanCap *capabilitytypes.Capability, ...) error + func (k Keeper) ChanOpenInit(ctx sdk.Context, order types.Order, connectionHops []string, portID string, ...) (string, *capabilitytypes.Capability, error) + func (k Keeper) ChanOpenTry(ctx sdk.Context, order types.Order, connectionHops []string, ...) (string, *capabilitytypes.Capability, error) + func (k Keeper) GenerateChannelIdentifier(ctx sdk.Context) string + func (k Keeper) GetAllChannels(ctx sdk.Context) (channels []types.IdentifiedChannel) + func (k Keeper) GetAllPacketAckSeqs(ctx sdk.Context) (seqs []types.PacketSequence) + func (k Keeper) GetAllPacketAcks(ctx sdk.Context) (acks []types.PacketState) + func (k Keeper) GetAllPacketCommitments(ctx sdk.Context) (commitments []types.PacketState) + func (k Keeper) GetAllPacketCommitmentsAtChannel(ctx sdk.Context, portID, channelID string) (commitments []types.PacketState) + func (k Keeper) GetAllPacketReceipts(ctx sdk.Context) (receipts []types.PacketState) + func (k Keeper) GetAllPacketRecvSeqs(ctx sdk.Context) (seqs []types.PacketSequence) + func (k Keeper) GetAllPacketSendSeqs(ctx sdk.Context) (seqs []types.PacketSequence) + func (k Keeper) GetChannel(ctx sdk.Context, portID, channelID string) (types.Channel, bool) + func (k Keeper) GetChannelClientState(ctx sdk.Context, portID, channelID string) (string, exported.ClientState, error) + func (k Keeper) GetChannelConnection(ctx sdk.Context, portID, channelID string) (string, exported.ConnectionI, error) + func (k Keeper) GetConnection(ctx sdk.Context, connectionID string) (exported.ConnectionI, error) + func (k Keeper) GetNextChannelSequence(ctx sdk.Context) uint64 + func (k Keeper) GetNextSequenceAck(ctx sdk.Context, portID, channelID string) (uint64, bool) + func (k Keeper) GetNextSequenceRecv(ctx sdk.Context, portID, channelID string) (uint64, bool) + func (k Keeper) GetNextSequenceSend(ctx sdk.Context, portID, channelID string) (uint64, bool) + func (k Keeper) GetPacketAcknowledgement(ctx sdk.Context, portID, channelID string, sequence uint64) ([]byte, bool) + func (k Keeper) GetPacketCommitment(ctx sdk.Context, portID, channelID string, sequence uint64) []byte + func (k Keeper) GetPacketReceipt(ctx sdk.Context, portID, channelID string, sequence uint64) (string, bool) + func (k Keeper) HasPacketAcknowledgement(ctx sdk.Context, portID, channelID string, sequence uint64) bool + func (k Keeper) HasPacketCommitment(ctx sdk.Context, portID, channelID string, sequence uint64) bool + func (k Keeper) IterateChannels(ctx sdk.Context, cb func(types.IdentifiedChannel) bool) + func (k Keeper) IteratePacketAcknowledgement(ctx sdk.Context, ...) + func (k Keeper) IteratePacketCommitment(ctx sdk.Context, ...) + func (k Keeper) IteratePacketCommitmentAtChannel(ctx sdk.Context, portID, channelID string, ...) + func (k Keeper) IteratePacketReceipt(ctx sdk.Context, ...) + func (k Keeper) IteratePacketSequence(ctx sdk.Context, iterator db.Iterator, ...) + func (k Keeper) Logger(ctx sdk.Context) log.Logger + func (k Keeper) LookupModuleByChannel(ctx sdk.Context, portID, channelID string) (string, *capabilitytypes.Capability, error) + func (k Keeper) RecvPacket(ctx sdk.Context, chanCap *capabilitytypes.Capability, packet exported.PacketI, ...) error + func (k Keeper) SendPacket(ctx sdk.Context, channelCap *capabilitytypes.Capability, ...) error + func (k Keeper) SetChannel(ctx sdk.Context, portID, channelID string, channel types.Channel) + func (k Keeper) SetNextChannelSequence(ctx sdk.Context, sequence uint64) + func (k Keeper) SetNextSequenceAck(ctx sdk.Context, portID, channelID string, sequence uint64) + func (k Keeper) SetNextSequenceRecv(ctx sdk.Context, portID, channelID string, sequence uint64) + func (k Keeper) SetNextSequenceSend(ctx sdk.Context, portID, channelID string, sequence uint64) + func (k Keeper) SetPacketAcknowledgement(ctx sdk.Context, portID, channelID string, sequence uint64, ackHash []byte) + func (k Keeper) SetPacketCommitment(ctx sdk.Context, portID, channelID string, sequence uint64, ...) + func (k Keeper) SetPacketReceipt(ctx sdk.Context, portID, channelID string, sequence uint64) + func (k Keeper) TimeoutExecuted(ctx sdk.Context, chanCap *capabilitytypes.Capability, packet exported.PacketI) error + func (k Keeper) TimeoutOnClose(ctx sdk.Context, chanCap *capabilitytypes.Capability, packet exported.PacketI, ...) error + func (k Keeper) TimeoutPacket(ctx sdk.Context, packet exported.PacketI, proof []byte, ...) error + func (k Keeper) WriteAcknowledgement(ctx sdk.Context, chanCap *capabilitytypes.Capability, packet exported.PacketI, ...) error + func (k Keeper) WriteOpenAckChannel(ctx sdk.Context, ...) + func (k Keeper) WriteOpenConfirmChannel(ctx sdk.Context, portID, channelID string) + func (k Keeper) WriteOpenInitChannel(ctx sdk.Context, portID, channelID string, order types.Order, ...) + func (k Keeper) WriteOpenTryChannel(ctx sdk.Context, portID, channelID string, order types.Order, ...) + func (q Keeper) Channel(c context.Context, req *types.QueryChannelRequest) (*types.QueryChannelResponse, error) + func (q Keeper) ChannelClientState(c context.Context, req *types.QueryChannelClientStateRequest) (*types.QueryChannelClientStateResponse, error) + func (q Keeper) ChannelConsensusState(c context.Context, req *types.QueryChannelConsensusStateRequest) (*types.QueryChannelConsensusStateResponse, error) + func (q Keeper) Channels(c context.Context, req *types.QueryChannelsRequest) (*types.QueryChannelsResponse, error) + func (q Keeper) ConnectionChannels(c context.Context, req *types.QueryConnectionChannelsRequest) (*types.QueryConnectionChannelsResponse, error) + func (q Keeper) NextSequenceReceive(c context.Context, req *types.QueryNextSequenceReceiveRequest) (*types.QueryNextSequenceReceiveResponse, error) + func (q Keeper) PacketAcknowledgement(c context.Context, req *types.QueryPacketAcknowledgementRequest) (*types.QueryPacketAcknowledgementResponse, error) + func (q Keeper) PacketAcknowledgements(c context.Context, req *types.QueryPacketAcknowledgementsRequest) (*types.QueryPacketAcknowledgementsResponse, error) + func (q Keeper) PacketCommitment(c context.Context, req *types.QueryPacketCommitmentRequest) (*types.QueryPacketCommitmentResponse, error) + func (q Keeper) PacketCommitments(c context.Context, req *types.QueryPacketCommitmentsRequest) (*types.QueryPacketCommitmentsResponse, error) + func (q Keeper) PacketReceipt(c context.Context, req *types.QueryPacketReceiptRequest) (*types.QueryPacketReceiptResponse, error) + func (q Keeper) UnreceivedAcks(c context.Context, req *types.QueryUnreceivedAcksRequest) (*types.QueryUnreceivedAcksResponse, error) + func (q Keeper) UnreceivedPackets(c context.Context, req *types.QueryUnreceivedPacketsRequest) (*types.QueryUnreceivedPacketsResponse, error)