keeper

Documentation

Index

• type Keeper
  • func NewKeeper(m codec.Codec, storeKey sdk.StoreKey, channelKeeper types.ChannelKeeper, ...) Keeper
  • func (k Keeper) ExtSignTx(goCtx context.Context, msg *types.MsgExtSignTx) (*types.MsgExtSignTxResponse, error)
  • func (p Keeper) HandleACK(ctx sdk.Context, packet channeltypes.Packet, ip packets.IncomingPacket, ...) (*sdk.Result, error)
  • func (p Keeper) HandlePacket(ctx sdk.Context, packet channeltypes.Packet, ip packets.IncomingPacket) (*sdk.Result, *packets.PacketAcknowledgementData, error)
  • func (k Keeper) IBCSignTx(goCtx context.Context, msg *types.MsgIBCSignTx) (*types.MsgIBCSignTxResponse, error)
  • func (k Keeper) InitAuthState(ctx sdk.Context, txID crosstypes.TxID, signers []authtypes.Account) error
  • func (k Keeper) IsCompletedAuth(ctx sdk.Context, txID crosstypes.TxID) (bool, error)
  • func (k Keeper) Logger(ctx sdk.Context) log.Logger
  • func (k Keeper) ReceiveIBCSignTx(ctx sdk.Context, destPort, destChannel string, data types.PacketDataIBCSignTx) (completed bool, err error)
  • func (k Keeper) SendIBCSignTx(ctx sdk.Context, packetSender packets.PacketSender, xcc xcctypes.XCC, ...) error
  • func (k *Keeper) SetTxManager(txm types.TxManager)
  • func (k Keeper) Sign(ctx sdk.Context, txID crosstypes.TxID, signers []authtypes.Account) (bool, error)
  • func (k Keeper) SignTx(goCtx context.Context, msg *types.MsgSignTx) (*types.MsgSignTxResponse, error)
  • func (q Keeper) TxAuthState(c context.Context, req *types.QueryTxAuthStateRequest) (*types.QueryTxAuthStateResponse, error)

Types

type Keeper

type Keeper struct {
	packets.PacketSendKeeper
	// contains filtered or unexported fields
}

func NewKeeper

func NewKeeper(
	m codec.Codec,
	storeKey sdk.StoreKey,
	channelKeeper types.ChannelKeeper,
	packetSendKeeper packets.PacketSendKeeper,
	packetMiddleware packets.PacketMiddleware,
	xccResolver xcctypes.XCCResolver,
) Keeper

func (Keeper) ExtSignTx

func (k Keeper) ExtSignTx(goCtx context.Context, msg *types.MsgExtSignTx) (*types.MsgExtSignTxResponse, error)

func (Keeper) HandleACK

func (p Keeper) HandleACK(
	ctx sdk.Context,
	packet channeltypes.Packet,
	ip packets.IncomingPacket,
	ipa packets.IncomingPacketAcknowledgement,
) (*sdk.Result, error)

func (Keeper) HandlePacket

func (p Keeper) HandlePacket(
	ctx sdk.Context,
	packet channeltypes.Packet,
	ip packets.IncomingPacket,
) (*sdk.Result, *packets.PacketAcknowledgementData, error)

func (Keeper) IBCSignTx

func (k Keeper) IBCSignTx(goCtx context.Context, msg *types.MsgIBCSignTx) (*types.MsgIBCSignTxResponse, error)

IBCSignTx defines a rpc handler method for MsgIBCSignTx.

func (Keeper) InitAuthState

func (k Keeper) InitAuthState(ctx sdk.Context, txID crosstypes.TxID, signers []authtypes.Account) error

InitAuthState implements the TxAuthenticator interface

func (Keeper) IsCompletedAuth

func (k Keeper) IsCompletedAuth(ctx sdk.Context, txID crosstypes.TxID) (bool, error)

IsCompletedAuth implements the TxAuthenticator interface

func (Keeper) Logger

func (k Keeper) Logger(ctx sdk.Context) log.Logger

Logger returns a logger instance

func (Keeper) ReceiveIBCSignTx

func (k Keeper) ReceiveIBCSignTx(
	ctx sdk.Context,
	destPort,
	destChannel string,
	data types.PacketDataIBCSignTx,
) (completed bool, err error)

ReceiveIBCSignTx receives PacketDataIBCSignTx to verify the transaction If all required signs are completed, run the transaction

func (Keeper) SendIBCSignTx

func (k Keeper) SendIBCSignTx(
	ctx sdk.Context,
	packetSender packets.PacketSender,
	xcc xcctypes.XCC,
	txID crosstypes.TxID,
	signers []authtypes.AccountID,
	timeoutHeight clienttypes.Height,
	timeoutTimestamp uint64,
) error

SendIBCSign sends PacketDataIBCSignTx

func (*Keeper) SetTxManager

func (k *Keeper) SetTxManager(txm types.TxManager)

SetTxManager sets the keeper to txManager

func (Keeper) Sign

func (k Keeper) Sign(ctx sdk.Context, txID crosstypes.TxID, signers []authtypes.Account) (bool, error)

Sign implements the TxAuthenticator interface

func (Keeper) SignTx

func (k Keeper) SignTx(goCtx context.Context, msg *types.MsgSignTx) (*types.MsgSignTxResponse, error)

SignTx defines a rpc handler method for MsgSignTx.

func (Keeper) TxAuthState

func (q Keeper) TxAuthState(c context.Context, req *types.QueryTxAuthStateRequest) (*types.QueryTxAuthStateResponse, error)