mqtt

Documentation

Index

• type MQTTClient
  • func StartNewMQTTClient(opts *MQTTOptions) (*MQTTClient, error)
  • func (mqttClient *MQTTClient) PublishMessage(topic string, message string)
• type MQTTOptions
  • func ParseConfig(config config.MQTTConfig) (*MQTTOptions, error)

Types

type MQTTClient

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

func StartNewMQTTClient

func StartNewMQTTClient(opts *MQTTOptions) (*MQTTClient, error)

func (*MQTTClient) PublishMessage

func (mqttClient *MQTTClient) PublishMessage(topic string, message string)

type MQTTOptions

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

func ParseConfig

func ParseConfig(config config.MQTTConfig) (*MQTTOptions, error)