Versions in this module Expand all Collapse all v0 v0.0.1 Mar 21, 2025 Changes in this version + var S scheduler + func WithClearCallback[T any](callback clearCallback[T]) func(hub *TimeoutQueueHub[T]) + func WithTickTime[T any](tickTime time.Duration) func(hub *TimeoutQueueHub[T]) + func WithTimeoutCallback[T any](callback timeoutCallback[T]) func(hub *TimeoutQueueHub[T]) + type DelayQueue struct + func (q *DelayQueue[T]) Clear(callback clearCallBack[T]) + func (q *DelayQueue[T]) DelayPop(value *time.Time) *queueItem[T] + func (q *DelayQueue[T]) IsEmpty() bool + func (q *DelayQueue[T]) Pop() *queueItem[T] + func (q *DelayQueue[T]) Push(delay *time.Time, data T) + type TimeoutQueue struct + func (tq *TimeoutQueue[T]) Clear() + func (tq *TimeoutQueue[T]) Init() + func (tq *TimeoutQueue[T]) Push(data T, expire *time.Time) + type TimeoutQueueHub struct + func NewTimeoutQueueHub[T any](opts ...func(hub *TimeoutQueueHub[T])) *TimeoutQueueHub[T] + func (hub *TimeoutQueueHub[T]) GetQueue(ctx context.Context, queueName string) *TimeoutQueue[T]
Go to main page