Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client interface {
Connect() error
Publish(topic string, obj any)
Disconnect()
Subscribe(topic string, callback mqtt.MessageHandler) error
}
func NewClientWithConfig ¶
func NewClientWithConfig(conf conf.MQTTConfig, monitor Monitor) Client
type Monitor ¶
type Monitor struct {
// contains filtered or unexported fields
}
func NewMQTTMonitor ¶
func NewMQTTMonitor(registry *monitoring.Registry) Monitor
Source Files
Click to show internal directories.
Click to hide internal directories.