Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MQTTPublish ¶
type MQTTPublish struct { In <-chan string // contains filtered or unexported fields }
func NewMQTTPublish ¶
func NewMQTTPublish(logger *zap.SugaredLogger, client mqtt.Client, topic string) *MQTTPublish
func (*MQTTPublish) Process ¶
func (m *MQTTPublish) Process()
type MQTTReceive ¶
type MQTTReceive struct { Out chan<- string // contains filtered or unexported fields }
func NewMQTTReceive ¶
func NewMQTTReceive(logger *zap.SugaredLogger, client mqtt.Client, topic string) *MQTTReceive
func (*MQTTReceive) Process ¶
func (m *MQTTReceive) Process()
Click to show internal directories.
Click to hide internal directories.