mqtt

Documentation

Index

• Variables
• type MQTTBroker
  • func NewBroker(opts ...Option) (*MQTTBroker, error)
  • func (m *MQTTBroker) Connect() 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 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) 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

WitClientID returns an Option which set the broker client id.

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.