Method Iterate

pkg/task/queue/task_storage.go:206–213

Iterate iterates over all tasks in the queue with a callback

(fn func(*list.Element[task.Task]))

// Iterate iterates over all tasks in the queue with a callback
func (ts *TaskStorage) Iterate(fn func(*list.Element[task.Task])) {
	ts.mu.RLock()
	defer ts.mu.RUnlock()

	for e := ts.items.Front(); e != nil; e = e.Next() {
		fn(e)
	}
}

// RemoveElement removes an element from the list and updates the index
func (ts *TaskStorage) RemoveElement(element *list.Element[task.Task]) task.Task {