Documentation ¶
Index ¶
- type MQTTService
- func (m *MQTTService) Close()
- func (m *MQTTService) Get() <-chan MessageFromBroker
- func (m *MQTTService) Put(msg MessageFromBroker)
- func (m *MQTTService) RegisterMqttClient(clientID string, brokerURL string, topicsToSub []string, deviceCert string, ...) error
- func (m *MQTTService) UserInputPubHandler(topic string, message string)
- type MessageFromBroker
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MQTTService ¶
type MQTTService struct {
// contains filtered or unexported fields
}
func NewMQTTService ¶
func NewMQTTService() *MQTTService
func (*MQTTService) Close ¶
func (m *MQTTService) Close()
func (*MQTTService) Get ¶
func (m *MQTTService) Get() <-chan MessageFromBroker
func (*MQTTService) Put ¶
func (m *MQTTService) Put(msg MessageFromBroker)
func (*MQTTService) RegisterMqttClient ¶
func (*MQTTService) UserInputPubHandler ¶
func (m *MQTTService) UserInputPubHandler(topic string, message string)
type MessageFromBroker ¶
Click to show internal directories.
Click to hide internal directories.