Versions in this module Expand all Collapse all v0 v0.3.0 Mar 9, 2022 v0.2.0 Jan 5, 2022 Changes in this version + var ErrUnavailable = errors.New("runner is unavailable") + type Option func(*options) + func WithLogger(logger *zap.Logger) Option + func WithStopTimeout(timeout time.Duration) Option + func WithTimeoutTaskHandler(handler func(tasks []string, timeAfterStop time.Duration)) Option + type Stopper struct + func NewStopper(name string, opts ...Option) *Stopper + func (s *Stopper) RunNamedTask(ctx context.Context, name string, task func(context.Context)) error + func (s *Stopper) RunTask(ctx context.Context, task func(context.Context)) error + func (s *Stopper) Stop()
Go to main page