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) ExpireOraclePrograms(ctx sdk.Context) error
  • func (k Keeper) GetAllExecutorWasms(ctx sdk.Context) []types.ExecutorWasm
  • func (k Keeper) GetAllOraclePrograms(ctx sdk.Context) []types.OracleProgram
  • func (k Keeper) GetAuthority() string
  • func (k Keeper) GetCoreContractAddr(ctx context.Context) (sdk.AccAddress, error)
  • func (k Keeper) GetExpiredOracleProgamKeys(ctx sdk.Context, expirationHeight int64) ([][]byte, error)
  • func (k Keeper) GetOracleProgram(ctx context.Context, hash string) (types.OracleProgram, error)
  • func (k Keeper) IterateExecutorWasms(ctx sdk.Context, callback func(wasm types.ExecutorWasm) (stop bool)) error
  • func (k Keeper) IterateOraclePrograms(ctx sdk.Context, callback func(program types.OracleProgram) (stop bool)) error
  • func (k Keeper) ListExecutorWasms(ctx sdk.Context) []string
  • func (k Keeper) ListOraclePrograms(ctx sdk.Context) []string
  • func (k Keeper) Logger(ctx sdk.Context) log.Logger
• type Querier
  • func (q Querier) CoreContractRegistry(c context.Context, _ *types.QueryCoreContractRegistryRequest) (*types.QueryCoreContractRegistryResponse, 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)
  • func (q Querier) OracleProgram(c context.Context, req *types.QueryOracleProgramRequest) (*types.QueryOracleProgramResponse, error)
  • func (q Querier) OraclePrograms(c context.Context, req *types.QueryOracleProgramsRequest) (*types.QueryOracleProgramsResponse, 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
	OracleProgram           collections.Map[[]byte, types.OracleProgram]
	ExecutorWasm            collections.Map[[]byte, types.ExecutorWasm]
	OracleProgramExpiration 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) ExpireOraclePrograms

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

func (Keeper) GetAllExecutorWasms

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

func (Keeper) GetAllOraclePrograms

func (k Keeper) GetAllOraclePrograms(ctx sdk.Context) []types.OracleProgram

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

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

GetExpiredOracleProgamKeys retrieves the keys of the oracle programs that will expire at the given block height.

func (Keeper) GetOracleProgram

func (k Keeper) GetOracleProgram(ctx context.Context, hash string) (types.OracleProgram, error)

GetOracleProgram retrieves the oracle program from the store given its hex-encoded hash.

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

func (k Keeper) IterateOraclePrograms(ctx sdk.Context, callback func(program types.OracleProgram) (stop bool)) error

IterateOraclePrograms iterates over the oracle programs and performs a given callback function.

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

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

ListOraclePrograms returns hashes and expiration block heights of all oracle programs in the store.

func (Keeper) Logger

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

type Querier

type Querier struct {
	Keeper
}

func (Querier) CoreContractRegistry

func (q Querier) CoreContractRegistry(c context.Context, _ *types.QueryCoreContractRegistryRequest) (*types.QueryCoreContractRegistryResponse, 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)

func (Querier) OracleProgram

func (q Querier) OracleProgram(c context.Context, req *types.QueryOracleProgramRequest) (*types.QueryOracleProgramResponse, error)

func (Querier) OraclePrograms

func (q Querier) OraclePrograms(c context.Context, req *types.QueryOracleProgramsRequest) (*types.QueryOracleProgramsResponse, error)