worker

type TaskHandler func(ctx context.Context, task *models.TaskInfo, queue *queue.Queue) error

type TaskWorkerPool interface {
	// StartWorkerPool starts background processes and workers
	// Should be run as a go routine.
	StartWorkerPool(ctx context.Context)
	// StartWorkers Starts workers up to number numWorkers defined in config.
	StartWorkers(ctx context.Context)
	// Stop Gracefully stops all workers
	Stop()
	// HeartbeatListener requeues tasks of workers whose heartbeats do not refresh within heartbeat duration
	HeartbeatListener(ctx context.Context)
	// ListenForCancelledTasks listens for task cancellation notifications
	ListenForCancelledTasks(ctx context.Context)
	// RequeueFailedTasks requeues failed tasks at regular intervals
	RequeueFailedTasks(ctx context.Context)
	// RegisterHandler assigns a function of type TaskHandler to a typename.
	// This function is the action performed to tasks of typename taskType.
	RegisterHandler(taskType string, handler TaskHandler)
}

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