keeper

package
v1.0.0 Latest Latest
Warning

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

Go to latest
Published: Oct 20, 2022 License: Apache-2.0 Imports: 18 Imported by: 4

Documentation

Index

Constants

View Source
const (
	RetryInterval = 25
)

Variables

This section is empty.

Functions

func GenerateQueryHash

func GenerateQueryHash(connectionID string, chainID string, 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 sdk.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)

DeleteQuery delete 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 string, connectionID string, chainID string, 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 string, connectionID string, chainID string, queryType string, request []byte, maxAge uint64) (types.DataPoint, error)

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 string, chainID string, queryType string, request []byte, period sdk.Int, module string, callbackID string, ttl uint64)

func (Keeper) NewQuery

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

func (Keeper) Queries

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 sdk.Int) error

func (Keeper) SetQuery

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

SetQuery set query info

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL