mqtt

package

v0.14.0 Latest Latest Go to latest Published: Aug 5, 2026 License: MIT Imports: 4 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Client struct {
	Conf Config
	mqtt.Client
}

func (c *Client) Close() error

Close disconnects the MQTT client with a 5ms quiesce period.

func (c *Client) Config() any

Config returns the embedded Conf as the configuration for injection.

func (c *Client) Init() error

Init creates and connects the MQTT client.

type Config struct {
	*mqtt.ClientOptions
	Brokers    []string
	CAFile     string `json:"ca_file,omitempty"`
	ServerName string
}

func (c *Config) AfterInject()

AfterInject calls Init to finalize broker addresses and TLS config.

func (c *Config) BeforeInject()

BeforeInject initializes the embedded ClientOptions with MQTT defaults.

func (c *Config) Build() (mqtt.Client, error)

Build creates an MQTT client, connects to all configured brokers, and returns it.

func (c *Config) Init() *Config

Init sets up TLS and broker addresses, logs warnings for unset timeouts.