Skip to content
Snippets Groups Projects
Commit 03a392b8 authored by Levente Pap's avatar Levente Pap
Browse files

Add Prometheus exporter for MessageRequestQueueSize

parent 866f09e9
No related branches found
No related tags found
No related merge requests found
...@@ -10,6 +10,7 @@ var ( ...@@ -10,6 +10,7 @@ var (
messageTips prometheus.Gauge messageTips prometheus.Gauge
messagePerTypeCount *prometheus.GaugeVec messagePerTypeCount *prometheus.GaugeVec
messageTotalCount prometheus.Gauge messageTotalCount prometheus.Gauge
messageRequestCount prometheus.Gauge
transactionCounter prometheus.Gauge transactionCounter prometheus.Gauge
valueTips prometheus.Gauge valueTips prometheus.Gauge
...@@ -44,9 +45,15 @@ func registerTangleMetrics() { ...@@ -44,9 +45,15 @@ func registerTangleMetrics() {
Help: "current number of tips in the value tangle", Help: "current number of tips in the value tangle",
}) })
messageRequestCount = prometheus.NewGauge(prometheus.GaugeOpts{
Name: "tangle_message_request_queue_size",
Help: "current number requested messages by the message tangle",
})
registry.MustRegister(messageTips) registry.MustRegister(messageTips)
registry.MustRegister(messagePerTypeCount) registry.MustRegister(messagePerTypeCount)
registry.MustRegister(messageTotalCount) registry.MustRegister(messageTotalCount)
registry.MustRegister(messageRequestCount)
registry.MustRegister(transactionCounter) registry.MustRegister(transactionCounter)
registry.MustRegister(valueTips) registry.MustRegister(valueTips)
...@@ -60,6 +67,7 @@ func collectTangleMetrics() { ...@@ -60,6 +67,7 @@ func collectTangleMetrics() {
messagePerTypeCount.WithLabelValues(payload.Name(payloadType)).Set(float64(count)) messagePerTypeCount.WithLabelValues(payload.Name(payloadType)).Set(float64(count))
} }
messageTotalCount.Set(float64(metrics.MessageTotalCount())) messageTotalCount.Set(float64(metrics.MessageTotalCount()))
messageRequestCount.Set(float64(metrics.MessageRequestQueueSize()))
transactionCounter.Set(float64(metrics.ValueTransactionCounter())) transactionCounter.Set(float64(metrics.ValueTransactionCounter()))
valueTips.Set(float64(metrics.ValueTips())) valueTips.Set(float64(metrics.ValueTips()))
} }
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment