[SDK] Implementation of container resource as per semconv

sdk/include/opentelemetry/sdk/common/container.h

@@ -0,0 +1,30 @@
+// Copyright The OpenTelemetry Authors
+// SPDX-License-Identifier: Apache-2.0
+
+#pragma once
+
+#include <string>
+
+#include "opentelemetry/version.h"
+
+OPENTELEMETRY_BEGIN_NAMESPACE
+namespace sdk
+{
+namespace common
+{
+/**
+  Reads the container.id from /proc/self/cgroup file.
+  @param file_path file path of cgroup
+  @return container.id as string or empty string
+*/
+std::string GetContainerIDFromCgroup(const char *file_path);
+
+/**
+  Matches the line with the regex to find container.id
+  @param line contains 
+  @return matched id or empty string
+*/
+std::string ExtractContainerIDFromLine(std::string &line);
+}  // namespace common
+}  // namespace sdk
+OPENTELEMETRY_END_NAMESPACE

sdk/include/opentelemetry/sdk/resource/resource_detector.h

@@ -39,6 +39,17 @@ class OTELResourceDetector : public ResourceDetector
   Resource Detect() noexcept override;
 };
 
+/**
+ * ContainerResourceDetector to detect resource attributes when running inside a containerized environment.
+ * This detector extracts metadata such as container ID from cgroup information
+ * and sets attributes like container.id following the OpenTelemetry semantic conventions.
+ */
+class ContainerResourceDetector : public ResourceDetector
+{
+public:
+  Resource Detect() noexcept override;
+};
+
 }  // namespace resource
 }  // namespace sdk
 OPENTELEMETRY_END_NAMESPACE

sdk/src/common/BUILD

@@ -57,6 +57,17 @@ cc_library(
     ],
 )
 
