|
27 | 27 |
|
28 | 28 | import io.micrometer.core.instrument.Gauge; |
29 | 29 | import io.micrometer.core.instrument.MeterRegistry; |
30 | | -import io.micrometer.core.instrument.Tags; |
31 | 30 | import io.micrometer.core.instrument.binder.BaseUnits; |
32 | 31 | import jakarta.annotation.PostConstruct; |
33 | 32 | import jakarta.annotation.PreDestroy; |
@@ -63,17 +62,15 @@ public void start() { |
63 | 62 | taskExecutor.start(); |
64 | 63 | editSchedulerStatus.checkinToRegistry(name, 0, taskExecutor.getMaxThreads()); |
65 | 64 |
|
66 | | - Gauge.builder("persistent_tasks.scheduler." + name, |
67 | | - taskExecutor, |
68 | | - e -> e.countRunning()) |
69 | | - .tags(Tags.of("thread", "running")) |
| 65 | + Gauge.builder("persistent_tasks.schedulers", |
| 66 | + taskExecutor, e -> e.countRunning()) |
| 67 | + .tags("scheduler", name, BaseUnits.TASKS, "running") |
70 | 68 | .baseUnit(BaseUnits.TASKS) |
71 | 69 | .register(meterRegistry); |
72 | 70 |
|
73 | | - Gauge.builder("persistent_tasks.scheduler." + name, |
74 | | - taskExecutor, |
75 | | - e -> e.getMaxThreads()) |
76 | | - .tags(Tags.of("thread", "max")) |
| 71 | + Gauge.builder("persistent_tasks.schedulers", |
| 72 | + taskExecutor, e -> e.getMaxThreads()) |
| 73 | + .tags("scheduler", name, BaseUnits.TASKS, "total") |
77 | 74 | .baseUnit(BaseUnits.TASKS) |
78 | 75 | .register(meterRegistry); |
79 | 76 | } |
|
0 commit comments