runner

May 11, 2026

Changes in this version

+ type Default struct

+ func NewDefault(closer closer.Closer, logger logger.Logger) *Default

+ func (runner *Default) Close() (err error)

+ func (runner *Default) HasProcess(process Process) bool

+ func (runner *Default) HasProcessByName(name string) bool

+ func (runner *Default) RunProcess(process Process) (err error)

+ func (runner *Default) RunProcesses(process ...Process) (err error)

+ func (runner *Default) StopProcess(process Process) (err error)

+ func (runner *Default) StopProcessByName(name string) error

+ func (runner *Default) Use(middlewares ...Middleware)

type Process

+ Name func() string

type Runner

+ HasProcess func(Process) bool

+ HasProcessByName func(string) bool

+ RunProcess func(Process) error

+ RunProcesses func(...Process) error

+ StopProcess func(Process) error

+ StopProcessByName func(string) error

type Task

+ func (task *Task) Close() error

+ func (task *Task) Process(ctx context.Context) error

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