Versions in this module Expand all Collapse all v0 v0.0.3 Mar 15, 2026 Changes in this version + const DelayFieldName + var Component = &component.Component + var DelayDefault = time.Second / 60 + func StrategyRegister(st StrategyType, strategy Strategy) + type Config struct + Delay time.Duration + func Configuration(config *Config, configurator configurator.Configurator) *Config + func NewConfig() *Config + type Middleware interface + Middleware func(task *Task, next runner.Process) runner.Process + type MiddlewareFunc func(task *Task, next runner.Process) runner.Process + func (m MiddlewareFunc) Middleware(task *Task, next runner.Process) runner.Process + type Option func(task *Task) *Task + type Repeater interface + AddTask func(task *Task) error + AddTasks func(tasks ...*Task) error + HasTask func(task *Task) bool + HasTaskByName func(name string) bool + RemoveTask func(task *Task) error + RemoveTaskByName func(name string) error + Use func(middlewares ...Middleware) + func NewRepeater(config *Config, logger logger.Logger, runner runner.Runner) Repeater + type Strategy interface + GenerateName func(task *Task) string + IsTaskRun func(task *Task, runner runner.Runner) bool + type StrategyType uint8 + const Lock + const Unlock + func (s StrategyType) String() string + type Task struct + func NewTask(name string, process runner.Process, delay time.Duration, ...) *Task + func NewTaskWithLock(name string, process runner.Process, delay time.Duration, options ...Option) *Task + func NewTaskWithUnlock(name string, process runner.Process, delay time.Duration, options ...Option) *Task + func SkipFirstRun(task *Task) *Task + func (t *Task) Delay() time.Duration + func (t *Task) Name() string + func (t *Task) RunNumbers() uint64 + func (t *Task) Strategy() StrategyType + func (t *Task) String() string
Go to main page