client

type Client struct {
	Client  mqtt.Client
	Logger  *zap.Logger
	Tracer  trace.Tracer
	Metrics Metrics
	Cache   *cache.Cache

	QoS         int
	Retained    bool
	IsSubscribe bool
}

type Config struct {
	URL           string        `json:"url,omitempty"            koanf:"url"`
	ClientID      string        `json:"client_id,omitempty"      koanf:"clientid"`
	Username      string        `json:"username,omitempty"       koanf:"username"`
	Password      string        `json:"password,omitempty"       koanf:"password"`
	KeepAlive     time.Duration `json:"keep_alive,omitempty"     koanf:"keepalive"`
	PingTimeout   time.Duration `json:"ping_timeout,omitempty"   koanf:"ping_timeout"`
	AutoReconnect bool          `json:"auto_reconnect,omitempty" koanf:"auto_reconnect"`
	QoS           int           `json:"qo_s,omitempty"           koanf:"qos"`
	Retained      bool          `json:"retained,omitempty"       koanf:"retained"`
}

type Message struct {
	Headers map[string]string `json:"headers,omitempty"`
}

type Metrics struct {
	ConnectionErrors prometheus.Counter
	PublishErrors    prometheus.Counter
	Pings            prometheus.Counter
	Pongs            prometheus.Counter
	PingDuration     prometheus.Histogram
}