redisnatsbroker

Dec 27, 2023

Changes in this version

+ type Broker struct

+ func New(nats *natsbroker.NatsBroker, redis *centrifuge.RedisBroker) (*Broker, error)

+ func (b *Broker) History(ch string, opts centrifuge.HistoryOptions) ([]*centrifuge.Publication, centrifuge.StreamPosition, error)

+ func (b *Broker) Publish(ch string, data []byte, opts centrifuge.PublishOptions) (centrifuge.StreamPosition, bool, error)

+ func (b *Broker) RemoveHistory(ch string) error