keeper

package
v9.1.4 Latest Latest
Warning

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

 Go to latest Published: Jun 7, 2024 License: MIT Imports: 21 Imported by: 3

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Keeper 

type Keeper struct {
	// implements gRPC QueryServer interface
	types.QueryServer

	ClientKeeper     clientkeeper.Keeper
	ConnectionKeeper connectionkeeper.Keeper
	ChannelKeeper    channelkeeper.Keeper
	PortKeeper       *portkeeper.Keeper
	Router           *porttypes.Router
	// contains filtered or unexported fields
}

Keeper defines each ICS keeper for IBC

func NewKeeper 

func NewKeeper(
	cdc codec.BinaryCodec, key storetypes.StoreKey, paramSpace types.ParamSubspace,
	stakingKeeper clienttypes.StakingKeeper, upgradeKeeper clienttypes.UpgradeKeeper,
	scopedKeeper capabilitykeeper.ScopedKeeper, authority string,
) *Keeper

NewKeeper creates a new ibc Keeper

func (Keeper) Acknowledgement 

func (k Keeper) Acknowledgement(goCtx context.Context, msg *channeltypes.MsgAcknowledgement) (*channeltypes.MsgAcknowledgementResponse, error)

Acknowledgement defines a rpc handler method for MsgAcknowledgement.

func (Keeper) Channel 

func (k Keeper) Channel(c context.Context, req *channeltypes.QueryChannelRequest) (*channeltypes.QueryChannelResponse, error)

Channel implements the IBC QueryServer interface

func (Keeper) ChannelClientState 

func (k Keeper) ChannelClientState(c context.Context, req *channeltypes.QueryChannelClientStateRequest) (*channeltypes.QueryChannelClientStateResponse, error)

ChannelClientState implements the IBC QueryServer interface

func (Keeper) ChannelCloseConfirm 

func (k Keeper) ChannelCloseConfirm(goCtx context.Context, msg *channeltypes.MsgChannelCloseConfirm) (*channeltypes.MsgChannelCloseConfirmResponse, error)

ChannelCloseConfirm defines a rpc handler method for MsgChannelCloseConfirm.

func (Keeper) ChannelCloseInit 

func (k Keeper) ChannelCloseInit(goCtx context.Context, msg *channeltypes.MsgChannelCloseInit) (*channeltypes.MsgChannelCloseInitResponse, error)

ChannelCloseInit defines a rpc handler method for MsgChannelCloseInit.

func (Keeper) ChannelConsensusState 

func (k Keeper) ChannelConsensusState(c context.Context, req *channeltypes.QueryChannelConsensusStateRequest) (*channeltypes.QueryChannelConsensusStateResponse, error)

ChannelConsensusState implements the IBC QueryServer interface

func (Keeper) ChannelOpenAck 

func (k Keeper) ChannelOpenAck(goCtx context.Context, msg *channeltypes.MsgChannelOpenAck) (*channeltypes.MsgChannelOpenAckResponse, error)

ChannelOpenAck defines a rpc handler method for MsgChannelOpenAck. ChannelOpenAck will perform 04-channel checks, route to the application callback, and write an OpenAck channel into state upon successful execution.

func (Keeper) ChannelOpenConfirm 

func (k Keeper) ChannelOpenConfirm(goCtx context.Context, msg *channeltypes.MsgChannelOpenConfirm) (*channeltypes.MsgChannelOpenConfirmResponse, error)

ChannelOpenConfirm defines a rpc handler method for MsgChannelOpenConfirm. ChannelOpenConfirm will perform 04-channel checks, route to the application callback, and write an OpenConfirm channel into state upon successful execution.

func (Keeper) ChannelOpenInit 

func (k Keeper) ChannelOpenInit(goCtx context.Context, msg *channeltypes.MsgChannelOpenInit) (*channeltypes.MsgChannelOpenInitResponse, error)

ChannelOpenInit defines a rpc handler method for MsgChannelOpenInit. ChannelOpenInit will perform 04-channel checks, route to the application callback, and write an OpenInit channel into state upon successful execution.

func (Keeper) ChannelOpenTry 

func (k Keeper) ChannelOpenTry(goCtx context.Context, msg *channeltypes.MsgChannelOpenTry) (*channeltypes.MsgChannelOpenTryResponse, error)

ChannelOpenTry defines a rpc handler method for MsgChannelOpenTry. ChannelOpenTry will perform 04-channel checks, route to the application callback, and write an OpenTry channel into state upon successful execution.

