redis

Jun 18, 2025

Changes in this version

+ const DefaultReceiveTimeout

+ type Broker struct

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

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

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

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

+ type BrokerOption func(*Broker)

+ func WithPool(pool *redis.Pool) BrokerOption

+ func WithReceiveTimeout(timeout time.Duration) BrokerOption