keeper

Documentation

Index

• Constants
• func GenerateQueryHash(connection_id string, chain_id string, query_type string, ...) string
• func NewMsgServerImpl(keeper Keeper) types.MsgServer
• type Keeper
  • func NewKeeper(cdc codec.Codec, storeKey sdk.StoreKey) 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) GetDatapoint(ctx sdk.Context, connection_id string, chain_id string, query_type string, ...) (types.DataPoint, error)
  • func (k *Keeper) GetDatapointForId(ctx sdk.Context, id string) (types.DataPoint, error)
  • func (k *Keeper) GetDatapointOrRequest(ctx sdk.Context, connection_id string, chain_id string, query_type string, ...) (types.DataPoint, error)
  • func (k Keeper) GetQuery(ctx sdk.Context, id string) (types.Query, 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, connection_id string, chain_id string, query_type string, ...)
  • func (k Keeper) NewQuery(ctx sdk.Context, connection_id string, chain_id string, query_type string, ...) *types.Query
  • func (k *Keeper) SetCallbackHandler(module string, handler types.QueryCallbacks) error
  • func (k *Keeper) SetDatapointForId(ctx sdk.Context, id string, result []byte, height sdk.Int) error
  • func (k Keeper) SetQuery(ctx sdk.Context, query types.Query)

Constants

const (
	RetryInterval = 25
)

Functions

func GenerateQueryHash

func GenerateQueryHash(connection_id string, chain_id string, query_type string, query_params map[string]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 {
	// contains filtered or unexported fields
}

Keeper of this module maintains collections of registered zones.

func NewKeeper

func NewKeeper(cdc codec.Codec, storeKey sdk.StoreKey) 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) GetDatapoint

func (k *Keeper) GetDatapoint(ctx sdk.Context, connection_id string, chain_id string, query_type string, query_params map[string]string) (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, connection_id string, chain_id string, query_type string, query_params map[string]string, max_age int64) (types.DataPoint, error)

func (Keeper) GetQuery

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

GetQuery returns query

func (Keeper) IterateQueries

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

IterateQueries iterate through querys

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, connection_id string, chain_id string, query_type string, query_params map[string]string, period sdk.Int, module string, callback interface{})

func (Keeper) NewQuery

func (k Keeper) NewQuery(ctx sdk.Context, connection_id string, chain_id string, query_type string, query_params map[string]string, period sdk.Int) *types.Query

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