func (Keeper) ChannelParams 

func (k Keeper) ChannelParams(c context.Context, req *channeltypes.QueryChannelParamsRequest) (*channeltypes.QueryChannelParamsResponse, error)

ChannelParams implements the IBC QueryServer interface

func (Keeper) ChannelUpgradeAck 

func (k Keeper) ChannelUpgradeAck(goCtx context.Context, msg *channeltypes.MsgChannelUpgradeAck) (*channeltypes.MsgChannelUpgradeAckResponse, error)

ChannelUpgradeAck defines a rpc handler method for MsgChannelUpgradeAck.

func (Keeper) ChannelUpgradeCancel 

func (k Keeper) ChannelUpgradeCancel(goCtx context.Context, msg *channeltypes.MsgChannelUpgradeCancel) (*channeltypes.MsgChannelUpgradeCancelResponse, error)

ChannelUpgradeCancel defines a rpc handler method for MsgChannelUpgradeCancel.

func (Keeper) ChannelUpgradeConfirm 

func (k Keeper) ChannelUpgradeConfirm(goCtx context.Context, msg *channeltypes.MsgChannelUpgradeConfirm) (*channeltypes.MsgChannelUpgradeConfirmResponse, error)

ChannelUpgradeConfirm defines a rpc handler method for MsgChannelUpgradeConfirm.

func (Keeper) ChannelUpgradeInit 

func (k Keeper) ChannelUpgradeInit(goCtx context.Context, msg *channeltypes.MsgChannelUpgradeInit) (*channeltypes.MsgChannelUpgradeInitResponse, error)

ChannelUpgradeInit defines a rpc handler method for MsgChannelUpgradeInit.

func (Keeper) ChannelUpgradeOpen 

func (k Keeper) ChannelUpgradeOpen(goCtx context.Context, msg *channeltypes.MsgChannelUpgradeOpen) (*channeltypes.MsgChannelUpgradeOpenResponse, error)

ChannelUpgradeOpen defines a rpc handler method for MsgChannelUpgradeOpen.

func (Keeper) ChannelUpgradeTimeout 

func (k Keeper) ChannelUpgradeTimeout(goCtx context.Context, msg *channeltypes.MsgChannelUpgradeTimeout) (*channeltypes.MsgChannelUpgradeTimeoutResponse, error)

ChannelUpgradeTimeout defines a rpc handler method for MsgChannelUpgradeTimeout.

func (Keeper) ChannelUpgradeTry 

func (k Keeper) ChannelUpgradeTry(goCtx context.Context, msg *channeltypes.MsgChannelUpgradeTry) (*channeltypes.MsgChannelUpgradeTryResponse, error)

ChannelUpgradeTry defines a rpc handler method for MsgChannelUpgradeTry.

func (Keeper) Channels 

func (k Keeper) Channels(c context.Context, req *channeltypes.QueryChannelsRequest) (*channeltypes.QueryChannelsResponse, error)

Channels implements the IBC QueryServer interface

func (Keeper) ClientConnections 

func (k Keeper) ClientConnections(c context.Context, req *connectiontypes.QueryClientConnectionsRequest) (*connectiontypes.QueryClientConnectionsResponse, error)

ClientConnections implements the IBC QueryServer interface

func (Keeper) ClientParams 

func (k Keeper) ClientParams(c context.Context, req *clienttypes.QueryClientParamsRequest) (*clienttypes.QueryClientParamsResponse, error)

ClientParams implements the IBC QueryServer interface

func (Keeper) ClientState 

func (k Keeper) ClientState(c context.Context, req *clienttypes.QueryClientStateRequest) (*clienttypes.QueryClientStateResponse, error)

ClientState implements the IBC QueryServer interface

func (Keeper) ClientStates 

func (k Keeper) ClientStates(c context.Context, req *clienttypes.QueryClientStatesRequest) (*clienttypes.QueryClientStatesResponse, error)

ClientStates implements the IBC QueryServer interface

func (Keeper) ClientStatus 

func (k Keeper) ClientStatus(c context.Context, req *clienttypes.QueryClientStatusRequest) (*clienttypes.QueryClientStatusResponse, error)

ClientStatus implements the IBC QueryServer interface

func (Keeper) Codec 

func (k Keeper) Codec() codec.BinaryCodec

Codec returns the IBC module codec.

func (Keeper) Connection 

