mqtt

package
v2.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 18, 2023 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL