workers

type DefaultWorker struct{}

type Handler interface {
	Handle(ctx context.Context, job jobs.Job) error
}

type PoolOptionFunc func(p *WorkerPool) *WorkerPool

type Queue interface {
	Poll(ctx context.Context) (jobs.Job, error)
	RequeueTimedOutJobs(ctx context.Context, timeout time.Duration) error
}

type Spawner interface {
	Spawn(runner)
	Wait()
	Shutdown()
	Done() <-chan struct{}
}

type Worker interface {
	Execute(ctx context.Context, job jobs.Job) (interface{}, error)
	OnFailure(ctx context.Context, job jobs.Job) error
}

type WorkerFunc func(ctx context.Context, job jobs.Job) (interface{}, error)

type WorkerOptionFunc func(workerConfig) workerConfig

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