mqtt

Documentation

Index

• type Config
• type Endpoint
  • func New(logger *zap.Logger, gwCfg *gwTY.Config, protocol cmap.CustomMap, ...) (*Endpoint, error)
  • func (ep *Endpoint) Close() error
  • func (ep *Endpoint) Subscribe(topicsStr string) error
  • func (ep *Endpoint) Write(rawMsg *msgTY.RawMessage) error

Types

type Config

type Config struct {
	Type             string
	Broker           string
	Username         string
	Password         string
	Subscribe        string
	Publish          string
	QoS              int
	TransmitPreDelay string
	Insecure         bool
}

Config data

type Endpoint

type Endpoint struct {
	GatewayCfg *gwTY.Config
	Config     Config

	Client paho.Client
	// contains filtered or unexported fields
}

Endpoint data

func New

func New(logger *zap.Logger, gwCfg *gwTY.Config, protocol cmap.CustomMap, rxMsgFunc func(rm *msgTY.RawMessage) error, bus busTY.Plugin, logRootDir string) (*Endpoint, error)

New mqtt driver

func (*Endpoint) Close

func (ep *Endpoint) Close() error

Close the driver

func (*Endpoint) Subscribe

func (ep *Endpoint) Subscribe(topicsStr string) error

Subscribe topics supply comma separated topic names example: root/topic1/hello,root/topic2/#

func (*Endpoint) Write

func (ep *Endpoint) Write(rawMsg *msgTY.RawMessage) error

Write publishes a payload