keeper

package
v10.3.0 Latest Latest
Warning

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

 Go to latest Published: Jun 6, 2025 License: MIT Imports: 25 Imported by: 62

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Keeper 

type Keeper struct {
	ClientKeeper     *clientkeeper.Keeper
	ClientV2Keeper   *clientv2keeper.Keeper
	ConnectionKeeper *connectionkeeper.Keeper
	ChannelKeeper    *channelkeeper.Keeper
	ChannelKeeperV2  *channelkeeperv2.Keeper
	PortKeeper       *portkeeper.Keeper
	// contains filtered or unexported fields
}

Keeper defines each ICS keeper for IBC

func NewKeeper 

func NewKeeper(
	cdc codec.BinaryCodec, storeService corestore.KVStoreService, paramSpace types.ParamSubspace,
	upgradeKeeper clienttypes.UpgradeKeeper, 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) 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) 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) Codec 

func (k *Keeper) Codec() codec.BinaryCodec

Codec returns the IBC module codec.

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) 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) DeleteClientCreator added in v10.1.0 

func (k *Keeper) DeleteClientCreator(goCtx context.Context, msg *clienttypes.MsgDeleteClientCreator) (*clienttypes.MsgDeleteClientCreatorResponse, error)

DeleteClientCreator defines an rpc handler method for MsgDeleteClientCreator for the 02-client v1 submodule.

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

func (k *Keeper) RegisterCounterparty(goCtx context.Context, msg *clientv2types.MsgRegisterCounterparty) (*clientv2types.MsgRegisterCounterpartyResponse, error)

RegisterCounterparty will register the IBC v2 counterparty info for the given client id it must be called by the same relayer that called CreateClient

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

func (k *Keeper) SetRouterV2(rtr *api.Router)

SetRouterV2 sets the v2 router for the IBC Keeper.

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

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

UpdateClient defines a rpc handler method for MsgUpdateClient.

func (*Keeper) UpdateClientConfig added in v10.1.0 

func (k *Keeper) UpdateClientConfig(goCtx context.Context, msg *clientv2types.MsgUpdateClientConfig) (*clientv2types.MsgUpdateClientConfigResponse, error)

UpdateClientConfig defines an rpc handler method for MsgUpdateClientConfig for the 02-client v2 submodule.

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

type PacketHandler 

type PacketHandler interface {
	RecvPacket(
		ctx sdk.Context,
		packet channeltypes.Packet,
		proof []byte,
		proofHeight exported.Height) (string, error)

	WriteAcknowledgement(
		ctx sdk.Context,
		packet exported.PacketI,
		acknowledgement exported.Acknowledgement,
	) error

	AcknowledgePacket(
		ctx sdk.Context,
		packet channeltypes.Packet,
		acknowledgement []byte,
		proof []byte,
		proofHeight exported.Height,
	) (string, error)

	TimeoutPacket(
		ctx sdk.Context,
		packet channeltypes.Packet,
		proof []byte,
		proofHeight exported.Height,
		nextSequenceRecv uint64,
	) (string, error)
}

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.