queue

Jul 13, 2026

Changes in this version

+ type Queue interface

+ Append func(stream string, message data.Message) error

+ Register func(stream string, fn data.ConsumerFunc)

+ Run func()

+ Shutdown func()

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