func (k Keeper) Connection(c context.Context, req *connectiontypes.QueryConnectionRequest) (*connectiontypes.QueryConnectionResponse, error)

Connection implements the IBC QueryServer interface

func (Keeper) ConnectionChannels 

func (k Keeper) ConnectionChannels(c context.Context, req *channeltypes.QueryConnectionChannelsRequest) (*channeltypes.QueryConnectionChannelsResponse, error)

ConnectionChannels implements the IBC QueryServer interface

func (Keeper) ConnectionClientState 

func (k Keeper) ConnectionClientState(c context.Context, req *connectiontypes.QueryConnectionClientStateRequest) (*connectiontypes.QueryConnectionClientStateResponse, error)

ConnectionClientState implements the IBC QueryServer interface

func (Keeper) ConnectionConsensusState 

func (k Keeper) ConnectionConsensusState(c context.Context, req *connectiontypes.QueryConnectionConsensusStateRequest) (*connectiontypes.QueryConnectionConsensusStateResponse, error)

ConnectionConsensusState implements the IBC QueryServer interface

func (Keeper) ConnectionOpenAck 

func (k Keeper) ConnectionOpenAck(goCtx context.Context, msg *connectiontypes.MsgConnectionOpenAck) (*connectiontypes.MsgConnectionOpenAckResponse, error)

ConnectionOpenAck defines a rpc handler method for MsgConnectionOpenAck.

func (Keeper) ConnectionOpenConfirm 

func (k Keeper) ConnectionOpenConfirm(goCtx context.Context, msg *connectiontypes.MsgConnectionOpenConfirm) (*connectiontypes.MsgConnectionOpenConfirmResponse, error)

ConnectionOpenConfirm defines a rpc handler method for MsgConnectionOpenConfirm.

func (Keeper) ConnectionOpenInit 

func (k Keeper) ConnectionOpenInit(goCtx context.Context, msg *connectiontypes.MsgConnectionOpenInit) (*connectiontypes.MsgConnectionOpenInitResponse, error)

ConnectionOpenInit defines a rpc handler method for MsgConnectionOpenInit.

func (Keeper) ConnectionOpenTry 

func (k Keeper) ConnectionOpenTry(goCtx context.Context, msg *connectiontypes.MsgConnectionOpenTry) (*connectiontypes.MsgConnectionOpenTryResponse, error)

ConnectionOpenTry defines a rpc handler method for MsgConnectionOpenTry.

func (Keeper) ConnectionParams 

func (k Keeper) ConnectionParams(c context.Context, req *connectiontypes.QueryConnectionParamsRequest) (*connectiontypes.QueryConnectionParamsResponse, error)

ConnectionParams implements the IBC QueryServer interface

func (Keeper) Connections 

func (k Keeper) Connections(c context.Context, req *connectiontypes.QueryConnectionsRequest) (*connectiontypes.QueryConnectionsResponse, error)

Connections implements the IBC QueryServer interface

func (Keeper) ConsensusState 

func (k Keeper) ConsensusState(c context.Context, req *clienttypes.QueryConsensusStateRequest) (*clienttypes.QueryConsensusStateResponse, error)

ConsensusState implements the IBC QueryServer interface

func (Keeper) ConsensusStateHeights 

func (k Keeper) ConsensusStateHeights(c context.Context, req *clienttypes.QueryConsensusStateHeightsRequest) (*clienttypes.QueryConsensusStateHeightsResponse, error)

ConsensusStateHeights implements the IBC QueryServer interface

func (Keeper) ConsensusStates 

func (k Keeper) ConsensusStates(c context.Context, req *clienttypes.QueryConsensusStatesRequest) (*clienttypes.QueryConsensusStatesResponse, error)

ConsensusStates implements the IBC QueryServer interface

func (Keeper) CreateClient 

func (k Keeper) CreateClient(goCtx context.Context, msg *clienttypes.MsgCreateClient) (*clienttypes.MsgCreateClientResponse, error)

CreateClient defines a rpc handler method for MsgCreateClient. NOTE: The raw bytes of the concrete types encoded into protobuf.Any is passed to the client keeper. The 02-client handler will route to the appropriate light client module based on client type and it is the responsibility of the light client module to unmarshal and interpret the proto encoded bytes. Backwards compatibility with older versions of ibc-go is maintained through the light client module reconstructing and encoding the expected concrete type to the protobuf.Any for proof verification.

func (Keeper) GetAuthority 

func (k Keeper) GetAuthority() string

