mqtt

Documentation

Index

• func ConnectHandler(logger zerolog.Logger) func(client pmqtt.Client)
• func ConnectLostHandler(logger zerolog.Logger) func(client pmqtt.Client, err error)
• type Mqtt
  • func NewMqtt(conf MqttConf, logl int, ctx context.Context) (*Mqtt, error)
  • func (m *Mqtt) Connect() error
  • func (m *Mqtt) ConnectHandler() func(client pmqtt.Client)
  • func (m *Mqtt) ConnectLostHandler() func(client pmqtt.Client, err error)
  • func (m *Mqtt) Disconnect()
  • func (m *Mqtt) SendAlarm(events []model.FCTSDataModel) error
• type MqttConf

Functions

func ConnectHandler

func ConnectHandler(logger zerolog.Logger) func(client pmqtt.Client)

func ConnectLostHandler

func ConnectLostHandler(logger zerolog.Logger) func(client pmqtt.Client, err error)

Types

type Mqtt

type Mqtt struct {
	Topic  string
	MgtUrl string

	ClientID uuid.UUID
	// contains filtered or unexported fields
}

func NewMqtt

func NewMqtt(conf MqttConf, logl int, ctx context.Context) (*Mqtt, error)

func (*Mqtt) Connect

func (m *Mqtt) Connect() error

func (*Mqtt) ConnectHandler

func (m *Mqtt) ConnectHandler() func(client pmqtt.Client)

func (*Mqtt) ConnectLostHandler

func (m *Mqtt) ConnectLostHandler() func(client pmqtt.Client, err error)

func (*Mqtt) Disconnect

func (m *Mqtt) Disconnect()

func (*Mqtt) SendAlarm

func (m *Mqtt) SendAlarm(events []model.FCTSDataModel) error

type MqttConf

type MqttConf struct {
	Connection string `yaml:"Connection"`
	Topic      string `yaml:"Topic"`
}