redismq

Oct 18, 2024

Changes in this version

+ type MqCallback func(id string, data any)

+ type RedisMq struct

+ Consumer string

+ Group string

+ Prefix string

+ Streams []string

+ func NewRedisMq(redisOption *redis.Options, prefix string, group string) *RedisMq

+ func (t *RedisMq) Add(channel string, dataPtr any) error

+ func (t *RedisMq) Clean() error

+ func (t *RedisMq) On(channel string, cb MqCallback, dataPtr any) error

+ func (t *RedisMq) Start()