From 08888165fd207984f2fe1cca2592447e4b9f8c4a Mon Sep 17 00:00:00 2001 From: Philipp Date: Fri, 15 Nov 2024 14:12:24 +0100 Subject: [PATCH] add reports statistics --- internal/metrics/collector.go | 30 ++++++++++++++++++++++++++++++ 1 file changed, 30 insertions(+) diff --git a/internal/metrics/collector.go b/internal/metrics/collector.go index 8b2f2e6..954754d 100644 --- a/internal/metrics/collector.go +++ b/internal/metrics/collector.go @@ -85,6 +85,18 @@ var ( metricPrefix+"users_pending", "Number of pending users.", nil, nil) + reportsNewest = prometheus.NewDesc( + metricPrefix+"reports_newest", + "Contains the datetime about the newest report of this Instance.", + []string{"datetime"}, nil) + reportsOpen = prometheus.NewDesc( + metricPrefix+"reports_open", + "Number of open reports.", + nil, nil) + reportsClosed = prometheus.NewDesc( + metricPrefix+"reports_closed", + "Number of closed reports.", + nil, nil) ) type friendicaCollector struct { @@ -133,6 +145,9 @@ func (c *friendicaCollector) Describe(ch chan<- *prometheus.Desc) { ch <- postsOutbound ch <- packetsInbound ch <- packetsOutbound + ch <- reportsNewest + ch <- reportsOpen + ch <- reportsClosed } func (c *friendicaCollector) Collect(ch chan<- prometheus.Metric) { @@ -254,6 +269,14 @@ func collectSimpleMetrics(ch chan<- prometheus.Metric, status *serverinfo.Server desc: usersPending, value: float64(status.Users.Pending), }, + { + desc: reportsOpen, + value: float64(status.Reports.Open), + }, + { + desc: reportsClosed, + value: float64(status.Reports.Closed), + }, } for _, m := range metrics { @@ -391,6 +414,13 @@ func collectLastExecutions(ch chan<- prometheus.Metric, status *serverinfo.Serve } ch <- metric + reportsInfo := status.Reports + + metric, err = prometheus.NewConstMetric(reportsNewest, prometheus.GaugeValue, float64(reportsInfo.Newest.Timestamp), reportsInfo.Newest.DateTime) + if err != nil { + return fmt.Errorf("error creating metric for %s: %w", reportsNewest, err) + } + ch <- metric return nil }