lib

Documentation

Index

• func CreateMQTTClient(mqttBroker string) (mqtt.Client, error)
• func Prefixify(topicPrefix, subtopic string) string
• type BaseMQTTBridge
  • func (bridge *BaseMQTTBridge) PublishBytesMQTT(subtopic string, message []byte, retained bool)
  • func (bridge *BaseMQTTBridge) PublishJSONMQTT(subtopic string, obj any, retained bool)
  • func (bridge *BaseMQTTBridge) PublishStringMQTT(subtopic string, message string, retained bool)

Functions

func CreateMQTTClient

func CreateMQTTClient(mqttBroker string) (mqtt.Client, error)

func Prefixify

func Prefixify(topicPrefix, subtopic string) string

Types

type BaseMQTTBridge

type BaseMQTTBridge struct {
	MQTTClient  mqtt.Client
	TopicPrefix string
}

func (*BaseMQTTBridge) PublishBytesMQTT

func (bridge *BaseMQTTBridge) PublishBytesMQTT(subtopic string, message []byte, retained bool)

func (*BaseMQTTBridge) PublishJSONMQTT

func (bridge *BaseMQTTBridge) PublishJSONMQTT(subtopic string, obj any, retained bool)

func (*BaseMQTTBridge) PublishStringMQTT

func (bridge *BaseMQTTBridge) PublishStringMQTT(subtopic string, message string, retained bool)