pubsub

Documentation

Index

• func NewClient() *redis.Client
• type Notifier
  • func NewNotifier(client *redis.Client) *Notifier
  • func (s *Notifier) PublishMessage(c context.Context, channel, message string) error
• type Observer
  • func NewObserver(client *redis.Client, channel string, queueSize int) *Observer
  • func (o *Observer) ProcessMessages(handler func(msg string))
  • func (o *Observer) Subscribe(c context.Context)

Functions

func NewClient

func NewClient() *redis.Client

Types

type Notifier

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

func NewNotifier

func NewNotifier(client *redis.Client) *Notifier

func (*Notifier) PublishMessage

func (s *Notifier) PublishMessage(c context.Context, channel, message string) error

type Observer

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

func NewObserver

func NewObserver(client *redis.Client, channel string, queueSize int) *Observer

func (*Observer) ProcessMessages

func (o *Observer) ProcessMessages(handler func(msg string))

func (*Observer) Subscribe

func (o *Observer) Subscribe(c context.Context)