mqtt

package

v0.0.0-...-0cd63e0 Latest Latest Go to latest Published: Oct 17, 2024 License: GPL-3.0 Imports: 11 Imported by: 1

Details

This section is empty.

This section is empty.

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

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

type Mqtt struct {
	Topic  string
	MgtUrl string

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

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 struct {
	Connection string `yaml:"Connection"`
	Topic      string `yaml:"Topic"`
}