Method GetSnapshot

pkg/task/queue/task_queue.go:1080–1082

GetSnapshot returns a copy of all tasks in the queue. This is useful for external iteration or processing without holding locks. The returned slice is a snapshot at the time of the call and will not reflect subsequent changes to the queue.

()

// The returned slice is a snapshot at the time of the call and will not reflect
// subsequent changes to the queue.
func (q *TaskQueue) GetSnapshot() []task.Task {
	return q.storage.GetSnapshot()
}

// DeleteFunc runs fn on every task and removes each task for which fn returns false.
func (q *TaskQueue) DeleteFunc(fn func(task.Task) bool) {