Versions in this module Expand all Collapse all v0 v0.0.7 Mar 15, 2026 Changes in this version + var Component = &component.Component + var TaskAlreadyExistsError = errors.New("task already exists") + var TaskUndefinedError = errors.New("task is undefined") + type Middleware interface + Middleware func(task *Task, next Process) Process + type MiddlewareFunc func(task *Task, next Process) Process + func (m MiddlewareFunc) Middleware(task *Task, next Process) Process + type Process interface + Process func(ctx context.Context) error + type ProcessFunc func(ctx context.Context) error + func (p ProcessFunc) Process(ctx context.Context) error + type Runner interface + HasTask func(task *Task) bool + HasTaskByName func(name string) bool + RunTask func(task *Task) error + RunTasks func(tasks ...*Task) error + StopTask func(task *Task) error + StopTaskByName func(name string) error + Use func(middlewares ...Middleware) + func NewRunner(closer closer.Closer, logger logger.Logger) Runner + type Task struct + func NewTask(name string, process Process) *Task + func (task *Task) Name() string + func (task *Task) String() string
Go to main page