mqtt

type AdConf struct {
	Tpc      string `json:"topic"`
	Qos      byte   `json:"qos"`
	Retained bool   `json:"retained"`

	ResendTopic string `json:"resendDestination"`
}

type Conf struct {
	Topic string `json:"datasource"`
	Qos   int    `json:"qos"`
}

type Connection struct {
	pahoMqtt.Client
	// contains filtered or unexported fields
}

type ConnectionConfig struct {
	Server   string `json:"server"`
	PVersion string `json:"protocolVersion"`
	ClientId string `json:"clientid"`
	Uname    string `json:"username"`
	Password string `json:"password"`
	// contains filtered or unexported fields
}

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

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

type SubscriptionInfo struct {
	Qos        byte
	Handler    pahoMqtt.MessageHandler
	ErrHandler func(error)
}