redispubsub

Apr 20, 2024

Changes in this version

+ type Publisher struct

+ func NewPublisher(client redis.UniversalClient, channel string) *Publisher

+ func (p *Publisher) Publish(message string) error

+ type Subscriber struct

+ func NewSubscriber(client redis.UniversalClient, channel string) *Subscriber

+ func (s *Subscriber) OnMessage(ctx context.Context, callback func(string)) error