X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/9f1850a385ee8e0a011474de19ee6507b0b168f3..f049ebcb40b5509413f73840ead3ef8893f9331b:/services/keepstore/metrics.go diff --git a/services/keepstore/metrics.go b/services/keepstore/metrics.go index d04601fbec..4638de5444 100644 --- a/services/keepstore/metrics.go +++ b/services/keepstore/metrics.go @@ -5,66 +5,9 @@ package keepstore import ( - "fmt" - "github.com/prometheus/client_golang/prometheus" ) -type nodeMetrics struct { - reg *prometheus.Registry -} - -func (m *nodeMetrics) setupBufferPoolMetrics(b *bufferPool) { - m.reg.MustRegister(prometheus.NewGaugeFunc( - prometheus.GaugeOpts{ - Namespace: "arvados", - Subsystem: "keepstore", - Name: "bufferpool_allocated_bytes", - Help: "Number of bytes allocated to buffers", - }, - func() float64 { return float64(b.Alloc()) }, - )) - m.reg.MustRegister(prometheus.NewGaugeFunc( - prometheus.GaugeOpts{ - Namespace: "arvados", - Subsystem: "keepstore", - Name: "bufferpool_max_buffers", - Help: "Maximum number of buffers allowed", - }, - func() float64 { return float64(b.Cap()) }, - )) - m.reg.MustRegister(prometheus.NewGaugeFunc( - prometheus.GaugeOpts{ - Namespace: "arvados", - Subsystem: "keepstore", - Name: "bufferpool_inuse_buffers", - Help: "Number of buffers in use", - }, - func() float64 { return float64(b.Len()) }, - )) -} - -func (m *nodeMetrics) setupWorkQueueMetrics(q *WorkQueue, qName string) { - m.reg.MustRegister(prometheus.NewGaugeFunc( - prometheus.GaugeOpts{ - Namespace: "arvados", - Subsystem: "keepstore", - Name: fmt.Sprintf("%s_queue_inprogress_entries", qName), - Help: fmt.Sprintf("Number of %s requests in progress", qName), - }, - func() float64 { return float64(getWorkQueueStatus(q).InProgress) }, - )) - m.reg.MustRegister(prometheus.NewGaugeFunc( - prometheus.GaugeOpts{ - Namespace: "arvados", - Subsystem: "keepstore", - Name: fmt.Sprintf("%s_queue_pending_entries", qName), - Help: fmt.Sprintf("Number of queued %s requests", qName), - }, - func() float64 { return float64(getWorkQueueStatus(q).Queued) }, - )) -} - type volumeMetricsVecs struct { ioBytes *prometheus.CounterVec errCounters *prometheus.CounterVec