Function WithContext

pkg/task/queue/task_queue.go:143–147

WithContext sets the context for the TaskQueue

(ctx context.Context)

// WithContext sets the context for the TaskQueue
func WithContext(ctx context.Context) TaskQueueOption {
	return func(q *TaskQueue) {
		q.ctx, q.cancel = context.WithCancel(ctx)
	}
}

// WithHandler sets the task handler for the TaskQueue
func WithHandler(fn func(ctx context.Context, t task.Task) TaskResult) TaskQueueOption {