mqtt

type Factory struct {
}

type HandlerSettings struct {
	Topic      string `md:"topic,required"` // The topic to listen on
	ReplyTopic string `md:"replyTopic"`     // The topic to reply on
	Qos        int    `md:"qos"`            // The Quality of Service
	Retain     bool   `md:"retain"`         // Retain messages
	AssetName  string `md:"assetName"`
	SensorName string `md:"sensorName"`
	SensorType string `md:"sensorType"`
}

type Output struct {
	Message     string            `md:"message"`     // The message recieved
	Topic       string            `md:"topic"`       // The MQTT topic
	TopicParams map[string]string `md:"topicParams"` // The topic parameters
	AssetName   string            `md:"assetName"`
	SensorName  string            `md:"sensorName"`
	SensorType  string            `md:"sensorType"`
}

type Reply struct {
	Data interface{} `md:"data"` // The data to reply with
}

type Settings struct {
	Broker        string                 `md:"broker,required"` // The broker URL
	Id            string                 `md:"id,required"`     // The id of client
	Username      string                 `md:"username"`        // The user's name
	Password      string                 `md:"password"`        // The user's password
	Store         string                 `md:"store"`           // The store for message persistence
	CleanSession  bool                   `md:"cleanSession"`    // Clean session flag
	KeepAlive     int                    `md:"keepAlive"`       // Keep Alive time in seconds
	AutoReconnect bool                   `md:"autoReconnect"`   // Enable Auto-Reconnect
	SSLConfig     map[string]interface{} `md:"sslConfig"`       // SSL Configuration
}

type Token struct {
	TokenType TokenType
	Token     string
}

type TokenType int

type Topic []Token

type Trigger struct {
	// contains filtered or unexported fields
}