redis

Mar 1, 2024

Changes in this version

+ type Publisher struct

+ func NewPublisher(ctx context.Context, client *redis.Client, ns Namespace) *Publisher

+ func (r *Publisher) Close() error

+ func (r *Publisher) Flush() error

+ func (r *Publisher) Write(channel api.Channel, payload []byte) error