mqtt

package
v0.0.0-...-7dcaf7b Latest Latest
Warning

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

Go to latest
Published: Mar 20, 2023 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source
const (
	PluginMQTT = "mqtt"
)

Constants in serial device

Variables

This section is empty.

Functions

func NewDevice

func NewDevice(ID string, config cmap.CustomMap, rxFunc func(msg *model.Message), statusFunc func(state *model.State)) (deviceType.Plugin, error)

NewDevice mqtt driver

Types

type Config

type Config struct {
	Name             string `yaml:"name"`
	Broker           string `yaml:"broker"`
	Insecure         bool   `yaml:"insecure"`
	Username         string `yaml:"username"`
	Password         string `yaml:"password" json:"-"`
	Subscribe        string `yaml:"subscribe"`
	Publish          string `yaml:"publish"`
	QoS              int    `yaml:"qos"`
	TransmitPreDelay string `yaml:"transmit_pre_delay"`
	ReconnectDelay   string `yaml:"reconnect_delay"`
}

Config struct

type Endpoint

type Endpoint struct {
	ID     string
	Config *Config

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

Endpoint data

func (*Endpoint) Close

func (ep *Endpoint) Close() error

Close the driver

func (*Endpoint) Name

func (ep *Endpoint) Name() string

func (*Endpoint) Subscribe

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

Subscribe a topic

func (*Endpoint) Write

func (ep *Endpoint) Write(message *model.Message) error

Write publishes a payload

Jump to

Keyboard shortcuts

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