Merge pull request #41281 from melloware/lgtm-41241

Observability Dev UI Card and Log Console

docs/src/main/asciidoc/observability-devservices-lgtm.adoc

@@ -97,6 +97,10 @@ If you miss the message you can always check the port with this Docker command:
 docker ps | grep grafana
 ----
 
+Another option is to use the Dev UI as the Grafana URL link will be available and if selected will open a new browser tab directly to the running Grafana instance:
+
+image::dev-ui-observability-card.png[alt=Dev UI LGTM, align=center,width=80%]
+
 === Additional configuration
 
 This extension will configure your `quarkus-opentelemetry` and `quarkus-micrometer-registry-otlp` extensions to send data to the OTel Collector bundled with the Grafana OTel LGTM image.

extensions/observability-devservices/deployment/pom.xml

@@ -29,6 +29,15 @@
             <groupId>io.quarkus</groupId>
             <artifactId>quarkus-observability-devservices</artifactId>
         </dependency>
+        <dependency>
+            <groupId>io.quarkus</groupId>
+            <artifactId>quarkus-vertx-http-deployment</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>io.quarkus</groupId>
+            <artifactId>quarkus-vertx-http-dev-ui-spi</artifactId>
+            <optional>true</optional>
+        </dependency>
 
         <dependency>
             <groupId>io.quarkus</groupId>

extensions/observability-devservices/deployment/src/main/java/io/quarkus/observability/deployment/ObservabilityDevServiceProcessor.java

@@ -38,6 +38,7 @@
 import io.quarkus.observability.common.config.ContainerConfig;
 import io.quarkus.observability.common.config.ContainerConfigUtil;
 import io.quarkus.observability.common.config.ModulesConfiguration;
+import io.quarkus.observability.deployment.devui.ObservabilityDevServicesConfigBuildItem;
 import io.quarkus.observability.devresource.Container;
 import io.quarkus.observability.devresource.DevResourceLifecycleManager;
 import io.quarkus.observability.devresource.DevResources;
