jetty sessions

Author: SylvainJuge

jmx-scraper/src/integrationTest/java/io/opentelemetry/contrib/jmxscraper/target_systems/JettyIntegrationTest.java

@@ -0,0 +1,61 @@
+/*
+ * Copyright The OpenTelemetry Authors
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+package io.opentelemetry.contrib.jmxscraper.target_systems;
+
+import static io.opentelemetry.contrib.jmxscraper.target_systems.MetricAssertions.assertSumWithAttributes;
+
+import io.opentelemetry.contrib.jmxscraper.JmxScraperContainer;
+import java.time.Duration;
+import org.testcontainers.containers.GenericContainer;
+import org.testcontainers.containers.wait.strategy.Wait;
+import org.testcontainers.images.builder.ImageFromDockerfile;
+
+public class JettyIntegrationTest extends TargetSystemIntegrationTest {
+
+  @Override
+  protected GenericContainer<?> createTargetContainer(int jmxPort) {
+    GenericContainer<?> container =
+        new GenericContainer<>(
+            new ImageFromDockerfile()
+                .withDockerfileFromBuilder(
+                    builder ->
+                        builder
+                            .from("jetty:11")
+                            .run(
+                                "java",
+                                "-jar",
+                                "/usr/local/jetty/start.jar",
+                                "--add-to-startd=jmx,stats,http")
+                            .run("mkdir -p /var/lib/jetty/webapps/ROOT/")
+                            .run("touch /var/lib/jetty/webapps/ROOT/index.html")
+                            .build()));
+
+    container
+        .withEnv("JAVA_OPTIONS", genericJmxJvmArguments(jmxPort))
+        .withEnv("LOCAL_JMX", "no")
+        .withStartupTimeout(Duration.ofMinutes(2))
+        .waitingFor(Wait.forLogMessage(".*Started Server.*", 1));
+
+    return container;
+  }
+
+  @Override
+  protected JmxScraperContainer customizeScraperContainer(JmxScraperContainer scraper) {
+    return scraper.withTargetSystem("jetty");
+  }
+
+  @Override
+  protected void verifyMetrics() {
+    waitAndAssertMetrics(
+        metric ->
+            assertSumWithAttributes(
+                metric,
+                "jetty.session.count",
+                "The number of sessions established in total.",
+                "{sessions}",
+                attrs -> attrs.containsKey("resource")));
+  }
+}

jmx-scraper/src/main/resources/jetty.yaml

@@ -0,0 +1,14 @@
+---
+
+rules:
+
+  - bean: org.eclipse.jetty.server.session:context=*,type=sessionhandler,id=*
+    prefix: jetty.session.
+    metricAttribute:
+      resource: param(context)
+    mapping:
+      sessionsCreated:
+        metric: count
+        type: counter
+        unit: "{sessions}"
+        desc: The number of sessions established in total.