dqueue

Documentation

Index

• type DelayQueue
  • func NewDelayQueue(name string, interval time.Duration, rd *redis.Client, handler Handler) *DelayQueue
  • func (dq *DelayQueue) Push(ctx context.Context, req *delay.DelayTaskRequest) error
  • func (dq *DelayQueue) Start()
  • func (dq *DelayQueue) Stop()
• type Handler

Types

type DelayQueue

type DelayQueue struct {
	Name string
	// contains filtered or unexported fields
}

func NewDelayQueue

func NewDelayQueue(name string, interval time.Duration, rd *redis.Client, handler Handler) *DelayQueue

func (*DelayQueue) Push

func (dq *DelayQueue) Push(ctx context.Context, req *delay.DelayTaskRequest) error

func (*DelayQueue) Start

func (dq *DelayQueue) Start()

func (*DelayQueue) Stop

func (dq *DelayQueue) Stop()

type Handler

type Handler func(taskID int64) error