workers

Documentation

Index

• type Worker
• type Workers
  • func NewWorkers(log *slog.Logger) *Workers
  • func (r *Workers) Add(w Worker) *Workers
  • func (r *Workers) AddFunc(name string, run func(ctx context.Context) error) *Workers
  • func (r *Workers) AllHealthy() bool
  • func (r *Workers) AnyCrashed() bool
  • func (r *Workers) Drain(timeout time.Duration)
  • func (r *Workers) Start(ctx context.Context)

Types

type Worker

type Worker interface {
	Name() string
	Run(ctx context.Context) error
}

type Workers

type Workers struct {
	// contains filtered or unexported fields
}

func NewWorkers

func NewWorkers(log *slog.Logger) *Workers

func (*Workers) Add

func (r *Workers) Add(w Worker) *Workers

func (*Workers) AddFunc

func (r *Workers) AddFunc(name string, run func(ctx context.Context) error) *Workers

func (*Workers) AllHealthy

func (r *Workers) AllHealthy() bool

func (*Workers) AnyCrashed

func (r *Workers) AnyCrashed() bool

func (*Workers) Drain

func (r *Workers) Drain(timeout time.Duration)

func (*Workers) Start

func (r *Workers) Start(ctx context.Context)