mqtt

Documentation

Index

• Variables
• type MQTTBroker
  • func NewBroker(opts ...Option) (*MQTTBroker, error)
  • func (m *MQTTBroker) Connect() error
  • func (m *MQTTBroker) ConnectAndSubscribe(subHandler broker.Handler, subTopics []string) error
  • func (m *MQTTBroker) Disconnect() error
  • func (m *MQTTBroker) Publish(topic string, payload interface{}) error
  • func (m *MQTTBroker) String() string
  • func (m *MQTTBroker) Subscribe(topics []string, h broker.Handler) error
• type Option
  • func WithClientID(id string) Option
  • func WithLogger(logger *zap.Logger) Option
  • func WithPassword(password string) Option
  • func WithURL(u string) Option
  • func WithUsername(username string) Option

Variables

var ErrNoConnection = errors.New("no connection to broker server")

Types

type MQTTBroker

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

MQTTBroker implements broker.Broker interface.

func NewBroker

func NewBroker(opts ...Option) (*MQTTBroker, error)

NewBroker creates new mqtt broker.

func (*MQTTBroker) Connect

func (m *MQTTBroker) Connect() error

func (*MQTTBroker) ConnectAndSubscribe

func (m *MQTTBroker) ConnectAndSubscribe(subHandler broker.Handler, subTopics []string) error

connect and update option to auto resubscribe with option OnConnect

func (*MQTTBroker) Disconnect

func (m *MQTTBroker) Disconnect() error

func (*MQTTBroker) Publish

func (m *MQTTBroker) Publish(topic string, payload interface{}) error

func (*MQTTBroker) String

func (m *MQTTBroker) String() string

func (*MQTTBroker) Subscribe

func (m *MQTTBroker) Subscribe(topics []string, h broker.Handler) error

type Option

type Option func(m *MQTTBroker) error

func WithClientID

func WithClientID(id string) Option

WithClientID returns an Option which set the broker client id.

func WithLogger

func WithLogger(logger *zap.Logger) Option

WithLogger returns an Option which set the logger to use when connect to server.

func WithPassword

func WithPassword(password string) Option

WithPassword returns an Option which set the password use to connect to server.

func WithURL

func WithURL(u string) Option

WithURL returns an Option which set the broker url.

func WithUsername

func WithUsername(username string) Option

WithUsername returns an Option which set the username use to connect to server.