Versions in this module Expand all Collapse all v1 v1.0.0 Feb 27, 2025 Changes in this version + type DelayMessage struct + Delay time.Duration + ID string + Payload json.RawMessage + Timestamp time.Time + Topic string + type DelayQueue struct + func NewDelayQueue(client *redis.Client) *DelayQueue + func (q *DelayQueue) Pop(ctx context.Context, topic string) (*DelayMessage, error) + func (q *DelayQueue) Push(ctx context.Context, msg *DelayMessage) error
Go to main page