1 package sender
2
3 import "github.com/prometheus/client_golang/prometheus"
4
5 type metrics struct {
6 SentMessagesTotal *prometheus.CounterVec
7 }
8
9 func newMetrics() *metrics {
10 m := &metrics{
11 SentMessagesTotal: prometheus.NewCounterVec(
12 prometheus.CounterOpts{
13 Name: "data_sync_messaging_sent_messages_total",
14 Help: "Number of messages sent to kafka",
15 }, []string{"type", "tenant"},
16 ),
17 }
18
19 prometheus.MustRegister(m.SentMessagesTotal)
20
21 return m
22 }
23
View as plain text