publisher

type MqttConfig struct {
	Host     string
	Port     int
	User     string
	Password string
	ClientId string
}

type MqttMsg struct {
	Topic    string
	Qos      byte
	Retained bool
	Payload  interface{}
}

type Publisher interface {
	Start()
	Stop()
	Connect()
	SetIn(chan types.DataPoint)
	GetIn() chan types.DataPoint
}

type SimpleConfig struct {
	Mqtt MqttConfig
}

type SimpleSink struct {
	In   chan types.DataPoint
	Sink mqttClient
	// contains filtered or unexported fields
}