mqtt_utils

Documentation

Index

• type MQTTClient
  • func NewMQTTClient(config MQTTConfiguration, topicMap map[string]byte, ...) *MQTTClient
  • func (c *MQTTClient) ConnectionLostHandler(client mqtt.Client, err error)
  • func (c *MQTTClient) OnConnectHandler(client mqtt.Client)
  • func (c *MQTTClient) Publish(r *MQTTPublishRequest) ([]byte, error)
  • func (c *MQTTClient) Subscribe(topicMap map[string]byte, callback func(client mqtt.Client, msg mqtt.Message))
  • func (c *MQTTClient) SubscribeDefault()
  • func (c *MQTTClient) Unsubscribe(topicList []string)
• type MQTTConfiguration
• type MQTTHandler
• type MQTTPublishRequest
  • func NewMQTTPublishRequest(topic string, qos byte, retained bool, payload any) *MQTTPublishRequest

Types

type MQTTClient

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

func NewMQTTClient

func NewMQTTClient(config MQTTConfiguration, topicMap map[string]byte, defaultCallback mqtt.MessageHandler) *MQTTClient

func (*MQTTClient) ConnectionLostHandler

func (c *MQTTClient) ConnectionLostHandler(client mqtt.Client, err error)

func (*MQTTClient) OnConnectHandler

func (c *MQTTClient) OnConnectHandler(client mqtt.Client)

func (*MQTTClient) Publish

func (c *MQTTClient) Publish(r *MQTTPublishRequest) ([]byte, error)

func (*MQTTClient) Subscribe

func (c *MQTTClient) Subscribe(topicMap map[string]byte, callback func(client mqtt.Client, msg mqtt.Message))

func (*MQTTClient) SubscribeDefault

func (c *MQTTClient) SubscribeDefault()

func (*MQTTClient) Unsubscribe

func (c *MQTTClient) Unsubscribe(topicList []string)

type MQTTConfiguration

type MQTTConfiguration struct {
	ID       string `yaml:"id"`
	URL      string `yaml:"url"`
	Username string `yaml:"username"`
	Password string `yaml:"password"`
}

type MQTTHandler

type MQTTHandler interface {
	OnConnectHandler(client mqtt.Client)
	ConnectionLostHandler(client mqtt.Client, err error)
}

type MQTTPublishRequest

type MQTTPublishRequest struct {
	Topic    string
	Qos      byte
	Retained bool
	Payload  any
}

func NewMQTTPublishRequest

func NewMQTTPublishRequest(topic string, qos byte, retained bool, payload any) *MQTTPublishRequest