redis

package

v0.0.29 Latest Latest Go to latest Published: Sep 4, 2026 License: MIT Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Redis struct {
	// contains filtered or unexported fields
}

Redis Redis Stream 队列实现。

func NewRedis(redisCfg *configv1.Data_Redis, queueCfg *configv1.Data_Queue) (*Redis, error)

NewRedis 创建 Redis 队列实现。

func (s *Redis) Append(stream string, message data.Message) error

Append 追加消息到 Redis 队列。

func (s *Redis) Register(stream string, fn data.ConsumerFunc)

Register 注册 Redis 队列消费处理函数，并在首次注册后自动启动消费循环。

func (s *Redis) Run()

Run 启动 Redis 队列消费，并阻塞等待其结束。

func (s *Redis) Shutdown()

Shutdown 关闭 Redis 队列消费。