metrics.go

package write

import "github.com/prometheus/client_golang/prometheus"

type metrics struct {
	sentBytes       *prometheus.CounterVec
	droppedBytes    *prometheus.CounterVec
	sentProfiles    *prometheus.CounterVec
	droppedProfiles *prometheus.CounterVec
	retries         *prometheus.CounterVec
}

func newMetrics(reg prometheus.Registerer) *metrics {
	m := &metrics{
		sentBytes: prometheus.NewCounterVec(prometheus.CounterOpts{
			Name: "phlare_write_sent_bytes_total",
			Help: "Total number of compressed bytes sent to Phlare.",
		}, []string{"endpoint"}),
		droppedBytes: prometheus.NewCounterVec(prometheus.CounterOpts{
			Name: "phlare_write_dropped_bytes_total",
			Help: "Total number of compressed bytes dropped by Phlare.",
		}, []string{"endpoint"}),
		sentProfiles: prometheus.NewCounterVec(prometheus.CounterOpts{
			Name: "phlare_write_sent_profiles_total",
			Help: "Total number of profiles sent to Phlare.",
		}, []string{"endpoint"}),
		droppedProfiles: prometheus.NewCounterVec(prometheus.CounterOpts{
			Name: "phlare_write_dropped_profiles_total",
			Help: "Total number of profiles dropped by Phlare.",
		}, []string{"endpoint"}),
		retries: prometheus.NewCounterVec(prometheus.CounterOpts{
			Name: "phlare_write_retries_total",
			Help: "Total number of retries to Phlare.",
		}, []string{"endpoint"}),
	}

	if reg != nil {
		reg.MustRegister(
			m.sentBytes,
			m.droppedBytes,
			m.sentProfiles,
			m.droppedProfiles,
			m.retries,
		)
	}

	return m
}