Versions in this module Expand all Collapse all v1 v1.0.0 Mar 27, 2024 Changes in this version + var TypeOfExecutionEnum = struct{ ... } + func AddNewCronExecution(wr Worker) + func CustomErrorInstance() error + func MakeSchedulerAnchorPoint() + func StopCronExecution(wr *Worker, scheduler *gocron.Scheduler) + type CronSchedulerConfig struct + IntervalInSeconds int + TypeOfExecution TypeOfExecution + type ExecutionException interface + RegisterMetricsCount func(errorName string, count int64) error + type Instrumentation struct + FuncDispatcher func(ctx context.Context, data TaskParams) (TaskParams, error) + FuncName string + NestedCallback func(ctx context.Context, data TaskParams) error + TaskArguments TaskParams + type TaskParams struct + Params map[string]interface{} + func NewTaskParams() TaskParams + func (t *TaskParams) Clone() TaskParams + func (t *TaskParams) GetBytesParam(key string) ([]byte, bool) + func (t *TaskParams) GetComplexParam(key string) (*any, bool) + func (t *TaskParams) GetFloatParam(key string) (float64, bool) + func (t *TaskParams) GetIntParam(key string) (int, bool) + func (t *TaskParams) GetParams() map[string]interface{} + func (t *TaskParams) GetStringParam(key string) (string, bool) + func (t *TaskParams) SetBytesParam(key string, value []byte) + func (t *TaskParams) SetComplexParam(key string, value *any) + func (t *TaskParams) SetFloatParam(key string, value float64) + func (t *TaskParams) SetIntParam(key string, value int) + func (t *TaskParams) SetStringParam(key string, value string) + type TypeOfExecution int64 + type Worker struct + Callback func(ctx context.Context) + CronSchedulerConfig CronSchedulerConfig + ExecsPerTick []int + Instrumentation Instrumentation + SourceContext context.Context + TickDuration time.Duration + func (wr Worker) Run() + type WorkerError struct + func WorkerErrorInstance(error string) *WorkerError + func (e *WorkerError) Error() string + func (e *WorkerError) RegisterMetricsCount(errorName string, count int64, errorTags []string) + func (e WorkerError) ExecutionError(args []string) *error + func (w WorkerError) ListenErrosHappned()