+cc_library(
+    name = "container",
+    srcs = [
+        "container.cc",
+    ],
+    deps = [
+        "//api",
+        "//sdk:headers",
+    ],
+)
+
 cc_library(
     name = "global_log_handler",
     srcs = [

sdk/src/common/CMakeLists.txt

@@ -1,7 +1,7 @@
 # Copyright The OpenTelemetry Authors
 # SPDX-License-Identifier: Apache-2.0
 
-set(COMMON_SRCS random.cc global_log_handler.cc env_variables.cc base64.cc
+set(COMMON_SRCS random.cc global_log_handler.cc env_variables.cc container.cc base64.cc
                 disabled.cc)
 if(WIN32)
   list(APPEND COMMON_SRCS platform/fork_windows.cc)

sdk/src/common/container.cc

@@ -0,0 +1,53 @@
+// Copyright The OpenTelemetry Authors
+// SPDX-License-Identifier: Apache-2.0
+
+#include "opentelemetry/sdk/common/container.h"
+
+#ifdef _MSC_VER
+#  include <string.h>
+#  define strcasecmp _stricmp
+#else
+#  include <strings.h>
+#endif
+
+#include <fstream>
+#include <regex>
+
+#include "opentelemetry/version.h"
+
+OPENTELEMETRY_BEGIN_NAMESPACE
+namespace sdk
+{
+namespace common
+{
+std::string GetContainerIDFromCgroup(const char* file_path) 
+{
+  std::ifstream cgroup_file(file_path);
+  std::string line;
+
+  while(std::getline(cgroup_file, line))
+  {
+    std::string container_id = ExtractContainerIDFromLine(line);
+    if(!container_id.empty()) 
+    {
+      return container_id;  
+    }
+  }
+  return "";
+}
+
+std::string ExtractContainerIDFromLine(std::string &line)
+{
+  static const std::regex container_id_regex(R"(^.*/(?:.*[-:])?([0-9a-f]+)(?:\.|\s*$))");
+  std::smatch match;
+
+  if (std::regex_search(line, match, container_id_regex))
+  {
+    return match.str(1);
+  }
+
+  return "";
+}
+}  // namespace common
+}  // namespace sdk
+OPENTELEMETRY_END_NAMESPACE

sdk/src/resource/resource.cc

@@ -41,8 +41,9 @@ Resource Resource::Merge(const Resource &other) const noexcept
 Resource Resource::Create(const ResourceAttributes &attributes, const std::string &schema_url)
 {
   static auto otel_resource = OTELResourceDetector().Detect();
+  static auto container_resource = ContainerResourceDetector().Detect();
   auto resource =
-      Resource::GetDefault().Merge(otel_resource).Merge(Resource{attributes, schema_url});
+      Resource::GetDefault().Merge(otel_resource).Merge(container_resource).Merge(Resource{attributes, schema_url});
 
   if (resource.attributes_.find(semconv::service::kServiceName) == resource.attributes_.end())
   {

sdk/src/resource/resource_detector.cc

@@ -4,8 +4,10 @@
 #include "opentelemetry/sdk/resource/resource_detector.h"
 #include "opentelemetry/nostd/variant.h"
 #include "opentelemetry/sdk/common/env_variables.h"
+#include "opentelemetry/sdk/common/container.h"
 #include "opentelemetry/sdk/resource/resource.h"
 #include "opentelemetry/semconv/service_attributes.h"
+#include "opentelemetry/semconv/incubating/container_attributes.h"
 #include "opentelemetry/version.h"
 
 #include <stddef.h>
@@ -21,6 +23,10 @@ namespace resource
 
 const char *OTEL_RESOURCE_ATTRIBUTES = "OTEL_RESOURCE_ATTRIBUTES";
 const char *OTEL_SERVICE_NAME        = "OTEL_SERVICE_NAME";
+/**
+ * This is the file path from where we can get container.id
+*/
+const char *C_GROUP_PATH = "/proc/self/cgroup";
 
 Resource ResourceDetector::Create(const ResourceAttributes &attributes,
                                   const std::string &schema_url)
@@ -68,6 +74,23 @@ Resource OTELResourceDetector::Detect() noexcept
   return ResourceDetector::Create(attributes);
 }
 
+Resource ContainerResourceDetector::Detect() noexcept 
+{
+  std::string container_id = opentelemetry::sdk::common::GetContainerIDFromCgroup(C_GROUP_PATH);
+  if(container_id.empty())
+  {
+    return ResourceDetector::Create({});
+  }
+
+  ResourceAttributes attributes;
+
+  if(!container_id.empty())
+  {
+    attributes[semconv::container::kContainerId] = container_id;
+  }
+  return ResourceDetector::Create(attributes);
+}
+
 }  // namespace resource
 }  // namespace sdk
 OPENTELEMETRY_END_NAMESPACE

sdk/test/resource/resource_test.cc

@@ -8,9 +8,11 @@
 #include <string>
 #include <unordered_map>
 #include <utility>
+#include<fstream>
 
 #include "opentelemetry/nostd/variant.h"
 #include "opentelemetry/sdk/common/attribute_utils.h"
+#include "opentelemetry/sdk/common/container.h"
 #include "opentelemetry/sdk/resource/resource.h"
 #include "opentelemetry/sdk/resource/resource_detector.h"
 #include "opentelemetry/sdk/version/version.h"
@@ -292,3 +294,48 @@ TEST(ResourceTest, DerivedResourceDetector)
   EXPECT_EQ(resource.GetSchemaURL(), detector.schema_url);
   EXPECT_TRUE(received_attributes.find("key") != received_attributes.end());
 }
+
+TEST(ResourceTest, ExctractValidContainerId)
+{
+  std::string line = "13:name=systemd:/podruntime/docker/kubepods/ac679f8a8319c8cf7d38e1adf263bc08d23.aaaa";
+  std::string extracted_id = opentelemetry::sdk::common::ExtractContainerIDFromLine(line);
+  EXPECT_EQ(std::string{"ac679f8a8319c8cf7d38e1adf263bc08d23"}, extracted_id);
+}
+
+TEST(ResourceTest, ExtractIdFromMockUpCGroupFile)
+{
+  const char *filename = "test_cgroup.txt";
+
+  {
+    std::ofstream outfile(filename);
+    outfile << "13:name=systemd:/kuberuntime/containerd/kubepods-pod872d2066_00ef_48ea_a7d8_51b18b72d739:cri-containerd:e857a4bf05a69080a759574949d7a0e69572e27647800fa7faff6a05a8332aa1\n";
+    outfile << "9:cpu:/not-a-container\n";
+  }
+
+  std::string container_id = opentelemetry::sdk::common::GetContainerIDFromCgroup(filename);
+  EXPECT_EQ(container_id, std::string{"e857a4bf05a69080a759574949d7a0e69572e27647800fa7faff6a05a8332aa1"});
+
+  std::remove(filename);
+}
+
+TEST(ResourceTest, DoesNotExtractInvalidLine)
+{
+  std::string line = "this line does not contain a container id";
+  std::string id = opentelemetry::sdk::common::ExtractContainerIDFromLine(line);
+  EXPECT_EQ(id, std::string{""});
+}
+
+TEST(ContainerIdDetectorTest, ReturnsEmptyOnNoMatch)
+{
+  const char *filename = "test_empty_cgroup.txt";
+
+  {
+    std::ofstream outfile(filename);
+    outfile << "no container id here\n";
+  }
+
+  std::string id = opentelemetry::sdk::common::GetContainerIDFromCgroup(filename);
+  EXPECT_EQ(id, std::string{""});
+
+  std::remove(filename);  // cleanup
+}