Versions in this module Expand all Collapse all v1 v1.0.2 Jul 4, 2018 Changes in this version + func NewHandler(p *redis.Pool, c Config) (handler.Handler, error) + type Config struct + AckTopicTemplate string + CACert string + CleanSession bool + ClientID string + DownlinkTopicTemplate string + ErrorTopicTemplate string + JoinTopicTemplate string + Password string + QOS uint8 + Server string + TLSCert string + TLSKey string + UplinkTopicTemplate string + Username string + type MQTTHandler struct + func (h *MQTTHandler) Close() error + func (h *MQTTHandler) DataDownChan() chan handler.DataDownPayload + func (h *MQTTHandler) SendACKNotification(payload handler.ACKNotification) error + func (h *MQTTHandler) SendDataUp(payload handler.DataUpPayload) error + func (h *MQTTHandler) SendErrorNotification(payload handler.ErrorNotification) error + func (h *MQTTHandler) SendJoinNotification(payload handler.JoinNotification) error
Go to main page