Struct TaskStorage

pkg/task/queue/task_storage.go:11–15

TaskStorage encapsulates the queue data structures with their own mutex

// TaskStorage encapsulates the queue data structures with their own mutex
type TaskStorage struct {
	mu      sync.RWMutex
	items   *list.List[task.Task]
	idIndex map[string]*list.Element[task.Task]
}

// newTaskStorage creates a new TaskStorage instance
func newTaskStorage() *TaskStorage {