mqtt_generic

Documentation

Index

• Constants
• type MqttNode
  • func (mn *MqttNode) Clone() *MqttNode
• type MqttProtocol
  • func New(logger *zap.Logger, gwCfg *gwTY.Config, protocol cmap.CustomMap, ...) (*MqttProtocol, error)
  • func (mp *MqttProtocol) Close() error
  • func (mp *MqttProtocol) Post(msg *msgTY.Message) error
• type MqttProtocolConf

Constants

const (
	ScriptKeyDataIn   = "dataIn"
	ScriptKeyDataOut  = "dataOut"
	ScriptKeyTopicIn  = "topicIn"
	ScriptKeyTopicOut = "topicOut"
	ScriptKeyConfigIn = "configIn"

	DefaultNode = "default"
)

Types

type MqttNode

type MqttNode struct {
	Topic  string `json:"topic" yaml:"topic"`
	QoS    int    `json:"qos" yaml:"qos"`
	Script string `json:"script" yaml:"script"`
}

mqtt node config

func (*MqttNode) Clone

func (mn *MqttNode) Clone() *MqttNode

Clone cones the MqttNode

type MqttProtocol

type MqttProtocol struct {
	GatewayCfg *gwTY.Config
	Protocol   gwPtl.Protocol
	Config     *MqttProtocolConf
	// contains filtered or unexported fields
}

func New

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

returns a new generic mqtt protocol

func (*MqttProtocol) Close

func (mp *MqttProtocol) Close() error

closes the protocol

func (*MqttProtocol) Post

func (mp *MqttProtocol) Post(msg *msgTY.Message) error

posts a message to a topic

type MqttProtocolConf

type MqttProtocolConf struct {
	mqtt.Config
	Nodes map[string]MqttNode `json:"nodes" yaml:"nodes"`
}