Method DeleteFunc

pkg/task/queue/task_queue.go:1085–1100

DeleteFunc runs fn on every task and removes each task for which fn returns false.

(fn func(task.Task) bool)

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

	defer q.MeasureActionTime("DeleteFunc")()

	q.storage.DeleteFunc(func(t task.Task) bool {
		if !fn(t) {
			q.queueTasksCounter.Remove(t)
			return false
		}

		return true
	})
}

// TODO define mapping method with QueueAction to insert, modify and delete tasks.