workermanager

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

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 struct {
	Environment string
	Metrics     *observability.Metrics
}