Refactor: move collector metrics where they are used

This commit is contained in:
Bryan Boreham
2021-05-11 16:16:08 +00:00
parent 5833259963
commit 2dcb319ef5
2 changed files with 17 additions and 14 deletions

View File

@@ -83,17 +83,6 @@ var (
Name: "reports_bytes_total",
Help: "Total bytes stored in reports per user.",
}, []string{"user"})
topologiesDropped = prometheus.NewCounterVec(prometheus.CounterOpts{
Namespace: "scope",
Name: "topologies_dropped_total",
Help: "Total count of topologies dropped for being over limit.",
}, []string{"user", "topology"})
natsRequests = prometheus.NewCounterVec(prometheus.CounterOpts{
Namespace: "scope",
Name: "nats_requests_total",
Help: "Total count of NATS requests.",
}, []string{"method", "status_code"})
flushDuration = instrument.NewHistogramCollectorFromOpts(prometheus.HistogramOpts{
Namespace: "scope",
@@ -109,6 +98,9 @@ func registerAWSCollectorMetrics() {
prometheus.MustRegister(dynamoValueSize)
prometheus.MustRegister(inProcessCacheRequests)
prometheus.MustRegister(inProcessCacheHits)
prometheus.MustRegister(reportSizeHistogram)
prometheus.MustRegister(reportsPerUser)
prometheus.MustRegister(reportSizePerUser)
flushDuration.Register()
}

View File

@@ -27,10 +27,21 @@ import (
"golang.org/x/sync/errgroup"
)
var (
topologiesDropped = prometheus.NewCounterVec(prometheus.CounterOpts{
Namespace: "scope",
Name: "topologies_dropped_total",
Help: "Total count of topologies dropped for being over limit.",
}, []string{"user", "topology"})
natsRequests = prometheus.NewCounterVec(prometheus.CounterOpts{
Namespace: "scope",
Name: "nats_requests_total",
Help: "Total count of NATS requests.",
}, []string{"method", "status_code"})
)
func registerLiveCollectorMetrics() {
prometheus.MustRegister(reportSizeHistogram)
prometheus.MustRegister(reportsPerUser)
prometheus.MustRegister(reportSizePerUser)
prometheus.MustRegister(topologiesDropped)
prometheus.MustRegister(natsRequests)
}