keeper

package
v1.7.0-browser Latest Latest
Warning

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

 Go to latest Published: Apr 12, 2023 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Checkable added in v1.6.7 

type Checkable interface {
	GetIbcEnabled(ctx sdk.Context) bool
}

type FacadedKeeper added in v1.6.7 

type FacadedKeeper struct {
	*common.SelectorStrategy
	V2Keeper *Keeper
}

func NewFacadedKeeper added in v1.6.7 

func NewFacadedKeeper(v2Keeper *Keeper) *FacadedKeeper

func (*FacadedKeeper) Acknowledgement added in v1.6.7 

func (f *FacadedKeeper) Acknowledgement(goCtx context.Context, acknowledgement *channeltyeps.MsgAcknowledgement) (*channeltyeps.MsgAcknowledgementResponse, error)

func (*FacadedKeeper) Channel added in v1.6.7 

func (f *FacadedKeeper) Channel(goCtx context.Context, request *channeltyeps.QueryChannelRequest) (*channeltyeps.QueryChannelResponse, error)

func (*FacadedKeeper) ChannelClientState added in v1.6.7 

func (f *FacadedKeeper) ChannelClientState(goCtx context.Context, request *channeltyeps.QueryChannelClientStateRequest) (*channeltyeps.QueryChannelClientStateResponse, error)

func (*FacadedKeeper) ChannelCloseConfirm added in v1.6.7 

func (f *FacadedKeeper) ChannelCloseConfirm(goCtx context.Context, confirm *channeltyeps.MsgChannelCloseConfirm) (*channeltyeps.MsgChannelCloseConfirmResponse, error)

func (*FacadedKeeper) ChannelCloseInit added in v1.6.7 

func (f *FacadedKeeper) ChannelCloseInit(goCtx context.Context, init *channeltyeps.MsgChannelCloseInit) (*channeltyeps.MsgChannelCloseInitResponse, error)

func (*FacadedKeeper) ChannelConsensusState added in v1.6.7 

func (f *FacadedKeeper) ChannelConsensusState(goCtx context.Context, request *channeltyeps.QueryChannelConsensusStateRequest) (*channeltyeps.QueryChannelConsensusStateResponse, error)

func (*FacadedKeeper) ChannelOpenAck added in v1.6.7 

func (f *FacadedKeeper) ChannelOpenAck(goCtx context.Context, ack *channeltyeps.MsgChannelOpenAck) (*channeltyeps.MsgChannelOpenAckResponse, error)

func (*FacadedKeeper) ChannelOpenConfirm added in v1.6.7 

func (f *FacadedKeeper) ChannelOpenConfirm(goCtx context.Context, confirm *channeltyeps.MsgChannelOpenConfirm) (*channeltyeps.MsgChannelOpenConfirmResponse, error)

func (*FacadedKeeper) ChannelOpenInit added in v1.6.7 

func (f *FacadedKeeper) ChannelOpenInit(goCtx context.Context, init *channeltyeps.MsgChannelOpenInit) (*channeltyeps.MsgChannelOpenInitResponse, error)

func (*FacadedKeeper) ChannelOpenTry added in v1.6.7 

func (f *FacadedKeeper) ChannelOpenTry(goCtx context.Context, try *channeltyeps.MsgChannelOpenTry) (*channeltyeps.MsgChannelOpenTryResponse, error)

func (*FacadedKeeper) Channels added in v1.6.7 

func (f *FacadedKeeper) Channels(goCtx context.Context, request *channeltyeps.QueryChannelsRequest) (*channeltyeps.QueryChannelsResponse, error)

func (*FacadedKeeper) ConnectionChannels added in v1.6.7 

func (f *FacadedKeeper) ConnectionChannels(goCtx context.Context, request *channeltyeps.QueryConnectionChannelsRequest) (*channeltyeps.QueryConnectionChannelsResponse, error)

func (*FacadedKeeper) ConnectionOpenAck added in v1.6.7 

func (f *FacadedKeeper) ConnectionOpenAck(goCtx context.Context, ack *connectiontypes.MsgConnectionOpenAck) (*connectiontypes.MsgConnectionOpenAckResponse, error)

