worker

Oct 3, 2023

Changes in this version

type Runner

+ func (runner *Runner) WorkerNames() []string

Jun 26, 2023

Changes in this version

type RunnerParams

+ ShouldRestart func(error) bool

Feb 4, 2022

Changes in this version

+ var ErrAborted = errors.New("aborted waiting for worker")

type Runner

+ func (runner *Runner) StopAndRemoveWorker(id string, abort <-chan struct{}) error

Oct 12, 2021

Changes in this version

+ const DefaultRestartDelay

+ const KeyLastStart

+ const KeyReport

+ const KeyState

+ var ErrDead = errors.New("worker runner is not running")

+ var ErrStopped = errors.New("aborted waiting for worker")

+ func Dead(worker Worker) <-chan struct

+ func Stop(worker Worker) error

+ type Clock interface

+ After func(time.Duration) <-chan time.Time

+ Now func() time.Time

+ type Logger interface

+ Debugf func(string, ...interface{})

+ Errorf func(string, ...interface{})

+ Infof func(string, ...interface{})

+ type Reporter interface

+ Report func() map[string]interface{}

+ type Runner struct

+ func NewRunner(p RunnerParams) *Runner

+ func (runner *Runner) Kill()

+ func (runner *Runner) Report() map[string]interface{}

+ func (runner *Runner) StartWorker(id string, startFunc func() (Worker, error)) error

+ func (runner *Runner) StopWorker(id string) error

+ func (runner *Runner) Wait() error

+ func (runner *Runner) WaitWorker(id string, maxWait time.Duration) error

+ func (runner *Runner) Worker(id string, stop <-chan struct{}) (Worker, error)

+ type RunnerParams struct

+ Clock Clock

+ IsFatal func(error) bool

+ Logger Logger

+ MoreImportant func(err0, err1 error) bool

+ RestartDelay time.Duration

+ type Worker interface

+ Kill func()

+ Wait func() error