redispubsub

Documentation

Index

• type Publisher
  • func NewPublisher(client redis.UniversalClient, channel string) *Publisher
  • func (p *Publisher) Publish(message string) error
• type Subscriber
  • func NewSubscriber(client redis.UniversalClient, channel string) *Subscriber
  • func (s *Subscriber) OnMessage(ctx context.Context, callback func(string)) error

Types

type Publisher

type Publisher struct {
	// contains filtered or unexported fields
}

func NewPublisher

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

func (*Publisher) Publish

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

type Subscriber

type Subscriber struct {
	// contains filtered or unexported fields
}

func NewSubscriber

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

func (*Subscriber) OnMessage

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