Versions in this module Expand all Collapse all v0 v0.0.3 Aug 26, 2024 Changes in this version + func GetRedisQueue(diName string) queue.Queue + type RedisQueue struct + func (m *RedisQueue) AckMsg(ctx context.Context, key string, token string) (bool, error) + func (m *RedisQueue) BatchEnqueue(ctx context.Context, key string, messages []string) (bool, error) + func (m *RedisQueue) Dequeue(ctx context.Context, key string) (message string, tag string, token string, dequeueCount int64, err error) + func (m *RedisQueue) Enqueue(ctx context.Context, key string, message string) (bool, error)
Go to main page