queue

package module

v0.0.24 Latest Latest Go to latest Published: Aug 18, 2026 License: MIT Imports: 6 Imported by: 1

Details

This section is empty.

This section is empty.

This section is empty.

type Queue interface {
	Append(stream string, message data.Message) error
	Register(stream string, fn data.ConsumerFunc)
	Run()
	Shutdown()
}

Queue 定义统一的队列操作接口。

func NewQueue(redisConf *configv1.Data_Redis, queueConf *configv1.Data_Queue) (Queue, func(), error)

NewQueue 根据配置创建内存或 Redis 队列实例。