feat: report metric with scheduler max matches

topfreegames · Jan 20, 2025 · 9c7f8c8 · 9c7f8c8
1 parent d2f577e
commit 9c7f8c8
Show file tree

Hide file tree

Showing 2 changed files with 23 additions and 0 deletions.
diff --git a/internal/core/worker/metricsreporter/metrics.go b/internal/core/worker/metricsreporter/metrics.go
@@ -169,6 +169,17 @@ var (
 		},
 	})
 
+	schedulerMaxMatchesGaugeMetric = monitoring.CreateGaugeMetric(&monitoring.MetricOpts{
+		Namespace: monitoring.Namespace,
+		Subsystem: monitoring.SubsystemWorker,
+		Name:      "max_matches",
+		Help:      "The max number of matches that each Game Room can handle",
+		Labels: []string{
+			monitoring.LabelGame,
+			monitoring.LabelScheduler,
+		},
+	})
+
 	schedulerAutoscalePolicyReadyTargetGaugeMetric = monitoring.CreateGaugeMetric(&monitoring.MetricOpts{
 		Namespace: monitoring.Namespace,
 		Subsystem: monitoring.SubsystemWorker,
@@ -232,6 +243,10 @@ func reportTotalRunningMatches(game, schedulerName string, runningMatches int) {
 	runningMatchesGaugeMetric.WithLabelValues(game, schedulerName).Set(float64(runningMatches))
 }
 
+func reportSchedulerMaxMatches(game, schedulerName string, availableSlots int) {
+	schedulerMaxMatchesGaugeMetric.WithLabelValues(game, schedulerName).Set(float64(availableSlots))
+}
+
 func reportSchedulerPolicyReadyTarget(game, schedulerName string, readyTarget float64) {
 	schedulerAutoscalePolicyReadyTargetGaugeMetric.WithLabelValues(game, schedulerName).Set(readyTarget)
 }
diff --git a/internal/core/worker/metricsreporter/metrics_reporter_worker.go b/internal/core/worker/metricsreporter/metrics_reporter_worker.go
@@ -142,6 +142,7 @@ func (w *MetricsReporterWorker) reportGameRoomMetrics() {
 func (w *MetricsReporterWorker) reportSchedulerMetrics() {
 	w.logger.Info("Reporting scheduler metrics")
 	w.reportSchedulerAutoscale()
+	w.reportSchedulerMaxMatches()
 }
 
 func (w *MetricsReporterWorker) reportSchedulerAutoscale() {
@@ -153,6 +154,13 @@ func (w *MetricsReporterWorker) reportSchedulerAutoscale() {
 	}
 }
 
+func (w *MetricsReporterWorker) reportSchedulerMaxMatches() {
+	if w.scheduler.MatchAllocation == nil {
+		return
+	}
+	reportSchedulerMaxMatches(w.scheduler.Game, w.scheduler.Name, w.scheduler.MatchAllocation.MaxMatches)
+}
+
 func (w *MetricsReporterWorker) reportPendingRooms() {
 	pendingRooms, err := w.roomStorage.GetRoomCountByStatus(w.workerContext, w.scheduler.Name, game_room.GameStatusPending)
 	if err != nil {