Versions in this module Expand all Collapse all v1 v1.2.0 Mar 4, 2024 v1.1.0 Mar 3, 2024 v1.0.0 Mar 3, 2024 v0 v0.6.0 Mar 3, 2024 v0.5.0 Mar 3, 2024 v0.4.0 Mar 3, 2024 v0.3.0 Mar 3, 2024 v0.2.0 Mar 3, 2024 v0.1.0 Mar 3, 2024 Changes in this version + const DisconnectTimeout + const Namespace + const PingTopic + const Subsystem + type Client struct + Cache *cache.Cache + Client mqtt.Client + IsSubscribe bool + Logger *zap.Logger + Metrics Metrics + QoS int + Retained bool + Tracer trace.Tracer + func New(ctx context.Context, cfg Config, logger *zap.Logger, tracer trace.Tracer, ...) *Client + func (c *Client) Connect() error + func (c *Client) Disconnect() + func (c *Client) OnConnectHandler(_ mqtt.Client) + func (c *Client) OnConnectionLostHandler(_ mqtt.Client, err error) + func (c *Client) Ping(ctx context.Context, id int) error + func (c *Client) Pong(_ mqtt.Client, b mqtt.Message) + type Config struct + AutoReconnect bool + ClientID string + KeepAlive time.Duration + Password string + PingTimeout time.Duration + QoS int + Retained bool + URL string + Username string + type Message struct + Headers map[string]string + type Metrics struct + ConnectionErrors prometheus.Counter + PingDuration prometheus.Histogram + Pings prometheus.Counter + Pongs prometheus.Counter + PublishErrors prometheus.Counter + func NewMetrics() Metrics