messaging

Documentation

Index

• func WrapHandler[T any](handler func(T)) MQTT.MessageHandler
• type MQTTClient
  • func StartMQTTClient(url, port, clientID string) MQTTClient
  • func (c *MQTTClient) Close()
  • func (c *MQTTClient) SendMessage(topic string, message string)
  • func (c *MQTTClient) SubscribeToThermostat(topic string, handler func(models.SensorState))
  • func (c *MQTTClient) SubscribeToValves(topic string, handler func(map[string]any))
• type MessageClient

Functions

func WrapHandler

func WrapHandler[T any](handler func(T)) MQTT.MessageHandler

Types

type MQTTClient

type MQTTClient struct {
	// contains filtered or unexported fields
}

func StartMQTTClient

func StartMQTTClient(url, port, clientID string) MQTTClient

func (*MQTTClient) Close

func (c *MQTTClient) Close()

func (*MQTTClient) SendMessage

func (c *MQTTClient) SendMessage(topic string, message string)

func (*MQTTClient) SubscribeToThermostat

func (c *MQTTClient) SubscribeToThermostat(topic string, handler func(models.SensorState))

func (*MQTTClient) SubscribeToValves

func (c *MQTTClient) SubscribeToValves(topic string, handler func(map[string]any))

type MessageClient

type MessageClient interface {
	Close()
	SendMessage(topic string, message string)
	SubscribeToThermostat(topic string, handler func(models.SensorState))
	SubscribeToValves(topic string, handler func(map[string]any))
}