The highest tagged major version is v2.

mqtt

package

v1.0.0 Latest Latest Go to latest Published: Sep 28, 2026 License: MIT Imports: 14 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type MQTTChannel struct {
	*channels.BaseChannel
	// contains filtered or unexported fields
}

MQTTChannel implements the Channel interface for MQTT-based communication.

func NewMQTTChannel(bc *config.Channel, cfg *config.MQTTSettings, b *bus.MessageBus) (*MQTTChannel, error)

NewMQTTChannel creates a new MQTT channel instance.

func (c *MQTTChannel) Send(_ context.Context, msg bus.OutboundMessage) ([]string, error)

Send publishes a response to the client via MQTT.

func (c *MQTTChannel) Start(ctx context.Context) error

Start connects to the MQTT broker and begins listening for inbound messages.

func (c *MQTTChannel) Stop(_ context.Context) error

Stop disconnects from the MQTT broker.