api_binding/mqtt_binding/mqtt_init.go

package mqtt_binding

import (
	"git.sxidc.com/go-tools/api_binding/mqtt_binding/mqtt_client"
)

var mqttClientInstance *mqtt_client.MqttClient

func Init(opts *mqtt_client.MqttClientOptions) error {
	mqttClient, err := mqtt_client.NewMqttClient(opts)
	if err != nil {
		return err
	}

	mqttClientInstance = mqttClient

	return nil
}

func Destroy() {
	if mqttClientInstance != nil {
		mqtt_client.DestroyMqttClient(mqttClientInstance)
		mqttClientInstance = nil
	}
}