func (*FacadedKeeper) ConnectionOpenConfirm added in v1.6.7 

func (f *FacadedKeeper) ConnectionOpenConfirm(goCtx context.Context, confirm *connectiontypes.MsgConnectionOpenConfirm) (*connectiontypes.MsgConnectionOpenConfirmResponse, error)

func (*FacadedKeeper) ConnectionOpenInit added in v1.6.7 

func (f *FacadedKeeper) ConnectionOpenInit(goCtx context.Context, init *connectiontypes.MsgConnectionOpenInit) (*connectiontypes.MsgConnectionOpenInitResponse, error)

func (*FacadedKeeper) ConnectionOpenTry added in v1.6.7 

func (f *FacadedKeeper) ConnectionOpenTry(goCtx context.Context, try *connectiontypes.MsgConnectionOpenTry) (*connectiontypes.MsgConnectionOpenTryResponse, error)

func (*FacadedKeeper) CreateClient added in v1.6.7 

func (f *FacadedKeeper) CreateClient(goCtx context.Context, client *clienttypes.MsgCreateClient) (*clienttypes.MsgCreateClientResponse, error)

func (*FacadedKeeper) GetIbcEnabled added in v1.6.7 

func (f *FacadedKeeper) GetIbcEnabled(ctx sdk.Context) bool

func (*FacadedKeeper) GetPacketCommitment added in v1.6.7 

func (f *FacadedKeeper) GetPacketCommitment(ctx sdk.Context, portID, channelID string, sequence uint64) []byte

func (*FacadedKeeper) GetPacketReceipt added in v1.6.7 

func (f *FacadedKeeper) GetPacketReceipt(ctx sdk.Context, portID, channelID string, sequence uint64) (string, bool)

func (*FacadedKeeper) NextSequenceReceive added in v1.6.7 

func (f *FacadedKeeper) NextSequenceReceive(goCtx context.Context, request *channeltyeps.QueryNextSequenceReceiveRequest) (*channeltyeps.QueryNextSequenceReceiveResponse, error)

func (*FacadedKeeper) PacketAcknowledgement added in v1.6.7 

func (f *FacadedKeeper) PacketAcknowledgement(goCtx context.Context, request *channeltyeps.QueryPacketAcknowledgementRequest) (*channeltyeps.QueryPacketAcknowledgementResponse, error)

func (*FacadedKeeper) PacketAcknowledgements added in v1.6.7 

func (f *FacadedKeeper) PacketAcknowledgements(goCtx context.Context, request *channeltyeps.QueryPacketAcknowledgementsRequest) (*channeltyeps.QueryPacketAcknowledgementsResponse, error)

func (*FacadedKeeper) PacketCommitment added in v1.6.7 

func (f *FacadedKeeper) PacketCommitment(goCtx context.Context, request *channeltyeps.QueryPacketCommitmentRequest) (*channeltyeps.QueryPacketCommitmentResponse, error)

func (*FacadedKeeper) PacketCommitments added in v1.6.7 

func (f *FacadedKeeper) PacketCommitments(goCtx context.Context, request *channeltyeps.QueryPacketCommitmentsRequest) (*channeltyeps.QueryPacketCommitmentsResponse, error)

func (*FacadedKeeper) PacketReceipt added in v1.6.7 

func (f *FacadedKeeper) PacketReceipt(goCtx context.Context, request *channeltyeps.QueryPacketReceiptRequest) (*channeltyeps.QueryPacketReceiptResponse, error)

func (*FacadedKeeper) RecvPacket added in v1.6.7 

func (f *FacadedKeeper) RecvPacket(goCtx context.Context, packet *channeltyeps.MsgRecvPacket) (*channeltyeps.MsgRecvPacketResponse, error)

func (*FacadedKeeper) RegisterKeeper added in v1.6.7 

func (f *FacadedKeeper) RegisterKeeper(factories ...common.SelectorFactory)

func (*FacadedKeeper) SubmitMisbehaviour added in v1.6.7 

func (f *FacadedKeeper) SubmitMisbehaviour(goCtx context.Context, misbehaviour *clienttypes.MsgSubmitMisbehaviour) (*clienttypes.MsgSubmitMisbehaviourResponse, error)

