keeper

Documentation

Index

• func NewMsgServerImpl(keeper types.Keeper) types.MsgServer
• type ExecuteJobWasmEvent
• type Keeper
  • func NewKeeper(cdc codec.BinaryCodec, storeKey store.KVStoreService, ...) *Keeper
  • func (k Keeper) AddNewJob(ctx context.Context, job *types.Job) error
  • func (k Keeper) ExecuteJob(ctx context.Context, jobID string, payload []byte, ...) (uint64, error)
  • func (k Keeper) ExecuteWasmJobEventListener() wasmutil.MessengerFnc
  • func (k Keeper) GetAccount(ctx context.Context, addr sdk.AccAddress) authtypes.AccountI
  • func (k Keeper) GetJob(ctx context.Context, jobID string) (*types.Job, error)
  • func (k Keeper) GetParams(ctx context.Context) (params types.Params)
  • func (k Keeper) JobIDExists(ctx context.Context, jobID string) bool
  • func (k Keeper) Logger(ctx context.Context) log.Logger
  • func (k Keeper) ModuleName() string
  • func (k Keeper) Params(c context.Context, req *types.QueryParamsRequest) (*types.QueryParamsResponse, error)
  • func (k Keeper) PreJobExecution(ctx context.Context, job *types.Job) error
  • func (k Keeper) QueryGetJobByID(goCtx context.Context, req *types.QueryGetJobByIDRequest) (*types.QueryGetJobByIDResponse, error)
  • func (k Keeper) ScheduleNow(ctx context.Context, jobID string, in []byte, senderAddress sdk.AccAddress, ...) (uint64, error)
  • func (k Keeper) SetParams(ctx context.Context, params types.Params)
  • func (k Keeper) Store(ctx context.Context) storetypes.KVStore
  • func (k Keeper) UnmarshallJob(msg []byte) (ExecuteJobWasmEvent, error)

Functions

func NewMsgServerImpl

func NewMsgServerImpl(keeper types.Keeper) types.MsgServer

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

Types

type ExecuteJobWasmEvent

type ExecuteJobWasmEvent struct {
	JobID   string `json:"job_id"`
	Sender  string `json:"sender"`
	Payload []byte `json:"payload"`
}

type Keeper

type Keeper struct {
	EvmKeeper types.EvmKeeper

	Chains map[xchain.Type]xchain.Bridge
	// contains filtered or unexported fields
}

func NewKeeper

func NewKeeper(
	cdc codec.BinaryCodec,
	storeKey store.KVStoreService,
	account types.AccountKeeper,
	evmKeeper types.EvmKeeper,
	chains []xchain.Bridge,
) *Keeper

func (Keeper) AddNewJob

func (k Keeper) AddNewJob(ctx context.Context, job *types.Job) error

func (Keeper) ExecuteJob

func (k Keeper) ExecuteJob(ctx context.Context, jobID string, payload []byte, senderAddress sdk.AccAddress, contractAddr sdk.AccAddress) (uint64, error)

func (Keeper) ExecuteWasmJobEventListener

func (k Keeper) ExecuteWasmJobEventListener() wasmutil.MessengerFnc

func (Keeper) GetAccount

func (k Keeper) GetAccount(ctx context.Context, addr sdk.AccAddress) authtypes.AccountI

func (Keeper) GetJob

func (k Keeper) GetJob(ctx context.Context, jobID string) (*types.Job, error)

func (Keeper) GetParams

func (k Keeper) GetParams(ctx context.Context) (params types.Params)

GetParams get all parameters as types.Params

func (Keeper) JobIDExists

func (k Keeper) JobIDExists(ctx context.Context, jobID string) bool

func (Keeper) Logger

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

func (Keeper) ModuleName

func (k Keeper) ModuleName() string

func (Keeper) Params

func (k Keeper) Params(c context.Context, req *types.QueryParamsRequest) (*types.QueryParamsResponse, error)

func (Keeper) PreJobExecution

func (k Keeper) PreJobExecution(ctx context.Context, job *types.Job) error

func (Keeper) QueryGetJobByID

func (k Keeper) QueryGetJobByID(goCtx context.Context, req *types.QueryGetJobByIDRequest) (*types.QueryGetJobByIDResponse, error)

func (Keeper) ScheduleNow

func (k Keeper) ScheduleNow(ctx context.Context, jobID string, in []byte, senderAddress sdk.AccAddress, contractAddress sdk.AccAddress) (uint64, error)

func (Keeper) SetParams

func (k Keeper) SetParams(ctx context.Context, params types.Params)

SetParams sets the parameters in the store

func (Keeper) Store

func (k Keeper) Store(ctx context.Context) storetypes.KVStore

store returns default store for this keeper!

func (Keeper) UnmarshallJob

func (k Keeper) UnmarshallJob(msg []byte) (ExecuteJobWasmEvent, error)