Skip to content
Snippets Groups Projects
Unverified Commit b8331022 authored by capossele's avatar capossele
Browse files

:construction: WIP

parent 46e28b7f
Branches feat/prometheus
No related tags found
No related merge requests found
...@@ -6,8 +6,7 @@ import ( ...@@ -6,8 +6,7 @@ import (
) )
var ( var (
infoApp *prometheus.GaugeVec infoApp *prometheus.GaugeVec
infoTips prometheus.Gauge
) )
func init() { func init() {
...@@ -18,18 +17,5 @@ func init() { ...@@ -18,18 +17,5 @@ func init() {
}, },
[]string{"name", "version"}, []string{"name", "version"},
) )
infoTips = prometheus.NewGauge(prometheus.GaugeOpts{
Name: "iota_info_tips",
Help: "Number of tips.",
})
infoApp.WithLabelValues(banner.AppName, banner.AppVersion).Set(1) infoApp.WithLabelValues(banner.AppName, banner.AppVersion).Set(1)
registry.MustRegister(infoApp)
registry.MustRegister(infoTips)
addCollect(collectInfo)
}
func collectInfo() {
// Tips
infoTips.Set(0)
} }
package prometheus package prometheus
import ( import (
"github.com/iotaledger/goshimmer/dapps/valuetransfers"
"github.com/iotaledger/goshimmer/plugins/messagelayer"
"github.com/iotaledger/goshimmer/plugins/metrics" "github.com/iotaledger/goshimmer/plugins/metrics"
"github.com/prometheus/client_golang/prometheus" "github.com/prometheus/client_golang/prometheus"
) )
var ( var (
messagesPerSecond prometheus.Gauge messagesPerSecond prometheus.Gauge
infoMessageTips prometheus.Gauge
infoValueTips prometheus.Gauge
) )
func init() { func init() {
...@@ -14,12 +18,27 @@ func init() { ...@@ -14,12 +18,27 @@ func init() {
Name: "iota_messages_per_second", Name: "iota_messages_per_second",
Help: "Number of messages per second.", Help: "Number of messages per second.",
}) })
infoMessageTips = prometheus.NewGauge(prometheus.GaugeOpts{
Name: "iota_info_message_tips",
Help: "Number of message tips.",
})
infoValueTips = prometheus.NewGauge(prometheus.GaugeOpts{
Name: "iota_info_value_tips",
Help: "Number of value tips.",
})
registry.MustRegister(messagesPerSecond) registry.MustRegister(messagesPerSecond)
registry.MustRegister(infoApp)
registry.MustRegister(infoMessageTips)
addCollect(collectMetrics) addCollect(collectMetrics)
} }
func collectMetrics() { func collectMetrics() {
// MPS
messagesPerSecond.Set(float64(metrics.ReceivedMessagesPerSecond())) messagesPerSecond.Set(float64(metrics.ReceivedMessagesPerSecond()))
// Tips
infoMessageTips.Set(float64(messagelayer.TipSelector.TipCount()))
infoValueTips.Set(float64(valuetransfers.TipManager().Size()))
} }
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment