queues

type DelayQueue ¶

type DelayQueue[T any] struct {
	Items <-chan T
	// contains filtered or unexported fields
}

DelayQueue is a queue where items can only be pulled after a certain delay.

func NewDelayQueue[T any](ctx context.Context) *DelayQueue[T]

func (dq *DelayQueue[T]) Add(value T, delay time.Duration) uint

func (dq *DelayQueue[T]) Remove(id uint) bool