subscribe

Documentation

Index

• type Subscriber
  • func New(logger *zap.Logger, opts option.Options) *Subscriber
  • func (s *Subscriber) Subscribe(clients []mqtt.Client)

Types

type Subscriber

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

func New

func New(logger *zap.Logger, opts option.Options) *Subscriber

func (*Subscriber) Subscribe

func (s *Subscriber) Subscribe(clients []mqtt.Client)

Subscribe start subscribing with goroutines. please note that this isn't a blocking function.