prometheus

README

Prometheus

Prometheus implements the prometheus exporter for mqtt.

Metrics

metric name	Type	Labels
mqtt_clients_connected_total	Counter
mqtt_messages_dropped_total	Counter	qos: qos of the dropped message
mqtt_packets_received_bytes_total	Counter	type: type of the packet
mqtt_packets_received_total	Counter	type: type of the packet
mqtt_packets_sent_bytes_total	Counter	type: type of the packet
mqtt_packets_sent_total	Counter	type: type of the packet
mqtt_sessions_active_current	Gauge
mqtt_sessions_expired_total	Counter
mqtt_sessions_inactive_current	Gauge
mqtt_subscriptions_current	Gauge
mqtt_subscriptions_total	Counter
messages_queued_current	Gauge
messages_received_total	Counter	qos: qos of the message
messages_sent_total	Counter	qos: qos of the message

Documentation

Index

• type Prometheus
  • func New(httpSever *http.Server, path string) *Prometheus
  • func (p *Prometheus) Collect(m chan<- prometheus.Metric)
  • func (p *Prometheus) Describe(desc chan<- *prometheus.Desc)
  • func (p *Prometheus) HookWrapper() mqtt.HookWrapper
  • func (p *Prometheus) Load(service mqtt.Server) error
  • func (p *Prometheus) Name() string
  • func (p *Prometheus) Unload() error

Types

type Prometheus

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

Prometheus served as a prometheus exporter that exposes mqtt metrics.

func New

func New(httpSever *http.Server, path string) *Prometheus

func (*Prometheus) Collect

func (p *Prometheus) Collect(m chan<- prometheus.Metric)

func (*Prometheus) Describe

func (p *Prometheus) Describe(desc chan<- *prometheus.Desc)

func (*Prometheus) HookWrapper

func (p *Prometheus) HookWrapper() mqtt.HookWrapper

func (*Prometheus) Load

func (p *Prometheus) Load(service mqtt.Server) error

func (*Prometheus) Name

func (p *Prometheus) Name() string

func (*Prometheus) Unload

func (p *Prometheus) Unload() error