Skip to content

Commit 416c464

Browse files
authored
Revert "feat: health checks"
1 parent 4dd4b45 commit 416c464

File tree

8 files changed

+10
-184
lines changed

8 files changed

+10
-184
lines changed

src/main/java/de/sldk/mc/HealthController.java

-28
This file was deleted.

src/main/java/de/sldk/mc/MetricsController.java

+1-4
Original file line numberDiff line numberDiff line change
@@ -19,13 +19,10 @@ public class MetricsController extends Handler.Abstract {
1919
private final MetricRegistry metricRegistry = MetricRegistry.getInstance();
2020
private final PrometheusExporter exporter;
2121

22-
private MetricsController(PrometheusExporter exporter) {
22+
public MetricsController(PrometheusExporter exporter) {
2323
this.exporter = exporter;
2424
}
2525

26-
public static Handler create(final PrometheusExporter exporter) {
27-
return new MetricsController(exporter);
28-
}
2926

3027
@Override
3128
public boolean handle(Request request, Response response, Callback callback) throws Exception {

src/main/java/de/sldk/mc/MetricsServer.java

+3-7
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,6 @@
11
package de.sldk.mc;
22

33
import org.eclipse.jetty.http.pathmap.PathSpec;
4-
import de.sldk.mc.health.HealthChecks;
54
import org.eclipse.jetty.server.Server;
65
import org.eclipse.jetty.server.handler.PathMappingsHandler;
76
import org.eclipse.jetty.server.handler.gzip.GzipHandler;
@@ -13,23 +12,20 @@ public class MetricsServer {
1312
private final String host;
1413
private final int port;
1514
private final PrometheusExporter prometheusExporter;
16-
private final HealthChecks healthChecks;
1715

1816
private Server server;
1917

20-
public MetricsServer(String host, int port, PrometheusExporter prometheusExporter, HealthChecks healthChecks) {
18+
public MetricsServer(String host, int port, PrometheusExporter prometheusExporter) {
2119
this.host = host;
2220
this.port = port;
2321
this.prometheusExporter = prometheusExporter;
24-
this.healthChecks = healthChecks;
25-
}
22+
}
2623

2724
public void start() throws Exception {
2825
GzipHandler gzipHandler = new GzipHandler();
2926

3027
var pathMappings = new PathMappingsHandler();
31-
pathMappings.addMapping(PathSpec.from("/metrics"), MetricsController.create(prometheusExporter));
32-
pathMappings.addMapping(PathSpec.from("/health"), HealthController.create(healthChecks));
28+
pathMappings.addMapping(PathSpec.from("/metrics"), new MetricsController(prometheusExporter));
3329

3430
gzipHandler.setHandler(pathMappings);
3531

src/main/java/de/sldk/mc/health/ConcurrentHealthChecks.java

-33
This file was deleted.

src/main/java/de/sldk/mc/health/HealthCheck.java

-64
This file was deleted.

src/main/java/de/sldk/mc/health/HealthChecks.java

-21
This file was deleted.

src/main/kotlin/de/sldk/mc/PrometheusExporter.kt

+3-11
Original file line numberDiff line numberDiff line change
@@ -3,13 +3,9 @@
33
package de.sldk.mc
44

55
import de.sldk.mc.config.PrometheusExporterConfig
6-
import de.sldk.mc.health.ConcurrentHealthChecks
7-
import de.sldk.mc.health.HealthChecks
8-
import org.bukkit.plugin.ServicePriority
96
import org.bukkit.plugin.java.JavaPlugin
107
import java.util.logging.Level
118

12-
139
class PrometheusExporter : JavaPlugin() {
1410
private val config: PrometheusExporterConfig = PrometheusExporterConfig(this)
1511
private var server: MetricsServer? = null
@@ -18,18 +14,14 @@ class PrometheusExporter : JavaPlugin() {
1814
override fun onEnable() {
1915
config.loadDefaultsAndSave()
2016
config.enableConfiguredMetrics()
21-
22-
val healthChecks = ConcurrentHealthChecks.create()
23-
getServer().servicesManager.register(HealthChecks::class.java, healthChecks, this, ServicePriority.Normal)
24-
25-
startMetricsServer(healthChecks)
17+
startMetricsServer()
2618
}
2719

28-
private fun startMetricsServer(healthChecks: HealthChecks) {
20+
private fun startMetricsServer() {
2921
val host = config[PrometheusExporterConfig.HOST]
3022
val port = config[PrometheusExporterConfig.PORT]
3123

32-
server = MetricsServer(host, port, this, healthChecks)
24+
server = MetricsServer(host, port, this)
3325

3426
try {
3527
server?.start()

src/test/java/de/sldk/mc/exporter/PrometheusExporterTest.java

+3-16
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,10 @@
11
package de.sldk.mc.exporter;
22

33

4+
import static org.assertj.core.api.Assertions.assertThat;
5+
46
import de.sldk.mc.MetricsServer;
57
import de.sldk.mc.PrometheusExporter;
6-
import de.sldk.mc.health.ConcurrentHealthChecks;
78
import io.prometheus.client.CollectorRegistry;
89
import io.prometheus.client.Counter;
910
import io.prometheus.client.exporter.common.TextFormat;
@@ -20,8 +21,6 @@
2021
import java.io.IOException;
2122
import java.net.ServerSocket;
2223

23-
import static org.assertj.core.api.Assertions.assertThat;
24-
2524
@ExtendWith(MockitoExtension.class)
2625
public class PrometheusExporterTest {
2726

@@ -35,9 +34,7 @@ public class PrometheusExporterTest {
3534
void setup() throws Exception {
3635
CollectorRegistry.defaultRegistry.clear();
3736
metricsServerPort = getRandomFreePort();
38-
metricsServer = new MetricsServer(
39-
"localhost", metricsServerPort, exporterMock, ConcurrentHealthChecks.create()
40-
);
37+
metricsServer = new MetricsServer("localhost", metricsServerPort, exporterMock);
4138
metricsServer.start();
4239
}
4340

@@ -86,14 +83,4 @@ void metrics_server_should_return_404_on_unknown_paths() {
8683
.statusCode(HttpStatus.NOT_FOUND_404);
8784
}
8885

89-
@Test
90-
void metrics_server_should_return_200_on_health_check() {
91-
String requestPath = URIUtil.newURI("http", "localhost", metricsServerPort, "/health", null);
92-
93-
RestAssured.when()
94-
.get(requestPath)
95-
.then()
96-
.statusCode(HttpStatus.OK_200);
97-
}
98-
9986
}

0 commit comments

Comments
 (0)