mqtt

type DefMqttDoor struct{}

type IMqtt interface {
	Subscribe(topic string, qos byte, callback mqtt.MessageHandler) mqtt.Token
	Publish(topic string, qos byte, retained bool, payload interface{}) mqtt.Token
}

type IMqttDoor interface {
	ConnectHandler(client mqtt.Client)
	ConnectLostHandler(client mqtt.Client, err error)
	MessageHandler(client mqtt.Client, msg mqtt.Message)
}

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

type Optionfn func(*Options)

type Options struct {
	MqttAddr string
	MqttPort int
	ClientID string
	UserName string
	PassWord string
	MqttDoor IMqttDoor
}