@@ -86,7 +87,8 @@ public void startContainers(LaunchModeBuildItem launchMode,
             BuildProducer<DevServicesResultBuildItem> services,
             BeanArchiveIndexBuildItem indexBuildItem,
             Capabilities capabilities,
-            Optional<MetricsCapabilityBuildItem> metricsConfiguration) {
+            Optional<MetricsCapabilityBuildItem> metricsConfiguration,
+            BuildProducer<ObservabilityDevServicesConfigBuildItem> configBuildProducer) {
 
         if (!configuration.enabled()) {
             log.infof("Observability dev services are disabled in config");
@@ -162,6 +164,7 @@ public void startContainers(LaunchModeBuildItem launchMode,
 
                 devService = newDevService;
                 devServices.put(devId, newDevService);
+                configBuildProducer.produce(new ObservabilityDevServicesConfigBuildItem(newDevService.getConfig()));
             } catch (Throwable t) {
                 compressor.closeAndDumpCaptured();
                 throw new RuntimeException(t);

extensions/observability-devservices/deployment/src/main/java/io/quarkus/observability/deployment/devui/ObservabilityDevServicesConfigBuildItem.java

@@ -0,0 +1,22 @@
+package io.quarkus.observability.deployment.devui;
+
+import java.util.Map;
+
+import io.quarkus.builder.item.SimpleBuildItem;
+
+/**
+ * Build item used to carry running DevService values to Dev UI.
+ */
+public final class ObservabilityDevServicesConfigBuildItem extends SimpleBuildItem {
+
+    private final Map<String, String> config;
+
+    public ObservabilityDevServicesConfigBuildItem(Map<String, String> config) {
+        this.config = config;
+    }
+
+    public Map<String, String> getConfig() {
+        return config;
+    }
+
+}

extensions/observability-devservices/deployment/src/main/java/io/quarkus/observability/deployment/devui/ObservabilityDevUIProcessor.java

@@ -0,0 +1,70 @@
+package io.quarkus.observability.deployment.devui;
+
+import java.util.Map;
+import java.util.Optional;
+
+import org.apache.commons.lang3.StringUtils;
+
+import io.quarkus.deployment.IsDevelopment;
+import io.quarkus.deployment.IsNormal;
+import io.quarkus.deployment.annotations.BuildProducer;
+import io.quarkus.deployment.annotations.BuildStep;
+import io.quarkus.deployment.annotations.BuildSteps;
+import io.quarkus.deployment.dev.devservices.GlobalDevServicesConfig;
+import io.quarkus.devui.spi.page.CardPageBuildItem;
+import io.quarkus.devui.spi.page.ExternalPageBuilder;
+import io.quarkus.devui.spi.page.FooterPageBuildItem;
+import io.quarkus.devui.spi.page.Page;
+import io.quarkus.devui.spi.page.WebComponentPageBuilder;
+
+/**
+ * Dev UI card for displaying important details such LGTM embedded UI.
+ */
+@BuildSteps(onlyIfNot = IsNormal.class, onlyIf = { GlobalDevServicesConfig.Enabled.class })
+public class ObservabilityDevUIProcessor {
+
+    @BuildStep(onlyIf = IsDevelopment.class)
+    void createVersion(BuildProducer<CardPageBuildItem> cardPageBuildItemBuildProducer,
+            BuildProducer<FooterPageBuildItem> footerProducer,
+            Optional<ObservabilityDevServicesConfigBuildItem> configProps) {
+
+        // LGTM
+        if (configProps.isPresent()) {
+            Map<String, String> runtimeConfig = configProps.get().getConfig();
+            String grafanaUrl = runtimeConfig.getOrDefault("grafana.endpoint", "");
+
+            if (StringUtils.isNotEmpty(grafanaUrl)) {
+                final CardPageBuildItem card = new CardPageBuildItem();
+
+                // Grafana
+                grafanaUrl = StringUtils.prependIfMissing(grafanaUrl, "http://");
+                card.addPage(Page.externalPageBuilder("Grafana UI")
+                        .url(grafanaUrl, grafanaUrl)
+                        .doNotEmbed()
+                        .isHtmlContent()
+                        .icon("font-awesome-solid:chart-line"));
+
+                // Open Telemetry
+                final ExternalPageBuilder otelPage = Page.externalPageBuilder("OpenTelemetry Port")
+                        .icon("font-awesome-solid:binoculars")
+                        .doNotEmbed()
+                        .url("https://opentelemetry.io/")
+                        .staticLabel(StringUtils
+                                .substringAfterLast(runtimeConfig.getOrDefault("otel-collector.url", "0"), ":"));
+                card.addPage(otelPage);
+
+                card.setCustomCard("qwc-lgtm-card.js");
+                cardPageBuildItemBuildProducer.produce(card);
+
+                // LGTM Container Log Console
+                WebComponentPageBuilder mailLogPageBuilder = Page.webComponentPageBuilder()
+                        .icon("font-awesome-solid:chart-line")
+                        .title("LGTM")
+                        .componentLink("qwc-lgtm-log.js");
+
+                footerProducer.produce(new FooterPageBuildItem(mailLogPageBuilder));
+            }
+        }
+
+    }
+}

extensions/observability-devservices/deployment/src/main/resources/dev-ui/qwc-lgtm-log.js

@@ -0,0 +1,15 @@
+import { QwcServerLog } from "qwc-server-log";
+
+/**
+ * This component filter the log to only show LGTM related entries.
+ */
+export class QwcLgtmLog extends QwcServerLog {
+  doLogEntry(entry) {
+    if (entry.loggerName && entry.loggerName.includes("LgtmContainer")) {
+      return true;
+    }
+    return false;
+  }
+}
+
+customElements.define("qwc-lgtm-log", QwcLgtmLog);

extensions/observability-devservices/runtime/pom.xml

@@ -21,6 +21,10 @@
             <groupId>io.quarkus</groupId>
             <artifactId>quarkus-core</artifactId>
         </dependency>
+        <dependency>
+            <groupId>io.quarkus</groupId>
+            <artifactId>quarkus-vertx-http</artifactId>
+        </dependency>
 
         <dependency>
             <groupId>io.quarkus</groupId>

extensions/observability-devservices/runtime/src/main/resources/META-INF/quarkus-extension.yaml

@@ -0,0 +1,21 @@
+name: "Observability"
+artifact: ${project.groupId}:${project.artifactId}:${project.version}
+metadata:
+  keywords:
+    - "lgtm"
+    - "grafana"
+    - "prometheus"
+    - "tempo"
+    - "opentelemetry"
+    - "tracing"
+    - "distributed-tracing"
+    - "monitoring"
+    - "micrometer"
+    - "metrics"
+  categories:
+    - "observability"
+  config:
+    - "quarkus.observability."
+  status: "experimental"
+  guide: "https://quarkus.io/guides/observability-devservices-lgtm"
+  icon-url: "https://upload.wikimedia.org/wikipedia/commons/3/3b/Grafana_icon.svg"

extensions/observability-devservices/testcontainers/src/main/java/io/quarkus/observability/testcontainers/LgtmContainer.java

@@ -3,11 +3,18 @@
 import java.util.Optional;
 import java.util.Set;
 
+import org.jboss.logging.Logger;
+
 import io.quarkus.observability.common.ContainerConstants;
 import io.quarkus.observability.common.config.AbstractGrafanaConfig;
 import io.quarkus.observability.common.config.LgtmConfig;
 
 public class LgtmContainer extends GrafanaContainer<LgtmContainer, LgtmConfig> {
+    /**
+     * Logger which will be used to capture container STDOUT and STDERR.
+     */
+    private static final Logger log = Logger.getLogger(LgtmContainer.class);
+
     protected static final String LGTM_NETWORK_ALIAS = "ltgm.testcontainer.docker";
 
     public LgtmContainer() {
@@ -17,6 +24,7 @@ public LgtmContainer() {
     public LgtmContainer(LgtmConfig config) {
         super(config);
         addExposedPorts(config.otlpPort());
+        withLogConsumer(new LgtmContainerLogConsumer(log).withPrefix("LGTM"));
     }
 
     public int getOtlpPort() {