Versions in this module Expand all Collapse all v1 v1.1.5 Mar 31, 2025 v1.1.4 Mar 14, 2025 v1.1.3 Feb 28, 2025 v1.1.2 Feb 17, 2025 v1.1.0 Jan 11, 2025 v1.0.0 Dec 16, 2024 Changes in this version + type RedisConfig struct + Db int + Enabled bool + Host string + Password string + PoolSize int + Port int + Username string + type RedisModule struct + func (module *RedisModule) Name() string + func (module *RedisModule) Setup() + func (module *RedisModule) Start() error + func (module *RedisModule) Stop() error + type RedisQueue struct + func (module *RedisQueue) Close(k string) error + func (module *RedisQueue) Consume(q *queue.QueueConfig, consumer *queue.ConsumerConfig, offsetStr string) (ctx *queue.Context, messages []queue.Message, timeout bool, err error) + func (module *RedisQueue) Depth(k string) int64 + func (module *RedisQueue) GetQueues() []string + func (module *RedisQueue) Init(k string) error + func (module *RedisQueue) LatestOffset(string) string + func (module *RedisQueue) Name() string + func (module *RedisQueue) Pop(k string, timeoutDuration time.Duration) (data []byte, timeout bool) + func (module *RedisQueue) Push(k string, v []byte) error
Go to main page