subscriber

Documentation

Index

• type Subscriber
  • func NewSubscriber(logger *zap.Logger, brokerAddr string) *Subscriber
  • func (s *Subscriber) Subscribe(channel string) error

Types

type Subscriber

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

Subscriber is a message subscriber

func NewSubscriber

func NewSubscriber(logger *zap.Logger, brokerAddr string) *Subscriber

NewSubscriber returns a new Subscriber

func (*Subscriber) Subscribe

func (s *Subscriber) Subscribe(channel string) error

Subscribe subscribes to a channel