mqtt

type MQ struct {
	// Url to connect to
	Url      string `yaml:"url"`
	ClientID string `yaml:"clientID"`
	Username string `yaml:"username"`
	Password string `yaml:"password"`
	Debug    bool   `yaml:"debug"`
	// contains filtered or unexported fields
}

type MessageHandler func(mqtt.Message)

type Pool interface {
	GetMQ(string) *MQ
}

type Publisher struct {
	Topic    string `yaml:"topic"`              // Topic to publish to
	Retained bool   `yaml:"retained,omitempty"` // true if message to be retained
	// contains filtered or unexported fields
}

type Queue struct {
	Broker string `yaml:"broker"`
	Topic  string `yaml:"topic"`
	// contains filtered or unexported fields
}