Documentation
¶
Index ¶
- Variables
- func NewMsgServerImpl(keeper Keeper) types.MsgServer
- type Keeper
- func (k *Keeper) AddSchedule(ctx sdk.Context, name string, period uint64, msgs []types.MsgExecuteContract) error
- func (k *Keeper) ExecuteReadySchedules(ctx sdk.Context)
- func (k *Keeper) GetAllSchedules(ctx sdk.Context) []types.Schedule
- func (k Keeper) GetAuthority() string
- func (k Keeper) GetParams(ctx sdk.Context) (params types.Params)
- func (k *Keeper) GetSchedule(ctx sdk.Context, name string) (*types.Schedule, bool)
- func (k *Keeper) GetScheduleCount(ctx sdk.Context) int32
- func (k *Keeper) Logger(ctx sdk.Context) log.Logger
- func (k Keeper) Params(c context.Context, req *types.QueryParamsRequest) (*types.QueryParamsResponse, error)
- func (k *Keeper) RemoveSchedule(ctx sdk.Context, name string)
- func (k Keeper) Schedule(c context.Context, req *types.QueryGetScheduleRequest) (*types.QueryGetScheduleResponse, error)
- func (k Keeper) Schedules(c context.Context, req *types.QuerySchedulesRequest) (*types.QuerySchedulesResponse, error)
- func (k Keeper) SetParams(ctx sdk.Context, params types.Params) error
- func (k Keeper) UpdateParams(goCtx context.Context, req *types.MsgUpdateParams) (*types.MsgUpdateParamsResponse, error)
Constants ¶
This section is empty.
Variables ¶
View Source
var ( LabelExecuteReadySchedules = "execute_ready_schedules" LabelScheduleCount = "schedule_count" LabelScheduleExecutionsCount = "schedule_executions_count" MetricLabelSuccess = "success" MetricLabelScheduleName = "schedule_name" )
Functions ¶
func NewMsgServerImpl ¶
NewMsgServerImpl returns an implementation of the MsgServer interface for the provided Keeper.
Types ¶
type Keeper ¶
type Keeper struct {
WasmMsgServer types.WasmMsgServer
// contains filtered or unexported fields
}
func NewKeeper ¶
func NewKeeper( cdc codec.BinaryCodec, storeKey, memKey storetypes.StoreKey, accountKeeper types.AccountKeeper, authority string, ) *Keeper
func (*Keeper) AddSchedule ¶
func (k *Keeper) AddSchedule(ctx sdk.Context, name string, period uint64, msgs []types.MsgExecuteContract) error
AddSchedule adds new schedule to execution for every block `period`. First schedule execution is supposed to be on `now + period` block.
func (*Keeper) ExecuteReadySchedules ¶
ExecuteReadySchedules gets all schedules that are due for execution (with limit that is equal to Params.Limit) and executes messages in each one NOTE that errors in contract calls rollback all already executed messages
func (*Keeper) GetAllSchedules ¶
GetAllSchedules returns all schedules
func (Keeper) GetAuthority ¶
func (*Keeper) GetSchedule ¶
GetSchedule returns schedule with a given `name`
func (Keeper) Params ¶
func (k Keeper) Params(c context.Context, req *types.QueryParamsRequest) (*types.QueryParamsResponse, error)
func (*Keeper) RemoveSchedule ¶
RemoveSchedule removes schedule with a given `name`
func (Keeper) Schedule ¶
func (k Keeper) Schedule(c context.Context, req *types.QueryGetScheduleRequest) (*types.QueryGetScheduleResponse, error)
func (Keeper) Schedules ¶
func (k Keeper) Schedules(c context.Context, req *types.QuerySchedulesRequest) (*types.QuerySchedulesResponse, error)
func (Keeper) UpdateParams ¶
func (k Keeper) UpdateParams(goCtx context.Context, req *types.MsgUpdateParams) (*types.MsgUpdateParamsResponse, error)
UpdateParams updates the module parameters
Source Files
Click to show internal directories.
Click to hide internal directories.