xmqtt

type Client struct {
	Ops      *mqtt.ClientOptions
	Mqtt     mqtt.Client
	Topics   []string
	SubFuncs map[string]mqtt.MessageHandler // key:topic#qos, value: callback func
	// contains filtered or unexported fields
}

type Config struct {
	Broker       string        `json:"broker" yaml:"broker" toml:"broker"`
	TcpPort      int           `json:"tcp_port" yaml:"tcp_port" toml:"tcp_port"`
	ClientId     string        `json:"client_id" yaml:"client_id" toml:"client_id"`
	Uname        string        `json:"uname" yaml:"uname" toml:"uname"`
	Password     string        `json:"password" yaml:"password" toml:"password"`
	KeepAlive    time.Duration `json:"keep_alive" yaml:"keep_alive" toml:"keep_alive"` // 单位秒
	CleanSession bool          `json:"clean_session" yaml:"clean_session" toml:"clean_session"`
}

type Consumer struct {
	Topic    string
	QosType  QosType
	Callback mqtt.MessageHandler
}

type QosType byte