mqttclient

Documentation

Index

• func ResetMQTTClient()
• type Heartbeat
  • func (h *Heartbeat) Start() error
• type MQTTClient
  • func GetMQTTClient(onConnectHandler mqtt.OnConnectHandler) *MQTTClient

Functions

func ResetMQTTClient

func ResetMQTTClient()

ResetMQTTClient resets once

Types

type Heartbeat

type Heartbeat struct {
	Topic             string
	Client            *MQTTClient
	OnHeartbeatMissed func(error)
	LastHeartbeat     time.Time

	MaxDurationMs int64
	// contains filtered or unexported fields
}

Heartbeat for MQTT Client Will Subscribe and Publish to MQTT

func (*Heartbeat) Start

func (h *Heartbeat) Start() error

Start the heartbeat

type MQTTClient

type MQTTClient struct {
	MQTTServerHost   string
	MQTTServerPort   int
	MQTTClient       mqtt.Client
	Heartbeat        *Heartbeat
	OnConnectHandler mqtt.OnConnectHandler
}

MQTTClient contains the data needed to connect the client

func GetMQTTClient

func GetMQTTClient(onConnectHandler mqtt.OnConnectHandler) *MQTTClient

GetMQTTClient creates the mqttclient and returns it