Add configurable endpoint for Prometheus scraping

kamon-io · Feb 8, 2021 · 331365b · 331365b
1 parent 28cdeac
commit 331365b
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/reporters/kamon-prometheus/src/main/resources/reference.conf b/reporters/kamon-prometheus/src/main/resources/reference.conf
@@ -82,6 +82,7 @@ kamon.prometheus {
     # Hostname and port used by the embedded web server to publish the scraping enpoint.
     hostname = "0.0.0.0"
     port = 9095
+    path = "/metrics"
 
     # embedded server impl
     # choose between

diff --git a/...kamon-prometheus/src/main/scala/kamon/prometheus/embeddedhttp/SunEmbeddedHttpServer.scala b/...kamon-prometheus/src/main/scala/kamon/prometheus/embeddedhttp/SunEmbeddedHttpServer.scala
@@ -31,11 +31,12 @@ import scala.collection.mutable
 
 class SunEmbeddedHttpServer(hostname: String, port: Int, scrapeSource: ScrapeSource, config: Config) extends EmbeddedHttpServer(hostname, port, scrapeSource, config) {
   private val server = {
+    val path = config.getString("kamon.prometheus.embedded-server.path")
     val s = HttpServer.create(new InetSocketAddress(InetAddress.getByName(hostname), port), 0)
     s.setExecutor(null)
     val handler = new HttpHandler {
       override def handle(httpExchange: HttpExchange): Unit = {
-        if (httpExchange.getRequestURI.getPath == "/metrics") {
+        if (httpExchange.getRequestURI.getPath == path) {
           val data = scrapeSource.scrapeData()
           val bytes = data.getBytes(StandardCharsets.UTF_8)
           var os: OutputStream = null