mqtt

package

v0.9.0 Latest Latest Go to latest Published: Aug 23, 2025 License: MIT Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Connection struct {
	Opts         Opts
	StateManager *baby.StateManager
}

Connection - MQTT context

func NewConnection(opts Opts) *Connection

NewConnection - constructor

func (conn *Connection) Run(manager *baby.StateManager, ctx utils.GracefulContext)

Run - runs the mqtt connection handler

type Opts struct {
	BrokerURL string
	ClientID  string

	Username string
	Password string

	TopicPrefix string
}

Opts - holds configuration needed to establish connection to the broker