Versions in this module Expand all Collapse all v0 v0.43.1 Oct 28, 2021 Changes in this version + type Keeper struct + func NewKeeper(cdc codec.BinaryMarshaler, 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) CounterpartyHops(ctx sdk.Context, ch types.Channel) ([]string, bool) + 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) 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 (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)