delay_queue

README

delay_queue

Go delay queue

Documentation

Index

• Variables
• 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
  • 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
  • func (tq *TimeoutQueue[T]) Clear()
  • func (tq *TimeoutQueue[T]) Init()
  • func (tq *TimeoutQueue[T]) Push(data T, expire *time.Time)
• type TimeoutQueueHub
  • func NewTimeoutQueueHub[T any](opts ...func(hub *TimeoutQueueHub[T])) *TimeoutQueueHub[T]
  • func (hub *TimeoutQueueHub[T]) GetQueue(ctx context.Context, queueName string) *TimeoutQueue[T]

Variables

var S scheduler

Functions

func WithClearCallback

func WithClearCallback[T any](callback clearCallback[T]) func(hub *TimeoutQueueHub[T])

func WithTickTime

func WithTickTime[T any](tickTime time.Duration) func(hub *TimeoutQueueHub[T])

func WithTimeoutCallback

func WithTimeoutCallback[T any](callback timeoutCallback[T]) func(hub *TimeoutQueueHub[T])

Types

type DelayQueue

type DelayQueue[T any] struct {
	// contains filtered or unexported fields
}

func (*DelayQueue[T]) Clear

func (q *DelayQueue[T]) Clear(callback clearCallBack[T])

func (*DelayQueue[T]) DelayPop

func (q *DelayQueue[T]) DelayPop(value *time.Time) *queueItem[T]

func (*DelayQueue[T]) IsEmpty

func (q *DelayQueue[T]) IsEmpty() bool

func (*DelayQueue[T]) Pop

func (q *DelayQueue[T]) Pop() *queueItem[T]

func (*DelayQueue[T]) Push

func (q *DelayQueue[T]) Push(delay *time.Time, data T)

type TimeoutQueue

type TimeoutQueue[T any] struct {
	// contains filtered or unexported fields
}

func (*TimeoutQueue[T]) Clear

func (tq *TimeoutQueue[T]) Clear()

func (*TimeoutQueue[T]) Init

func (tq *TimeoutQueue[T]) Init()

func (*TimeoutQueue[T]) Push

func (tq *TimeoutQueue[T]) Push(data T, expire *time.Time)

type TimeoutQueueHub

type TimeoutQueueHub[T any] struct {
	// contains filtered or unexported fields
}

func NewTimeoutQueueHub

func NewTimeoutQueueHub[T any](opts ...func(hub *TimeoutQueueHub[T])) *TimeoutQueueHub[T]

func (*TimeoutQueueHub[T]) GetQueue

func (hub *TimeoutQueueHub[T]) GetQueue(ctx context.Context, queueName string) *TimeoutQueue[T]