workers

Documentation

Index

• Variables
• type DeadlockHandler
• type Worker
• type WorkerConfig
• type WorkerFactory
• type WorkerPool
  • func (wp WorkerPool) Run() error
  • func (wp WorkerPool) RunWithContext(ctx context.Context, onDeadlock DeadlockHandler, log *logrus.Entry) error

Variables

var WorkerDeadlocked = errors.New("Worker deadlocked")

Types

type DeadlockHandler

type DeadlockHandler func() error

type Worker

type Worker interface {
	Name() string
	Start(ctx context.Context, eg *errgroup.Group) error
}

type WorkerConfig

type WorkerConfig struct {
	// Should this worker run?
	Enabled bool `mapstructure:"enabled"`
	// Restart delay in seconds
	RestartDelay uint `mapstructure:"restart-delay"`
}

type WorkerFactory

type WorkerFactory func() (Worker, *WorkerConfig, error)

type WorkerPool

type WorkerPool []WorkerFactory

func (WorkerPool) Run

func (wp WorkerPool) Run() error

func (WorkerPool) RunWithContext

func (wp WorkerPool) RunWithContext(ctx context.Context, onDeadlock DeadlockHandler, log *logrus.Entry) error