mqtt

type Client interface {
	Connect() error
	Disconnect()
	Publish(topic string, qos QoSLevel, retained bool, message []byte) error
}

type Config struct {
	// Enabled indicates whether the service should be enabled
	Enabled bool   `toml:"enabled" override:"enabled"`
	Name    string `toml:"name" override:"name"`
	Default bool   `toml:"default" override:"default"`
	// URL of the MQTT Broker.
	// Valid URLs include tcp://host:port, ws://host:port or ssl://host:port.
	// If using ssl://host:port, one must also specify the SSL configuration options.
	URL string `toml:"url" override:"url"`

	// Path to CA file
	SSLCA string `toml:"ssl-ca" override:"ssl-ca"`
	// Path to host cert file
	SSLCert string `toml:"ssl-cert" override:"ssl-cert"`
	// Path to cert key file
	SSLKey string `toml:"ssl-key" override:"ssl-key"`
	// Use SSL but skip chain & host verification
	InsecureSkipVerify bool `toml:"insecure-skip-verify" override:"insecure-skip-verify"`

	// ClientID is the unique ID advertised to the MQTT broker from this client.
	// Defaults to Name if empty.
	ClientID string `toml:"client-id" override:"client-id"`
	Username string `toml:"username" override:"username"`
	Password string `toml:"password" override:"password,redact"`
	// contains filtered or unexported fields
}

type Configs []Config

type Diagnostic interface {
	WithContext(ctx ...keyvalue.T) Diagnostic
	Error(msg string, err error)
	CreatingAlertHandler(c HandlerConfig)
	HandlingEvent()
}

type HandlerConfig struct {
	BrokerName    string         `mapstructure:"broker-name"`
	Topic         string         `mapstructure:"topic"`
	QoS           QoSLevel       `mapstructure:"qos"`
	Retained      bool           `mapstructure:"retained"`
	TopicTemplate *text.Template `mapstructure:"topic-template"`
}

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

type QoSLevel byte

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