broker

May 16, 2022

Changes in this version

+ func GetAllProvider() []interface

+ type Config struct

+ Approx bool

+ Limit int64

+ MaxLen int64

+ NoMkStream bool

+ Stream string

+ type RedisBroker struct

+ func NewRedisBroker() *RedisBroker

+ func (r *RedisBroker) Consumer(job constraint.Job)

+ func (r *RedisBroker) Init()

+ func (r *RedisBroker) Loop()

+ func (r *RedisBroker) Push(event interface{}, names ...string)

+ func (r *RedisBroker) SetConfig(client constraint.RedisClient, config ...Config)

+ func (r *RedisBroker) SetWorker(worker constraint.Worker)