keeper

Documentation

Index

• func NewMsgServerImpl(keeper Keeper) types.MsgServer
• func UnmarshalAmountFromBalanceQuery(cdc codec.BinaryCodec, queryResponseBz []byte) (amount sdkmath.Int, err error)
• type Keeper
  • func NewKeeper(cdc codec.Codec, storeKey storetypes.StoreKey, ibckeeper *ibckeeper.Keeper) Keeper
  • func (k Keeper) AllQueries(ctx sdk.Context) []types.Query
  • func (k Keeper) DeleteQuery(ctx sdk.Context, id string)
  • func (k Keeper) EndBlocker(ctx sdk.Context)
  • func (k Keeper) GetQuery(ctx sdk.Context, id string) (types.Query, bool)
  • func (k Keeper) GetQueryId(ctx sdk.Context, query types.Query, forceUnique bool) string
  • func (k Keeper) GetQueryUID(ctx sdk.Context) []byte
  • func (k Keeper) HandleQueryTimeout(ctx sdk.Context, msg *types.MsgSubmitQueryResponse, query types.Query) error
  • func (k Keeper) InvokeCallback(ctx sdk.Context, msg *types.MsgSubmitQueryResponse, query types.Query) error
  • func (k Keeper) IterateQueries(ctx sdk.Context, fn func(index int64, queryInfo types.Query) (stop bool))
  • func (k Keeper) Logger(ctx sdk.Context) log.Logger
  • func (k Keeper) PendingQueries(c context.Context, req *types.QueryPendingQueriesRequest) (*types.QueryPendingQueriesResponse, error)
  • func (k *Keeper) RetryICQRequest(ctx sdk.Context, query types.Query) error
  • func (k *Keeper) SetCallbackHandler(module string, handler types.QueryCallbacks) error
  • func (k Keeper) SetQuery(ctx sdk.Context, query types.Query)
  • func (k *Keeper) SubmitICQRequest(ctx sdk.Context, query types.Query, forceUnique bool) error
  • func (k Keeper) ValidateQuery(ctx sdk.Context, query types.Query) error
  • func (k Keeper) VerifyKeyProof(ctx sdk.Context, msg *types.MsgSubmitQueryResponse, query types.Query) error

Functions

func NewMsgServerImpl

func NewMsgServerImpl(keeper Keeper) types.MsgServer

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

func UnmarshalAmountFromBalanceQuery

func UnmarshalAmountFromBalanceQuery(cdc codec.BinaryCodec, queryResponseBz []byte) (amount sdkmath.Int, err error)

Helper function to unmarshal a Balance query response across SDK versions Before SDK v46, the query response returned a sdk.Coin type. SDK v46 returns an int type https://github.com/cosmos/cosmos-sdk/pull/9832

Types

type Keeper

type Keeper struct {
	IBCKeeper *ibckeeper.Keeper
	// contains filtered or unexported fields
}

Keeper of this module maintains collections of registered zones.

func NewKeeper

func NewKeeper(cdc codec.Codec, storeKey storetypes.StoreKey, ibckeeper *ibckeeper.Keeper) Keeper

NewKeeper returns a new instance of zones Keeper

func (Keeper) AllQueries

func (k Keeper) AllQueries(ctx sdk.Context) []types.Query

AllQueries returns every queryInfo in the store

func (Keeper) DeleteQuery

func (k Keeper) DeleteQuery(ctx sdk.Context, id string)

DeleteQuery delete query info

func (Keeper) EndBlocker

func (k Keeper) EndBlocker(ctx sdk.Context)

EndBlocker of interchainquery module

func (Keeper) GetQuery

func (k Keeper) GetQuery(ctx sdk.Context, id string) (types.Query, bool)

GetQuery returns query

func (Keeper) GetQueryId

func (k Keeper) GetQueryId(ctx sdk.Context, query types.Query, forceUnique bool) string

Generates a query ID based on the request information If forceUnique is false, queries of the same request type will have the same query ID (e.g. "query the ATOM balance of address X", will always have the same query ID) If forceUnique is true, a unique ID will be used for the query

func (Keeper) GetQueryUID

func (k Keeper) GetQueryUID(ctx sdk.Context) []byte

To optionally force queries to be unique, a UID can be supplied when building the query Id This is implemented using a counter that increments every time a UID is retrieved The uid is returned as a byte array since it's appended to the serialized query key

func (Keeper) HandleQueryTimeout

func (k Keeper) HandleQueryTimeout(ctx sdk.Context, msg *types.MsgSubmitQueryResponse, query types.Query) error

Handles a query timeout based on the timeout policy

func (Keeper) InvokeCallback

func (k Keeper) InvokeCallback(ctx sdk.Context, msg *types.MsgSubmitQueryResponse, query types.Query) error

call the query's associated callback function

func (Keeper) IterateQueries

func (k Keeper) IterateQueries(ctx sdk.Context, fn func(index int64, queryInfo types.Query) (stop bool))

IterateQueries iterate through queries

func (Keeper) Logger

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

Logger returns a module-specific logger.

func (Keeper) PendingQueries

func (k Keeper) PendingQueries(c context.Context, req *types.QueryPendingQueriesRequest) (*types.QueryPendingQueriesResponse, error)

Queries all queries that have been requested but have not received a response

func (*Keeper) RetryICQRequest

func (k *Keeper) RetryICQRequest(ctx sdk.Context, query types.Query) error

Re-submit an ICQ, generally used after a timeout

func (*Keeper) SetCallbackHandler

func (k *Keeper) SetCallbackHandler(module string, handler types.QueryCallbacks) error

func (Keeper) SetQuery

func (k Keeper) SetQuery(ctx sdk.Context, query types.Query)

SetQuery set query info

func (*Keeper) SubmitICQRequest

func (k *Keeper) SubmitICQRequest(ctx sdk.Context, query types.Query, forceUnique bool) error

func (Keeper) ValidateQuery

func (k Keeper) ValidateQuery(ctx sdk.Context, query types.Query) error

ValidateQuery validates that all the required attributes of a query are supplied when submitting an ICQ

func (Keeper) VerifyKeyProof

func (k Keeper) VerifyKeyProof(ctx sdk.Context, msg *types.MsgSubmitQueryResponse, query types.Query) error

check if the query requires proving; if it does, verify it!