GetAuthority returns the ibc module's authority.

func (Keeper) IBCSoftwareUpgrade 

func (k Keeper) IBCSoftwareUpgrade(goCtx context.Context, msg *clienttypes.MsgIBCSoftwareUpgrade) (*clienttypes.MsgIBCSoftwareUpgradeResponse, error)

IBCSoftwareUpgrade defines a rpc handler method for MsgIBCSoftwareUpgrade.

func (Keeper) NextSequenceReceive 

func (k Keeper) NextSequenceReceive(c context.Context, req *channeltypes.QueryNextSequenceReceiveRequest) (*channeltypes.QueryNextSequenceReceiveResponse, error)

NextSequenceReceive implements the IBC QueryServer interface

func (Keeper) NextSequenceSend 

func (k Keeper) NextSequenceSend(c context.Context, req *channeltypes.QueryNextSequenceSendRequest) (*channeltypes.QueryNextSequenceSendResponse, error)

NextSequenceSend implements the IBC QueryServer interface

func (Keeper) PacketAcknowledgement 

func (k Keeper) PacketAcknowledgement(c context.Context, req *channeltypes.QueryPacketAcknowledgementRequest) (*channeltypes.QueryPacketAcknowledgementResponse, error)

PacketAcknowledgement implements the IBC QueryServer interface

func (Keeper) PacketAcknowledgements 

func (k Keeper) PacketAcknowledgements(c context.Context, req *channeltypes.QueryPacketAcknowledgementsRequest) (*channeltypes.QueryPacketAcknowledgementsResponse, error)

PacketAcknowledgements implements the IBC QueryServer interface

func (Keeper) PacketCommitment 

func (k Keeper) PacketCommitment(c context.Context, req *channeltypes.QueryPacketCommitmentRequest) (*channeltypes.QueryPacketCommitmentResponse, error)

PacketCommitment implements the IBC QueryServer interface

func (Keeper) PacketCommitments 

func (k Keeper) PacketCommitments(c context.Context, req *channeltypes.QueryPacketCommitmentsRequest) (*channeltypes.QueryPacketCommitmentsResponse, error)

PacketCommitments implements the IBC QueryServer interface

func (Keeper) PacketReceipt 

func (k Keeper) PacketReceipt(c context.Context, req *channeltypes.QueryPacketReceiptRequest) (*channeltypes.QueryPacketReceiptResponse, error)

PacketReceipt implements the IBC QueryServer interface

func (Keeper) PruneAcknowledgements 

func (k Keeper) PruneAcknowledgements(goCtx context.Context, msg *channeltypes.MsgPruneAcknowledgements) (*channeltypes.MsgPruneAcknowledgementsResponse, error)

PruneAcknowledgements defines a rpc handler method for MsgPruneAcknowledgements.

func (Keeper) RecoverClient 

func (k Keeper) RecoverClient(goCtx context.Context, msg *clienttypes.MsgRecoverClient) (*clienttypes.MsgRecoverClientResponse, error)

RecoverClient defines a rpc handler method for MsgRecoverClient.

func (Keeper) RecvPacket 

func (k Keeper) RecvPacket(goCtx context.Context, msg *channeltypes.MsgRecvPacket) (*channeltypes.MsgRecvPacketResponse, error)

RecvPacket defines a rpc handler method for MsgRecvPacket.

func (*Keeper) SetRouter 

func (k *Keeper) SetRouter(rtr *porttypes.Router)

SetRouter sets the Router in IBC Keeper and seals it. The method panics if there is an existing router that's already sealed.

func (Keeper) SubmitMisbehaviour 

func (k Keeper) SubmitMisbehaviour(goCtx context.Context, msg *clienttypes.MsgSubmitMisbehaviour) (*clienttypes.MsgSubmitMisbehaviourResponse, error)

SubmitMisbehaviour defines a rpc handler method for MsgSubmitMisbehaviour. Warning: DEPRECATED This handler is redundant as `MsgUpdateClient` is now capable of handling both a Header and a Misbehaviour

func (Keeper) Timeout 

func (k Keeper) Timeout(goCtx context.Context, msg *channeltypes.MsgTimeout) (*channeltypes.MsgTimeoutResponse, error)

Timeout defines a rpc handler method for MsgTimeout.

func (Keeper) TimeoutOnClose 

func (k Keeper) TimeoutOnClose(goCtx context.Context, msg *channeltypes.MsgTimeoutOnClose) (*channeltypes.MsgTimeoutOnCloseResponse, error)

