oppi.li
1package events
2
3import (
4 "github.com/prometheus/client_golang/prometheus"
5 "github.com/prometheus/client_golang/prometheus/promauto"
6)
7
8var eventsFromStreamCounter = promauto.NewCounterVec(prometheus.CounterOpts{
9 Name: "indigo_repo_stream_events_received_total",
10 Help: "Total number of events received from the stream",
11}, []string{"remote_addr"})
12
13var bytesFromStreamCounter = promauto.NewCounterVec(prometheus.CounterOpts{
14 Name: "indigo_repo_stream_bytes_total",
15 Help: "Total bytes received from the stream",
16}, []string{"remote_addr"})
17
18var eventsEnqueued = promauto.NewCounterVec(prometheus.CounterOpts{
19 Name: "indigo_events_enqueued_for_broadcast_total",
20 Help: "Total number of events enqueued to broadcast to subscribers",
21}, []string{"pool"})
22
23var eventsBroadcast = promauto.NewCounterVec(prometheus.CounterOpts{
24 Name: "indigo_events_broadcast_total",
25 Help: "Total number of events broadcast to subscribers",
26}, []string{"pool"})