oppi.li
bnewbold.net
+3
-3
events/schedulers/parallel/parallel.go
+3
-3
events/schedulers/parallel/parallel.go
···
30
30
itemsAdded prometheus.Counter
31
31
itemsProcessed prometheus.Counter
32
32
itemsActive prometheus.Counter
33
-
workesActive prometheus.Gauge
33
+
workersActive prometheus.Gauge
34
34
35
35
log *slog.Logger
36
36
}
···
51
51
itemsAdded: schedulers.WorkItemsAdded.WithLabelValues(ident, "parallel"),
52
52
itemsProcessed: schedulers.WorkItemsProcessed.WithLabelValues(ident, "parallel"),
53
53
itemsActive: schedulers.WorkItemsActive.WithLabelValues(ident, "parallel"),
54
-
workesActive: schedulers.WorkersActive.WithLabelValues(ident, "parallel"),
54
+
workersActive: schedulers.WorkersActive.WithLabelValues(ident, "parallel"),
55
55
56
56
log: slog.Default().With("system", "parallel-scheduler"),
57
57
}
···
60
60
go p.worker()
61
61
}
62
62
63
-
p.workesActive.Set(float64(maxC))
63
+
p.workersActive.Set(float64(maxC))
64
64
65
65
return p
66
66
}