mqtt

Documentation

Index

• Constants
• func NewDevice(ctx context.Context, ID string, config cmap.CustomMap, ...) (deviceType.Plugin, error)
• type Config
• type Endpoint
  • func (ep *Endpoint) Close() error
  • func (ep *Endpoint) Name() string
  • func (ep *Endpoint) Subscribe(topicsStr string) error
  • func (ep *Endpoint) Write(message *model.Message) error

Constants

const (
	PluginMQTT = "mqtt"
)

Constants in serial device

Functions

func NewDevice

func NewDevice(ctx context.Context, 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"`
	ConnectionTimeout string `yaml:"connection_timeout"`
}

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