Workload tracing

metadata.yaml

@@ -61,9 +61,16 @@ requires:
       - (client) scraping targets for self-monitoring
       - (client) posting alerts to alertmanager server
       - (server) serving data to grafana
-  tracing:
+  charm-tracing:
     interface: tracing
     limit: 1
+    description: |
+      Used for passing charm traces from Prometheus charm to the tracing backend.
+  workload-tracing:
+    interface: tracing
+    limit: 1
+    description: |
+      Used for passing workload traces (internal Prometheus traces) to the tracing backend.
 
 peers:
   prometheus-peers:

src/charm.py

@@ -36,7 +36,7 @@
     PrometheusRemoteWriteProvider,
 )
 from charms.tempo_coordinator_k8s.v0.charm_tracing import trace_charm
-from charms.tempo_coordinator_k8s.v0.tracing import TracingEndpointRequirer
+from charms.tempo_coordinator_k8s.v0.tracing import TracingEndpointRequirer, charm_tracing_config
 from charms.traefik_k8s.v1.ingress_per_unit import (
     IngressPerUnitReadyForUnitEvent,
     IngressPerUnitRequirer,
@@ -120,8 +120,8 @@ def to_status(tpl: Tuple[str, str]) -> StatusBase:
 
 
 @trace_charm(
-    tracing_endpoint="tracing_endpoint",
-    server_cert="server_ca_cert_path",
+    tracing_endpoint="charm_tracing_endpoint",
+    server_cert="server_cert",
     extra_types=[
         KubernetesComputeResourcesPatch,
         CertHandler,
@@ -222,7 +222,16 @@ def __init__(self, *args):
         )
 
         self.catalogue = CatalogueConsumer(charm=self, item=self._catalogue_item)
-        self.tracing = TracingEndpointRequirer(self, protocols=["otlp_http"])
+        self.charm_tracing = TracingEndpointRequirer(
+            self, relation_name="charm-tracing", protocols=["otlp_http"]
+        )
+        self.workload_tracing = TracingEndpointRequirer(
+            self, relation_name="workload-tracing", protocols=["otlp_grpc"]
+        )
+
+        self.charm_tracing_endpoint, self.server_cert = charm_tracing_config(
+            self.charm_tracing, self._ca_cert_path
+        )
 
         self.framework.observe(self.on.prometheus_pebble_ready, self._on_pebble_ready)
         self.framework.observe(self.on.config_changed, self._configure)
@@ -413,6 +422,9 @@ def _prometheus_layer(self) -> Layer:
                     "summary": "prometheus daemon",
                     "command": self._generate_command(),
                     "startup": "enabled",
+                    "environment": {
+                        "OTEL_RESOURCE_ATTRIBUTES": f"juju_application={self._topology.application},juju_model={self._topology.model},juju_model_uuid={self._topology.model_uuid},juju_unit={self._topology.unit}"
+                    },
                 }
             },
         }
@@ -947,6 +959,22 @@ def _alerting_config(self) -> dict:
         )
         return alerting_config
 
+    def _tracing_config(self) -> dict:
+        config = {
+            "endpoint": self.workload_tracing.get_endpoint("otlp_grpc"),
+            "sampling_fraction": 1,
+        }
+        if self.server_cert:
+            config["insecure"] = False
+            config["tls_config"] = {
+                "ca_file": self.server_cert,
+                "cert_file": CERT_PATH,
+                "key_file": KEY_PATH,
+            }
+        else:
+            config["insecure"] = True
+        return config
+
     def _generate_prometheus_config(self) -> bool:
         """Construct Prometheus configuration and write to filesystem.
 
@@ -974,6 +1002,9 @@ def _generate_prometheus_config(self) -> bool:
 
         web_config = self._web_config()
 
+        if self.workload_tracing_endpoint:
+            prometheus_config["tracing"] = self._tracing_config()
+
         # Check if config changed, using its hash
         config_hash = sha256(
             yaml.safe_dump(
@@ -1072,10 +1103,10 @@ def _push(self, path, contents):
         self.container.push(path, contents, make_dirs=True, encoding="utf-8")
 
     @property
-    def tracing_endpoint(self) -> Optional[str]:
-        """Tempo endpoint for charm tracing."""
-        if self.tracing.is_ready():
-            return self.tracing.get_endpoint("otlp_http")
+    def workload_tracing_endpoint(self) -> Optional[str]:
+        """Tempo endpoint for workload tracing."""
+        if self.workload_tracing.is_ready():
+            return self.workload_tracing.get_endpoint("otlp_grpc")
         return None
 
     @property