Resource sdk Implementation

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

@@ -0,0 +1,70 @@
+#pragma once
+
+#include "opentelemetry/nostd/string_view.h"
+#include "opentelemetry/nostd/unique_ptr.h"
+#include "opentelemetry/sdk/trace/attribute_utils.h"
+#include "opentelemetry/sdk/version/version.h"
+#include "opentelemetry/version.h"
+
+#include <cstdlib>
+#include <memory>
+#include <sstream>
+#include <unordered_map>
+
+OPENTELEMETRY_BEGIN_NAMESPACE
+namespace sdk
+{
+namespace resource
+{
+
+class Resource
+{
+public:
+ Resource(const opentelemetry::common::KeyValueIterable &attributes) noexcept;
+
+ Resource(const opentelemetry::sdk::trace::AttributeMap &attributes) noexcept;
+
+ template <class T,
+ nostd::enable_if_t<common::detail::is_key_value_iterable<T>::value> * = nullptr>
+ Resource(const T &attributes) noexcept : Resource(common::KeyValueIterableView<T>(attributes))
+ {}
+
+ Resource(const std::initializer_list<std::pair<nostd::string_view, common::AttributeValue>>
+ attributes) noexcept
+ : Resource(nostd::span<const std::pair<nostd::string_view, common::AttributeValue>>{
+ attributes.begin(), attributes.end()})
+ {}
+
+ const opentelemetry::sdk::trace::AttributeMap &GetAttributes() const noexcept;
+
+ std::unique_ptr<Resource> Merge(const Resource &other);
+
+ static std::unique_ptr<Resource> Create(
+ const opentelemetry::common::KeyValueIterable &attributes);
+
+ static std::unique_ptr<Resource> Create(
+ std::initializer_list<std::pair<nostd::string_view, common::AttributeValue>>
+ attributes) noexcept
+ {
+ return Create(nostd::span<const std::pair<nostd::string_view, common::AttributeValue>>{
+ attributes.begin(), attributes.end()});
+ }
+
+ template <class T,
+ nostd::enable_if_t<common::detail::is_key_value_iterable<T>::value> * = nullptr>
+ static std::unique_ptr<Resource> Create(const T &attributes) noexcept
+ {
+ return Create(common::KeyValueIterableView<T>(attributes));
+ }
+
+ static std::unique_ptr<Resource> CreateEmpty();
+
+ static std::unique_ptr<Resource> Create(const std::string &attributes);
+
+private:
+ const opentelemetry::sdk::trace::AttributeMap attribute_map_;
+};
+
+} // namespace resource
+} // namespace sdk
+OPENTELEMETRY_END_NAMESPACE

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

@@ -0,0 +1,27 @@
+#pragma once
+
+#include "opentelemetry/nostd/unique_ptr.h"
+#include "opentelemetry/sdk/resource/resource.h"
+#include "opentelemetry/version.h"
+
+OPENTELEMETRY_BEGIN_NAMESPACE
+namespace sdk
+{
+namespace resource
+{
+
+class ResourceDetector
+{
+public:
+ virtual std::unique_ptr<opentelemetry::sdk::resource::Resource> Detect() = 0;
+};
+
+class OTELResourceDetector : public ResourceDetector
+{
+public:
+ std::unique_ptr<opentelemetry::sdk::resource::Resource> Detect() noexcept override;
+};
+
+} // namespace resource
+} // namespace sdk
+OPENTELEMETRY_END_NAMESPACE

sdk/include/opentelemetry/sdk/trace/attribute_utils.h

@@ -116,6 +116,19 @@ class AttributeMap
  return attributes_;
  }
 