func (*FacadedKeeper) Timeout added in v1.6.7 

func (f *FacadedKeeper) Timeout(goCtx context.Context, timeout *channeltyeps.MsgTimeout) (*channeltyeps.MsgTimeoutResponse, error)

func (*FacadedKeeper) TimeoutOnClose added in v1.6.7 

func (f *FacadedKeeper) TimeoutOnClose(goCtx context.Context, onClose *channeltyeps.MsgTimeoutOnClose) (*channeltyeps.MsgTimeoutOnCloseResponse, error)

func (*FacadedKeeper) UnreceivedAcks added in v1.6.7 

func (f *FacadedKeeper) UnreceivedAcks(goCtx context.Context, request *channeltyeps.QueryUnreceivedAcksRequest) (*channeltyeps.QueryUnreceivedAcksResponse, error)

func (*FacadedKeeper) UnreceivedPackets added in v1.6.7 

func (f *FacadedKeeper) UnreceivedPackets(goCtx context.Context, request *channeltyeps.QueryUnreceivedPacketsRequest) (*channeltyeps.QueryUnreceivedPacketsResponse, error)

func (*FacadedKeeper) UpdateClient added in v1.6.7 

func (f *FacadedKeeper) UpdateClient(goCtx context.Context, client *clienttypes.MsgUpdateClient) (*clienttypes.MsgUpdateClientResponse, error)

func (*FacadedKeeper) UpgradeClient added in v1.6.7 

func (f *FacadedKeeper) UpgradeClient(goCtx context.Context, client *clienttypes.MsgUpgradeClient) (*clienttypes.MsgUpgradeClientResponse, error)

type IBCServerKeeper added in v1.6.7 

type IBCServerKeeper interface {
	channeltyeps.QueryServer
	channeltyeps.MsgServer
	clienttypes.MsgServer
	connectiontypes.MsgServer

	Checkable

	GetPacketReceipt(ctx sdk.Context, portID, channelID string, sequence uint64) (string, bool)
	GetPacketCommitment(ctx sdk.Context, portID, channelID string, sequence uint64) []byte
}

type Keeper 

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

	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(
	proxy *codec.CodecProxy,
	key sdk.StoreKey, paramSpace paramtypes.Subspace,
	stakingKeeper clienttypes.StakingKeeper, upgradeKeeper clienttypes.UpgradeKeeper,
	scopedKeeper *capabilitykeeper.ScopedKeeper,
	registry types2.InterfaceRegistry,
) *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) AppVersion added in v1.5.4 

func (q Keeper) AppVersion(c context.Context, req *porttypes.QueryAppVersionRequest) (*porttypes.QueryAppVersionResponse, error)

AppVersion implements the IBC QueryServer interface

func (Keeper) Channel 

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

Channel implements the IBC QueryServer interface

func (Keeper) ChannelClientState 

