Struct TaskQueue

pkg/task/queue/task_queue.go:98–137

}

type TaskQueue struct {
	logger *log.Logger

	m             sync.RWMutex
	metricStorage metricsstorage.Storage
	ctx           context.Context
	cancel        context.CancelFunc

	waitInProgress atomic.Bool
	cancelDelay    atomic.Bool

	storage *TaskStorage

	started atomic.Bool // a flag to ignore multiple starts

	Name    string
	Handler func(ctx context.Context, t task.Task) TaskResult
	status  *TaskQueueStatus

	measureActionFn     func()
	measureActionFnOnce sync.Once

	// Timing settings.
	WaitLoopCheckInterval time.Duration
	DelayOnQueueIsEmpty   time.Duration
	DelayOnRepeat         time.Duration
	ExponentialBackoffFn  func(failureCount int) time.Duration

	// Compaction
	compactionCallback func(compactedTasks []task.Task, targetTask task.Task)

	compactableTypes map[task.TaskType]struct{}

	queueTasksCounter *TaskCounter

	// Pre-allocated buffers for compaction
	contextBuffer   []bindingcontext.BindingContext
	monitorIDBuffer []string
	groupBuffer     map[string]*compactionGroup
}

// TaskQueueOption defines a functional option for TaskQueue configuration
type TaskQueueOption func(*TaskQueue)