+ void AddAttributes(const AttributeMap &other)
+ {
+ for (auto &attr : other.attributes_)
+ {
+ if ((attributes_.find(attr.first) == attributes_.end()) ||
+ (nostd::holds_alternative<std::string>(attributes_[attr.first]) &&
+ nostd::get<std::string>(attributes_[attr.first]).size() == 0))
+ {
+ attributes_[attr.first] = attr.second;
+ }
+ }
+ }
+
  void SetAttribute(nostd::string_view key,
  const opentelemetry::common::AttributeValue &value) noexcept
  {

sdk/src/CMakeLists.txt

@@ -3,3 +3,4 @@ add_subdirectory(trace)
 add_subdirectory(metrics)
 add_subdirectory(logs)
 add_subdirectory(version)
+add_subdirectory(resource)

sdk/src/resource/BUILD

@@ -0,0 +1,26 @@
+# Copyright 2020, OpenTelemetry Authors
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+package(default_visibility = ["//visibility:public"])
+
+cc_library(
+ name = "resource",
+ srcs = glob(["**/*.cc"]),
+ hdrs = glob(["**/*.h"]),
+ include_prefix = "src/resource",
+ deps = [
+ "//api",
+ "//sdk:headers",
+ ],
+)

sdk/src/resource/CMakeLists.txt

@@ -0,0 +1,16 @@
+add_library(opentelemetry_resources resource.cc resource_detector.cc)
+
+set_target_properties(opentelemetry_resources PROPERTIES EXPORT_NAME resources)
+
+target_link_libraries(opentelemetry_resources opentelemetry_common)
+
+target_include_directories(
+ opentelemetry_resources
+ PUBLIC "$<BUILD_INTERFACE:${PROJECT_SOURCE_DIR}/sdk/include>")
+
+install(
+ TARGETS opentelemetry_resources
+ EXPORT "${PROJECT_NAME}-target"
+ RUNTIME DESTINATION ${CMAKE_INSTALL_BINDIR}
+ LIBRARY DESTINATION ${CMAKE_INSTALL_LIBDIR}
+ ARCHIVE DESTINATION ${CMAKE_INSTALL_LIBDIR})

sdk/src/resource/resource.cc

@@ -0,0 +1,74 @@
+#include "opentelemetry/sdk/resource/resource.h"
+#include "opentelemetry/nostd/span.h"
+#include "opentelemetry/sdk/resource/resource_detector.h"
+#include "opentelemetry/version.h"
+
+OPENTELEMETRY_BEGIN_NAMESPACE
+namespace sdk
+{
+namespace resource
+{
+
+const std::string TELEMETRY_SDK_LANGUAGE = "telemetry.sdk.language";
+const std::string TELEMETRY_SDK_NAME = "telemetry.sdk.name";
+const std::string TELEMETRY_SDK_VERSION = "telemetry.sdk.version";
+
+Resource::Resource(const opentelemetry::common::KeyValueIterable &attributes) noexcept
+ : attribute_map_(attributes)
+{}
+
+Resource::Resource(const opentelemetry::sdk::trace::AttributeMap &attributes) noexcept
+ : attribute_map_(attributes)
+{}
+
+const opentelemetry::sdk::trace::AttributeMap &Resource::GetAttributes() const noexcept
+{
+ return attribute_map_;
+}
+
+std::unique_ptr<Resource> Resource::Merge(const Resource &other)
+{
+ opentelemetry::sdk::trace::AttributeMap merged_resource_attributes(other.GetAttributes());
+ merged_resource_attributes.AddAttributes(attribute_map_);
+ return std::unique_ptr<Resource>(new Resource(merged_resource_attributes));
+}
+
+std::unique_ptr<Resource> Resource::Create(
+ const opentelemetry::common::KeyValueIterable &attributes)
+{
+ Resource default_resource({{{TELEMETRY_SDK_LANGUAGE, "cpp"},
+ {TELEMETRY_SDK_NAME, "opentelemetry"},
+ {TELEMETRY_SDK_VERSION, OPENTELEMETRY_SDK_VERSION}}});
+
+ if (attributes.size() > 0)
+ {
+ Resource input_resource(attributes);
+ auto merged_resource = default_resource.Merge(input_resource);
+ return merged_resource->Merge(*(OTELResourceDetector().Detect()));
+ }
+ return default_resource.Merge(*(OTELResourceDetector().Detect()));
+}
+
+std::unique_ptr<Resource> Resource::CreateEmpty()
+{
+ return Create({});
+}
+
+std::unique_ptr<Resource> Resource::Create(const std::string &attributes)
+{
+ opentelemetry::sdk::trace::AttributeMap resource_attributes;
+ std::istringstream iss(attributes);
+ std::string token;
+ while (std::getline(iss, token, ','))
+ {
+ size_t pos = token.find('=');
+ std::string key = token.substr(0, pos);
+ std::string value = token.substr(pos + 1);
+ resource_attributes.SetAttribute(key, value);
+ }
+ return std::unique_ptr<Resource>(new Resource(resource_attributes));
+}
+
+} // namespace resource
+} // namespace sdk
+OPENTELEMETRY_END_NAMESPACE

sdk/src/resource/resource_detector.cc

@@ -0,0 +1,22 @@
+#include "opentelemetry/sdk/resource/resource_detector.h"
+#include <cstdlib>
+
+OPENTELEMETRY_BEGIN_NAMESPACE
+namespace sdk
+{
+namespace resource
+{
+
+const char *OTEL_RESOURCE_ATTRIBUTES = "OTEL_RESOURCE_ATTRIBUTES";
+
+std::unique_ptr<Resource> OTELResourceDetector::Detect() noexcept
+{
+ char *resource_attributes_str = std::getenv(OTEL_RESOURCE_ATTRIBUTES);
+ if (resource_attributes_str == nullptr)
+ return std::unique_ptr<Resource>(new Resource({}));
+ return Resource::Create(std::string(resource_attributes_str));
+}
+
+} // namespace resource
+} // namespace sdk
+OPENTELEMETRY_END_NAMESPACE

sdk/test/CMakeLists.txt

@@ -2,3 +2,4 @@ add_subdirectory(common)
 add_subdirectory(trace)
 add_subdirectory(metrics)
 add_subdirectory(logs)
+add_subdirectory(resource)

sdk/test/resource/BUILD

@@ -0,0 +1,11 @@
+cc_test(
+ name = "resource_test",
+ srcs = [
+ "resource_test.cc",
+ ],
+ deps = [
+ "//api",
+ "//sdk/src/resource",
+ "@com_google_googletest//:gtest_main",
+ ],
+)

sdk/test/resource/CMakeLists.txt

@@ -0,0 +1,9 @@
+foreach(testname resource_test)
+ add_executable(${testname} "${testname}.cc")
+ target_link_libraries(${testname} ${GTEST_BOTH_LIBRARIES}
+ ${CMAKE_THREAD_LIBS_INIT} opentelemetry_resources)
+ gtest_add_tests(
+ TARGET ${testname}
+ TEST_PREFIX resources.
+ TEST_LIST ${testname})
+endforeach()