Method Requeue

pkg/flushqueues/exclusivequeues.go:42–45

Requeue adds an op that is presumed to already be covered by activeKeys

(op T)

// Requeue adds an op that is presumed to already be covered by activeKeys
func (f *ExclusiveQueues[T]) Requeue(op T) error {
	_, err := f.queue.Enqueue(op)
	return err
}

// Clear unblocks the requested op.  This should be called only after a flush has been successful
func (f *ExclusiveQueues[T]) Clear(op T) {