Documentation ¶
Index ¶
- Variables
- func AddToQueue(client mqtt.Client, msg mqtt.Message, handler func(mqtt.Client, mqtt.Message))
- func Blind(client mqtt.Client, msg mqtt.Message)
- func Command(client mqtt.Client, msg mqtt.Message)
- func Dimmer(client mqtt.Client, msg mqtt.Message)
- func GetMQTTClientConnection() mqtt.Client
- func HandleMQTTQueue()
- func HandleQueue()
- func ParseMessage(msg mqtt.Message) (deviceid int64, state int, level int, x int64, y int64, color_temp int, ...)
- func Restart()
- func SendTopic(topic string, payload []byte, retained bool) error
- func SetHex(client mqtt.Client, msg mqtt.Message)
- func Start(wg *sync.WaitGroup, status_channel chan (error))
- func State(client mqtt.Client, msg mqtt.Message)
- func Stop()
- func Subscribe(client mqtt.Client, status_channel chan (error))
- type MQTTQueueItem
- type MQTTStateMessage
- type MQTTStatePayload
- type MQTTboolPayload
- type MQTTgwConfig
- type MQTTpayload
- type MQTTstatus
- type QueueItem
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrorBrokerConnectionRefused = errors.New("Bronker Error: Connection refused")
View Source
var ItemQueue []QueueItem
Functions ¶
func AddToQueue ¶
func GetMQTTClientConnection ¶
func HandleMQTTQueue ¶
func HandleMQTTQueue()
func HandleQueue ¶
func HandleQueue()
func ParseMessage ¶
Types ¶
type MQTTQueueItem ¶
type MQTTStateMessage ¶
type MQTTStatePayload ¶
type MQTTStatePayload struct {
State string
}
type MQTTboolPayload ¶
type MQTTboolPayload struct {
Value string
}
type MQTTgwConfig ¶
type MQTTpayload ¶
type MQTTpayload struct {
Value int64
}
type MQTTstatus ¶
Click to show internal directories.
Click to hide internal directories.