Method Enqueue

pkg/flushqueues/exclusivequeues.go:24–31

Enqueue adds the op to the queue and prevents any other items to be added with this key

(op T)

// Enqueue adds the op to the queue and prevents any other items to be added with this key
func (f *ExclusiveQueues[T]) Enqueue(op T) error {
	_, loaded := f.activeKeys.LoadOrStore(op.Key(), struct{}{})
	if loaded {
		return nil
	}

	return f.Requeue(op)
}

// Dequeue removes the next op from the queue. After dequeueing the calling
// process either needs to call Clear or Requeue.