mqtt

Documentation

Index

• type Mqtt
  • func NewMqtt(lc fx.Lifecycle, cfg *MqttConfig) (mqtt *Mqtt)
  • func (m *Mqtt) NewClient(cfg *mqtt_client.Config) (c *mqtt_client.Client, err error)
  • func (m *Mqtt) Shutdown() error
  • func (m *Mqtt) Start() error
• type MqttConfig
  • func NewMqttConfig(cfg *config.AppConfig) *MqttConfig

Types

type Mqtt

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

func NewMqtt

func NewMqtt(lc fx.Lifecycle, cfg *MqttConfig) (mqtt *Mqtt)

func (*Mqtt) NewClient

func (m *Mqtt) NewClient(cfg *mqtt_client.Config) (c *mqtt_client.Client, err error)

func (*Mqtt) Shutdown

func (m *Mqtt) Shutdown() error

func (*Mqtt) Start

func (m *Mqtt) Start() error

type MqttConfig

type MqttConfig struct {
	KeepAlive        int
	ConnectTimeout   int
	SessionsProvider string
	MqttUsername     string
	MqttPassword     string
	TopicsProvider   string
	Port             int
	ServerIp         string
	MqttClientId     string
}

func NewMqttConfig

func NewMqttConfig(cfg *config.AppConfig) *MqttConfig