feat: support process discovery v2 schema

Author: dmehala

src/datadog/tracer.cpp

@@ -143,20 +143,27 @@ void Tracer::store_config() {
 
   auto defaults = config_manager_->span_defaults();
 
+  std::string container_id = "";
+  if (auto maybe_container_id = container::get_id()) {
+    container_id = maybe_container_id->value;
+  }
+
   std::string buffer;
   buffer.reserve(1024);
 
   // clang-format off
   msgpack::pack_map(
     buffer, 
-    "schema_version", [&](auto& buffer) { msgpack::pack_integer(buffer, std::uint64_t(1)); return Expected<void>{}; },
+    "schema_version", [&](auto& buffer) { msgpack::pack_integer(buffer, std::uint64_t(2)); return Expected<void>{}; },
     "runtime_id", [&](auto& buffer) { return msgpack::pack_string(buffer, runtime_id_.string()); },
     "tracer_version", [&](auto& buffer) { return msgpack::pack_string(buffer, signature_.library_version); },
     "tracer_language", [&](auto& buffer) { return msgpack::pack_string(buffer, signature_.library_language); },
     "hostname", [&](auto& buffer) { return msgpack::pack_string(buffer, hostname_.value_or("")); },
     "service_name", [&](auto& buffer) { return msgpack::pack_string(buffer, defaults->service); },
     "service_env", [&](auto& buffer) { return msgpack::pack_string(buffer, defaults->environment); },
-    "service_version", [&](auto& buffer) { return msgpack::pack_string(buffer, defaults->version); }
+    "service_version", [&](auto& buffer) { return msgpack::pack_string(buffer, defaults->version); },
+    "process_tags", [&](auto& buffer) { return msgpack::pack_string(buffer, ""); },
+    "container_id", [&](auto& buffer) { return msgpack::pack_string(buffer, container_id); }
   );
   // clang-format on
 

test/test_tracer.cpp

@@ -18,6 +18,10 @@
 #include <datadog/tracer.h>
 #include <datadog/tracer_config.h>
 #include <datadog/w3c_propagation.h>
+#include <dirent.h>
+#include <stdio.h>
+#include <sys/types.h>
+#include <unistd.h>
 
 #include <chrono>
 #include <ctime>
@@ -1844,7 +1848,9 @@ TEST_TRACER("APM tracing disabled") {
       auto finalized_config = finalize_config(config, clock);
       REQUIRE(finalized_config);
       Tracer tracer{*finalized_config};
-      { auto root1 = tracer.create_span(); }
+      {
+        auto root1 = tracer.create_span();
+      }
       REQUIRE(collector->chunks.size() == 1);
       REQUIRE(collector->chunks.front().size() == 1);
 
@@ -1923,7 +1929,9 @@ TEST_TRACER("APM tracing disabled") {
 
     // When APM Tracing is disabled, we allow one trace per second for service
     // liveness. To ensure consistency, consume the limiter slot.
-    { tracer.create_span(); }
+    {
+      tracer.create_span();
+    }
     collector->chunks.clear();
 
     // Case 1: extracted context with priority, but no `_dd.p.ts` → depends if
@@ -2034,3 +2042,48 @@ TEST_TRACER("APM tracing disabled") {
     }
   }
 }
+
+#if defined(__linux__) || defined(__unix__)
+TEST_TRACER("process discovery") {
+  auto find_memfd = []() -> std::optional<std::string> {
+    DIR* dir = opendir("/proc/self/fd");
+    if (dir == nullptr) return nullopt;
+
+    char path[PATH_MAX];
+    char target[PATH_MAX];
+
+    for (struct dirent* entry = readdir(dir); entry != nullptr;
+         entry = readdir(dir)) {
+      if (entry->d_type != DT_LNK) continue;
+
+      snprintf(path, sizeof(path), "/proc/self/fd/%s", entry->d_name);
+      auto len = readlink(path, target, sizeof(target) - 1);
+      if (len == -1) continue;
+      target[len] = '\0';
+
+      if (starts_with(target, "/memfd:datadog-tracer-info-")) {
+        closedir(dir);
+        return path;
+      }
+    }
+
+    return nullopt;
+  };
+
+  TracerConfig cfg;
+  auto finalized_config = finalize_config(cfg);
+  REQUIRE(finalized_config);
+
+  {
+    Tracer tracer{*finalized_config};
+
+    auto fd = find_memfd();
+    CHECK(fd);
+
+    // TODO: Read content
+  }
+
+  auto fd = find_memfd();
+  CHECK(!fd);
+}
+#endif