mqtt_client

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

type ClientOptions struct {
	UserName        string
	Password        string
	Address         string
	ClientID        string
	KeepAliveSec    int64
	PingTimeoutSec  int64
	WriteTimeoutSec int64
}

type MessageHandler func(client *Client, token *SubscribeToken, topic string, data []byte) error

type PublishAndReceiveReplyParams struct {
	Topic                string
	ReplyTopic           string
	PublishData          []byte
	RepublishDurationSec int64
	TryTimes             int
	StopBefore           bool
}

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