prometheus

Documentation

Index

• type Metrics
  • func NewMetrics(prefix string) *Metrics
  • func Start(ctx context.Context, config configuration.Config) (metrics *Metrics, err error)
  • func (this *Metrics) ServeHTTP(writer http.ResponseWriter, request *http.Request)
  • func (this *Metrics) SetOnMetricsServeRequest(f func())

Types

type Metrics

type Metrics struct {
	TopicsChecked       prometheus.Counter
	TopicCheckLatencyMs prometheus.Gauge

	ClientsChecked       prometheus.Counter
	ClientCheckLatencyMs prometheus.Gauge

	DevicesChecked       prometheus.Counter
	DeviceCheckLatencyMs prometheus.Gauge

	HubsChecked       prometheus.Counter
	HubCheckLatencyMs prometheus.Gauge

	SendDeviceConnected    prometheus.Counter
	SendDeviceDisconnected prometheus.Counter
	SendHubConnected       prometheus.Counter
	SendHubDisconnected    prometheus.Counter

	TotalConnected    prometheus.Gauge
	TotalDisconnected prometheus.Gauge
	// contains filtered or unexported fields
}

func NewMetrics

func NewMetrics(prefix string) *Metrics

func Start

func Start(ctx context.Context, config configuration.Config) (metrics *Metrics, err error)

func (*Metrics) ServeHTTP

func (this *Metrics) ServeHTTP(writer http.ResponseWriter, request *http.Request)

func (*Metrics) SetOnMetricsServeRequest

func (this *Metrics) SetOnMetricsServeRequest(f func())