keeper

Documentation

Index

• func NewMsgServerImpl(keeper Keeper) types.MsgServer
• func NewQuerierImpl(keeper Keeper) types.QueryServer
• type Keeper
  • func NewKeeper(cdc codec.BinaryCodec, storeService storetypes.KVStoreService, ...) *Keeper
  • func (k Keeper) EndBlock(ctx sdk.Context) (err error)
  • func (k Keeper) GetAllDataRequestWasms(ctx sdk.Context) []types.DataRequestWasm
  • func (k Keeper) GetAllExecutorWasms(ctx sdk.Context) []types.ExecutorWasm
  • func (k Keeper) GetAuthority() string
  • func (k Keeper) GetCoreContractAddr(ctx context.Context) (sdk.AccAddress, error)
  • func (k Keeper) GetDataRequestWasm(ctx context.Context, hash string) (types.DataRequestWasm, error)
  • func (k Keeper) GetExpiredWasmKeys(ctx sdk.Context, expirationHeight int64) ([][]byte, error)
  • func (k Keeper) IterateDataRequestWasms(ctx sdk.Context, callback func(wasm types.DataRequestWasm) (stop bool)) error
  • func (k Keeper) IterateExecutorWasms(ctx sdk.Context, callback func(wasm types.ExecutorWasm) (stop bool)) error
  • func (k Keeper) ListDataRequestWasms(ctx sdk.Context) []string
  • func (k Keeper) ListExecutorWasms(ctx sdk.Context) []string
  • func (k Keeper) Logger(ctx sdk.Context) log.Logger
  • func (k Keeper) ProcessExpiredWasms(ctx sdk.Context) error
• type Querier
  • func (q Querier) CoreContractRegistry(c context.Context, _ *types.QueryCoreContractRegistryRequest) (*types.QueryCoreContractRegistryResponse, error)
  • func (q Querier) DataRequestWasm(c context.Context, req *types.QueryDataRequestWasmRequest) (*types.QueryDataRequestWasmResponse, error)
  • func (q Querier) DataRequestWasms(c context.Context, _ *types.QueryDataRequestWasmsRequest) (*types.QueryDataRequestWasmsResponse, error)
  • func (q Querier) ExecutorWasm(c context.Context, req *types.QueryExecutorWasmRequest) (*types.QueryExecutorWasmResponse, error)
  • func (q Querier) ExecutorWasms(c context.Context, _ *types.QueryExecutorWasmsRequest) (*types.QueryExecutorWasmsResponse, error)

Functions

func NewMsgServerImpl

func NewMsgServerImpl(keeper Keeper) types.MsgServer

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

func NewQuerierImpl

func NewQuerierImpl(keeper Keeper) types.QueryServer

Types

type Keeper

type Keeper struct {
	Schema               collections.Schema
	DataRequestWasm      collections.Map[[]byte, types.DataRequestWasm]
	ExecutorWasm         collections.Map[[]byte, types.ExecutorWasm]
	WasmExpiration       collections.KeySet[collections.Pair[int64, []byte]]
	CoreContractRegistry collections.Item[string]
	Params               collections.Item[types.Params]
	// contains filtered or unexported fields
}

func NewKeeper

func NewKeeper(cdc codec.BinaryCodec, storeService storetypes.KVStoreService, authority string, ak types.AccountKeeper, bk types.BankKeeper, wk wasmtypes.ContractOpsKeeper, wvk wasmtypes.ViewKeeper) *Keeper

func (Keeper) EndBlock

func (k Keeper) EndBlock(ctx sdk.Context) (err error)

func (Keeper) GetAllDataRequestWasms

func (k Keeper) GetAllDataRequestWasms(ctx sdk.Context) []types.DataRequestWasm

func (Keeper) GetAllExecutorWasms

func (k Keeper) GetAllExecutorWasms(ctx sdk.Context) []types.ExecutorWasm

func (Keeper) GetAuthority

func (k Keeper) GetAuthority() string

GetAuthority returns the module's authority.

func (Keeper) GetCoreContractAddr

func (k Keeper) GetCoreContractAddr(ctx context.Context) (sdk.AccAddress, error)

GetCoreContractAddr retrieves the core contract address.

func (Keeper) GetDataRequestWasm

func (k Keeper) GetDataRequestWasm(ctx context.Context, hash string) (types.DataRequestWasm, error)

GetDataRequestWasm retrieves the data request wasm from the store given its hex-encoded hash.

func (Keeper) GetExpiredWasmKeys

func (k Keeper) GetExpiredWasmKeys(ctx sdk.Context, expirationHeight int64) ([][]byte, error)

GetExpiredWasmKeys retrieves the keys of the data request wasms that will expire at the given block height.

func (Keeper) IterateDataRequestWasms

func (k Keeper) IterateDataRequestWasms(ctx sdk.Context, callback func(wasm types.DataRequestWasm) (stop bool)) error

IterateDataRequestWasms iterates over the data request wasms and performs a given callback function.

func (Keeper) IterateExecutorWasms

func (k Keeper) IterateExecutorWasms(ctx sdk.Context, callback func(wasm types.ExecutorWasm) (stop bool)) error

IterateExecutorWasms iterates over the executor wasms and performs a given callback function.

func (Keeper) ListDataRequestWasms

func (k Keeper) ListDataRequestWasms(ctx sdk.Context) []string

ListDataRequestWasms returns hashes and expiration block heights of all data request wasms in the store.

func (Keeper) ListExecutorWasms

func (k Keeper) ListExecutorWasms(ctx sdk.Context) []string

ListExecutorWasms returns hex-encoded hashes of all executor wasms in the store.

func (Keeper) Logger

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

func (Keeper) ProcessExpiredWasms

func (k Keeper) ProcessExpiredWasms(ctx sdk.Context) error

type Querier

type Querier struct {
	Keeper
}

func (Querier) CoreContractRegistry

func (q Querier) CoreContractRegistry(c context.Context, _ *types.QueryCoreContractRegistryRequest) (*types.QueryCoreContractRegistryResponse, error)

func (Querier) DataRequestWasm

func (q Querier) DataRequestWasm(c context.Context, req *types.QueryDataRequestWasmRequest) (*types.QueryDataRequestWasmResponse, error)

func (Querier) DataRequestWasms

func (q Querier) DataRequestWasms(c context.Context, _ *types.QueryDataRequestWasmsRequest) (*types.QueryDataRequestWasmsResponse, error)

func (Querier) ExecutorWasm

func (q Querier) ExecutorWasm(c context.Context, req *types.QueryExecutorWasmRequest) (*types.QueryExecutorWasmResponse, error)

func (Querier) ExecutorWasms

func (q Querier) ExecutorWasms(c context.Context, _ *types.QueryExecutorWasmsRequest) (*types.QueryExecutorWasmsResponse, error)