keeper

Documentation

Index

• Constants
• func GenerateQueryHash(connectionID, chainID, queryType string, request []byte, module string) string
• func NewMsgServerImpl(keeper Keeper) types.MsgServer
• 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) DeleteDatapoint(ctx sdk.Context, id string)
  • func (k Keeper) DeleteQuery(ctx sdk.Context, id string)
  • func (k Keeper) EndBlocker(ctx sdk.Context)
  • func (k *Keeper) GetDatapoint(ctx sdk.Context, module, connectionID, chainID, queryType string, ...) (types.DataPoint, error)
  • func (k *Keeper) GetDatapointForID(ctx sdk.Context, id string) (types.DataPoint, error)
  • func (k *Keeper) GetDatapointOrRequest(ctx sdk.Context, module, connectionID, chainID, queryType string, ...) (types.DataPoint, error)
  • func (k *Keeper) GetLatestHeight(ctx sdk.Context, chainID string) uint64
  • func (k Keeper) GetQuery(ctx sdk.Context, id string) (types.Query, bool)
  • func (k Keeper) IterateDatapoints(ctx sdk.Context, fn func(index int64, dp types.DataPoint) (stop bool))
  • 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) MakeRequest(ctx sdk.Context, connectionID, chainID, queryType string, request []byte, ...)
  • func (k Keeper) NewQuery(module, connectionID, chainID, queryType string, request []byte, ...) *types.Query
  • func (k Keeper) Queries(c context.Context, req *types.QueryRequestsRequest) (*types.QueryRequestsResponse, error)
  • func (k *Keeper) SetCallbackHandler(module string, handler types.QueryCallbacks) error
  • func (k *Keeper) SetDatapointForID(ctx sdk.Context, id string, result []byte, height math.Int) error
  • func (k *Keeper) SetLatestHeight(ctx sdk.Context, chainID string, height uint64)
  • func (k Keeper) SetQuery(ctx sdk.Context, query types.Query)

Constants

const (
	RetryInterval = 25
)

Functions

func GenerateQueryHash

func GenerateQueryHash(connectionID, chainID, queryType string, request []byte, module string) string

func NewMsgServerImpl

func NewMsgServerImpl(keeper Keeper) types.MsgServer

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

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

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

DeleteDatapoint deletes datapoint.

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

func (k *Keeper) GetDatapoint(ctx sdk.Context, module, connectionID, chainID, queryType string, request []byte) (types.DataPoint, error)

func (*Keeper) GetDatapointForID

func (k *Keeper) GetDatapointForID(ctx sdk.Context, id string) (types.DataPoint, error)

func (*Keeper) GetDatapointOrRequest

func (k *Keeper) GetDatapointOrRequest(ctx sdk.Context, module, connectionID, chainID, queryType string, request []byte, maxAge uint64) (types.DataPoint, error)

func (*Keeper) GetLatestHeight

func (k *Keeper) GetLatestHeight(ctx sdk.Context, chainID string) uint64

func (Keeper) GetQuery

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

GetQuery returns query.

func (Keeper) IterateDatapoints

func (k Keeper) IterateDatapoints(ctx sdk.Context, fn func(index int64, dp types.DataPoint) (stop bool))

IterateDatapoints iterate through datapoints.

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

func (k *Keeper) MakeRequest(
	ctx sdk.Context,
	connectionID,
	chainID,
	queryType string,
	request []byte,
	period math.Int,
	module string,
	callbackID string,
	ttl uint64,
)

func (Keeper) NewQuery

func (k Keeper) NewQuery(
	module,
	connectionID,
	chainID,
	queryType string,
	request []byte,
	period math.Int,
	callbackID string,
	ttl uint64,
) *types.Query

func (Keeper) Queries

func (k Keeper) Queries(c context.Context, req *types.QueryRequestsRequest) (*types.QueryRequestsResponse, error)

Queries returns information about registered zones.

func (*Keeper) SetCallbackHandler

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

func (*Keeper) SetDatapointForID

func (k *Keeper) SetDatapointForID(ctx sdk.Context, id string, result []byte, height math.Int) error

func (*Keeper) SetLatestHeight

func (k *Keeper) SetLatestHeight(ctx sdk.Context, chainID string, height uint64)

func (Keeper) SetQuery

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

SetQuery set query info.