mqtt

Documentation

Index

• type Client
  • func NewClient(monitor Monitor) Client
  • func NewClientWithConfig(conf conf.MQTTConfig, monitor Monitor) Client
• type Monitor
  • func NewMQTTMonitor(registry *monitoring.Registry) Monitor

Types

type Client

type Client interface {
	Connect() error
	Publish(topic string, obj any)
	Disconnect()
	Subscribe(topic string, callback mqtt.MessageHandler) error
}

func NewClient

func NewClient(monitor Monitor) Client

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