redis

Sep 30, 2022

Changes in this version

+ type BrokerOption func(*Broker)

+ func WithReceiveTimeout(timeout time.Duration) BrokerOption

Jul 2, 2022

Changes in this version

+ const DefaultReceiveTimeout

+ type Broker struct

+ func NewBroker(options ...Option) *Broker

+ func (br *Broker) Observe(queues []string)

+ func (br *Broker) Receive() ([]byte, error)

+ func (br *Broker) Send(m []byte, q string) error

+ type Option func(*Broker)

+ func WithLogger(logger log.Logger) Option

+ func WithPool(pool *redis.Pool) Option