func (q 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 (q 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.

func (Keeper) ChannelOpenConfirm 

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

ChannelOpenConfirm defines a rpc handler method for MsgChannelOpenConfirm.

func (Keeper) ChannelOpenInit 

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

ChannelOpenInit defines a rpc handler method for MsgChannelOpenInit.

func (Keeper) ChannelOpenTry 

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

ChannelOpenTry defines a rpc handler method for MsgChannelOpenTry.

func (Keeper) Channels 

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

Channels implements the IBC QueryServer interface

func (Keeper) ClientConnections 

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

ClientConnections implements the IBC QueryServer interface

func (Keeper) ClientParams 

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

ClientParams implements the IBC QueryServer interface

func (Keeper) ClientState 

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

ClientState implements the IBC QueryServer interface

func (Keeper) ClientStates 

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

ClientStates implements the IBC QueryServer interface

func (Keeper) ClientStatus 

func (q 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.CodecProxy

Codec returns the IBC module codec.

func (Keeper) Connection 

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

Connection implements the IBC QueryServer interface

func (Keeper) ConnectionChannels 

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

ConnectionChannels implements the IBC QueryServer interface

func (Keeper) ConnectionClientState 

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

ConnectionClientState implements the IBC QueryServer interface

func (Keeper) ConnectionConsensusState 

func (q 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) Connections 

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

Connections implements the IBC QueryServer interface

func (Keeper) ConsensusState 

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

ConsensusState implements the IBC QueryServer interface

func (Keeper) ConsensusStateHeights added in v1.6.7 

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

ConsensusStateHeights implements the IBC QueryServer interface

func (Keeper) ConsensusStates 

func (q 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.

func (Keeper) GetIbcEnabled 

func (k Keeper) GetIbcEnabled(ctx sdk.Context) bool

GetIbcEnabled retrieves the ibc enabled boolean from the param store

func (Keeper) GetPacketCommitment added in v1.6.7 

func (k Keeper) GetPacketCommitment(ctx sdk.Context, portID, channelID string, sequence uint64) []byte

func (Keeper) GetPacketReceipt added in v1.6.7 

func (k Keeper) GetPacketReceipt(ctx sdk.Context, portID, channelID string, sequence uint64) (string, bool)

/

func (Keeper) GetParams 

func (k Keeper) GetParams(ctx sdk.Context) types.Params

GetParams returns the total set of ibc parameters.

func (Keeper) IbcParams 

func (q Keeper) IbcParams(c context.Context, req *types.QueryIbcParamsRequest) (*types.QueryIbcParamsResponse, error)

func (Keeper) NextSequenceReceive 

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

NextSequenceReceive implements the IBC QueryServer interface

func (Keeper) PacketAcknowledgement 

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

PacketAcknowledgement implements the IBC QueryServer interface

func (Keeper) PacketAcknowledgements 

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

PacketAcknowledgements implements the IBC QueryServer interface

func (Keeper) PacketCommitment 

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

PacketCommitment implements the IBC QueryServer interface

func (Keeper) PacketCommitments 

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

PacketCommitments implements the IBC QueryServer interface

func (Keeper) PacketReceipt 

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

PacketReceipt implements the IBC QueryServer interface

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

func (k Keeper) SetParams(ctx sdk.Context, params types.Params)

SetParams sets the total set of ibc parameters.

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.

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 (q Keeper) UnreceivedAcks(c context.Context, req *channeltypes.QueryUnreceivedAcksRequest) (*channeltypes.QueryUnreceivedAcksResponse, error)

UnreceivedAcks implements the IBC QueryServer interface

func (Keeper) UnreceivedPackets 

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

UnreceivedPackets implements the IBC QueryServer interface

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

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

UpgradeClient defines a rpc handler method for MsgUpgradeClient.

func (Keeper) UpgradedClientState added in v1.5.4 

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

UpgradedClientState implements the IBC QueryServer interface

func (Keeper) UpgradedConsensusState added in v1.5.4 

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

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

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

Migrate1to2 migrates from version 1 to 2. This migration prunes: - migrates solo machine client state from protobuf definition v1 to v2 - prunes solo machine consensus states - prunes expired tendermint consensus states - adds ProcessedHeight and Iteration keys for unexpired tendermint consensus states

type V4Keeper added in v1.6.7 

type V4Keeper struct {
	*Keeper
}

func NewV4Keeper added in v1.6.7 

func NewV4Keeper(keeper *Keeper) *V4Keeper

func (V4Keeper) Acknowledgement added in v1.6.7 

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

func (V4Keeper) ChannelOpenAck added in v1.6.7 

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

func (V4Keeper) ChannelOpenConfirm added in v1.6.7 

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

func (V4Keeper) ChannelOpenInit added in v1.6.7 

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

func (V4Keeper) ChannelOpenTry added in v1.6.7 

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

func (V4Keeper) ConnectionOpenAck added in v1.6.7 

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

func (V4Keeper) ConnectionOpenTry added in v1.6.7 

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

ConnectionOpenTry defines a rpc handler method for MsgConnectionOpenTry.

func (V4Keeper) RecvPacket added in v1.6.7 

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

RecvPacket defines a rpc handler method for MsgRecvPacket.

func (V4Keeper) Timeout added in v1.6.7 

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

func (V4Keeper) TimeoutOnClose added in v1.6.7 

func (k V4Keeper) TimeoutOnClose(goCtx context.Context, msg *channeltypes.MsgTimeoutOnClose) (*channeltypes.MsgTimeoutOnCloseResponse, 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.