workermanager

Documentation

Index

• Constants
• func NewWorkerManager(spec WorkerManagerSpec) *serviceWorkerManager
• type BackgroundJobEnqueuer
• type WorkerManager
• type WorkerManagerSpec

Constants

const MaxOperandRequeue = math.MaxInt32

TODO: set a reasonable value for this based on metrics and testing.

Functions

func NewWorkerManager

func NewWorkerManager(spec WorkerManagerSpec) *serviceWorkerManager

Types

type BackgroundJobEnqueuer

type BackgroundJobEnqueuer interface {
	Enqueue(operand interface{}) error
	EnqueueAfter(operand interface{}, after time.Duration) error
	EnqueueAfterCommit(ctx context.Context, operand interface{}) error
}

type WorkerManager

type WorkerManager interface {
	Start(ctx context.Context) error
	Find(operand interface{}) workerlib.Worker
	RegisterWorker(worker workerlib.Worker, operand interface{})
	Stop(drain bool)
	BackgroundJobEnqueuer
}

type WorkerManagerSpec

type WorkerManagerSpec struct {
	Environment string
	Metrics     *observability.Metrics
}