TimeoutOnClose defines a rpc handler method for MsgTimeoutOnClose.

func (Keeper) UnreceivedAcks 

func (k Keeper) UnreceivedAcks(c context.Context, req *channeltypes.QueryUnreceivedAcksRequest) (*channeltypes.QueryUnreceivedAcksResponse, error)

UnreceivedAcks implements the IBC QueryServer interface

func (Keeper) UnreceivedPackets 

func (k Keeper) UnreceivedPackets(c context.Context, req *channeltypes.QueryUnreceivedPacketsRequest) (*channeltypes.QueryUnreceivedPacketsResponse, error)

UnreceivedPackets implements the IBC QueryServer interface

func (Keeper) UpdateChannelParams 

func (k Keeper) UpdateChannelParams(goCtx context.Context, msg *channeltypes.MsgUpdateParams) (*channeltypes.MsgUpdateParamsResponse, error)

UpdateChannelParams defines a rpc handler method for MsgUpdateParams.

func (Keeper) UpdateClient 

func (k Keeper) UpdateClient(goCtx context.Context, msg *clienttypes.MsgUpdateClient) (*clienttypes.MsgUpdateClientResponse, error)

UpdateClient defines a rpc handler method for MsgUpdateClient.

func (Keeper) UpdateClientParams 

func (k Keeper) UpdateClientParams(goCtx context.Context, msg *clienttypes.MsgUpdateParams) (*clienttypes.MsgUpdateParamsResponse, error)

UpdateClientParams defines a rpc handler method for MsgUpdateParams.

func (Keeper) UpdateConnectionParams 

func (k Keeper) UpdateConnectionParams(goCtx context.Context, msg *connectiontypes.MsgUpdateParams) (*connectiontypes.MsgUpdateParamsResponse, error)

UpdateConnectionParams defines a rpc handler method for MsgUpdateParams for the 03-connection submodule.

func (Keeper) Upgrade 

func (k Keeper) Upgrade(c context.Context, req *channeltypes.QueryUpgradeRequest) (*channeltypes.QueryUpgradeResponse, error)

Upgrade implements the IBC QueryServer interface

func (Keeper) UpgradeClient 

func (k Keeper) UpgradeClient(goCtx context.Context, msg *clienttypes.MsgUpgradeClient) (*clienttypes.MsgUpgradeClientResponse, error)

UpgradeClient defines a rpc handler method for MsgUpgradeClient. NOTE: The raw bytes of the concrete types encoded into protobuf.Any is passed to the client keeper. The 02-client handler will route to the appropriate light client module based on client identifier and it is the responsibility of the light client module to unmarshal and interpret the proto encoded bytes. Backwards compatibility with older versions of ibc-go is maintained through the light client module reconstructing and encoding the expected concrete type to the protobuf.Any for proof verification.

func (Keeper) UpgradeError 

func (k Keeper) UpgradeError(c context.Context, req *channeltypes.QueryUpgradeErrorRequest) (*channeltypes.QueryUpgradeErrorResponse, error)

UpgradeError implements the IBC QueryServer interface

func (Keeper) UpgradedClientState 

func (k Keeper) UpgradedClientState(c context.Context, req *clienttypes.QueryUpgradedClientStateRequest) (*clienttypes.QueryUpgradedClientStateResponse, error)

UpgradedClientState implements the IBC QueryServer interface

func (Keeper) UpgradedConsensusState 

func (k Keeper) UpgradedConsensusState(c context.Context, req *clienttypes.QueryUpgradedConsensusStateRequest) (*clienttypes.QueryUpgradedConsensusStateResponse, error)

UpgradedConsensusState implements the IBC QueryServer interface

func (Keeper) VerifyMembership 

func (k Keeper) VerifyMembership(c context.Context, req *clienttypes.QueryVerifyMembershipRequest) (*clienttypes.QueryVerifyMembershipResponse, error)

VerifyMembership implements the IBC QueryServer interface.

type Migrator 

type Migrator struct {
	// contains filtered or unexported fields
}

Migrator is a struct for handling in-place store migrations.

func NewMigrator 

func NewMigrator(keeper Keeper) Migrator

NewMigrator returns a new Migrator.

func (Migrator) Migrate2to3 

func (m Migrator) Migrate2to3(ctx sdk.Context) error

Migrate2to3 migrates from version 2 to 3. See 02-client keeper function Migrate2to3.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.