keeper

Documentation

Index

• func NewMsgServerImpl(keeper *Keeper) types.MsgServer
• type Keeper
  • func NewKeeper(cdc codec.BinaryCodec, storeKey, memKey storetypes.StoreKey, ...) *Keeper
  • func (k Keeper) AuthenticateCapability(ctx sdk.Context, capability *capabilitytypes.Capability, name string) bool
  • func (k Keeper) BindPort(ctx sdk.Context, portID string) error
  • func (k Keeper) ClaimCapability(ctx sdk.Context, capability *capabilitytypes.Capability, name string) error
  • func (k Keeper) ExportGenesis(ctx sdk.Context) *types.GenesisState
  • func (k Keeper) GetAuthority() string
  • func (k Keeper) GetOracle(ctx sdk.Context) (oracle sdk.AccAddress, err error)
  • func (k Keeper) GetPort(ctx sdk.Context) string
  • func (k Keeper) InitGenesis(ctx sdk.Context, genState *types.GenesisState)
  • func (k Keeper) IsBound(ctx sdk.Context, portID string) bool
  • func (k Keeper) Logger(ctx sdk.Context) log.Logger
  • func (k Keeper) OnAcknowledgementPacket(ctx sdk.Context, modulePacket channeltypes.Packet, ...) error
  • func (k Keeper) OnTimeoutPacket(ctx sdk.Context, modulePacket channeltypes.Packet) error
  • func (k Keeper) Oracle(goCtx context.Context, req *types.QueryOracleRequest) (*types.QueryOracleResponse, error)
  • func (k Keeper) OracleAddress(goCtx context.Context, _ *types.QueryOracleAddressRequest) (*types.QueryOracleAddressResponse, error)
  • func (k Keeper) QueryOracle(ctx sdk.Context, query wasmtypes.RawContractMessage, channel string) (uint64, error)
  • func (k Keeper) SendQuery(ctx sdk.Context, sourcePort, sourceChannel string, ...) (uint64, error)
  • func (k Keeper) SetOracle(ctx sdk.Context, oracle sdk.AccAddress)
  • func (k Keeper) SetPort(ctx sdk.Context, portID string)

Functions

func NewMsgServerImpl

func NewMsgServerImpl(keeper *Keeper) types.MsgServer

NewMsgServerImpl returns an implementation of the account MsgServer interface for the provided Keeper.

Types

type Keeper

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

func NewKeeper

func NewKeeper(
	cdc codec.BinaryCodec,
	storeKey,
	memKey storetypes.StoreKey,
	ics4Wrapper types.ICS4Wrapper,
	channelKeeper types.ChannelKeeper,
	portKeeper types.PortKeeper,
	scopedKeeper types.ScopedKeeper,
	wasmQueryServer wasmtypes.QueryServer,
) *Keeper

func (Keeper) AuthenticateCapability

func (k Keeper) AuthenticateCapability(ctx sdk.Context, capability *capabilitytypes.Capability, name string) bool

AuthenticateCapability wraps the scopedKeeper's AuthenticateCapability function

func (Keeper) BindPort

func (k Keeper) BindPort(ctx sdk.Context, portID string) error

BindPort stores the provided portID and binds to it

func (Keeper) ClaimCapability

func (k Keeper) ClaimCapability(ctx sdk.Context, capability *capabilitytypes.Capability, name string) error

ClaimCapability wraps the scopedKeeper's ClaimCapability function

func (Keeper) ExportGenesis

func (k Keeper) ExportGenesis(ctx sdk.Context) *types.GenesisState

ExportGenesis returns a GenesisState for a given context.

func (Keeper) GetAuthority

func (k Keeper) GetAuthority() string

GetAuthority returns the module's authority address

func (Keeper) GetOracle

func (k Keeper) GetOracle(ctx sdk.Context) (oracle sdk.AccAddress, err error)

GetOracle Gets the oracle used by the module.

func (Keeper) GetPort

func (k Keeper) GetPort(ctx sdk.Context) string

GetPort returns the portID for the transfer module. Used in ExportGenesis

func (Keeper) InitGenesis

func (k Keeper) InitGenesis(ctx sdk.Context, genState *types.GenesisState)

InitGenesis new oracle genesis

func (Keeper) IsBound

func (k Keeper) IsBound(ctx sdk.Context, portID string) bool

IsBound checks if the interchain query already bound to the desired port

func (Keeper) Logger

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

Logger returns the correctly named logger for the module

func (Keeper) OnAcknowledgementPacket

func (k Keeper) OnAcknowledgementPacket(
	ctx sdk.Context,
	modulePacket channeltypes.Packet,
	ack channeltypes.Acknowledgement,
) error

OnAcknowledgementPacket reacts to an Acknowledgement packet.

func (Keeper) OnTimeoutPacket

func (k Keeper) OnTimeoutPacket(
	ctx sdk.Context,
	modulePacket channeltypes.Packet,
) error

OnTimeoutPacket reacts to a timed out packet.

func (Keeper) Oracle

func (k Keeper) Oracle(goCtx context.Context, req *types.QueryOracleRequest) (*types.QueryOracleResponse, error)

Oracle queries module's oracle

func (Keeper) OracleAddress

func (k Keeper) OracleAddress(goCtx context.Context, _ *types.QueryOracleAddressRequest) (*types.QueryOracleAddressResponse, error)

QueryAddress returns the address of the module's oracle

func (Keeper) QueryOracle

func (k Keeper) QueryOracle(ctx sdk.Context, query wasmtypes.RawContractMessage, channel string) (uint64, error)

QueryOracle sends an ICQ to the other chain's module

func (Keeper) SendQuery

func (k Keeper) SendQuery(
	ctx sdk.Context,
	sourcePort,
	sourceChannel string,
	chanCap *capabilitytypes.Capability,
	reqs []abci.RequestQuery,
	_ clienttypes.Height,
	timeoutTimestamp uint64,
) (uint64, error)

SendQuery sends and records an icq

func (Keeper) SetOracle

func (k Keeper) SetOracle(ctx sdk.Context, oracle sdk.AccAddress)

SetOracle Sets the oracle used by the module.

func (Keeper) SetPort

func (k Keeper) SetPort(ctx sdk.Context, portID string)

SetPort sets the portID for the transfer module. Used in InitGenesis