Documentation ¶
Index ¶
- type DataDownPayload
- type MQTTHandler
- func (h *MQTTHandler) Close() error
- func (h *MQTTHandler) DataDownChan() chan DataDownPayload
- func (h *MQTTHandler) GetLostConnectTime() time.Time
- func (h *MQTTHandler) IsConnected() bool
- func (h *MQTTHandler) SendDataUp(payload interface{}) error
- func (h *MQTTHandler) SendSerDataUp(b []byte) error
- func (h *MQTTHandler) SubFirmware(topic string) chan []byte
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MQTTHandler ¶
type MQTTHandler struct { ClientID string ServerID string LostConnectTime time.Time Firmware chan []byte // contains filtered or unexported fields }
MQTTHandler ...
func (*MQTTHandler) DataDownChan ¶
func (h *MQTTHandler) DataDownChan() chan DataDownPayload
DataDownChan returns the channel containing the received DataDownPayload.
func (*MQTTHandler) GetLostConnectTime ¶
func (h *MQTTHandler) GetLostConnectTime() time.Time
GetLostConnectTime ..
func (*MQTTHandler) SendDataUp ¶
func (h *MQTTHandler) SendDataUp(payload interface{}) error
SendDataUp sends a DataUpPayload.
func (*MQTTHandler) SendSerDataUp ¶
func (h *MQTTHandler) SendSerDataUp(b []byte) error
SendSerDataUp sends a DataUpPayload.
func (*MQTTHandler) SubFirmware ¶
func (h *MQTTHandler) SubFirmware(topic string) chan []byte
SubFirmware ..
Click to show internal directories.
Click to hide internal directories.