use Abseil's string_view in Bazel builds, for Envoy.

Author: dgoffredo

BUILD.bazel

@@ -38,6 +38,7 @@ cc_library(
     "src/datadog/span_matcher.cpp",
     "src/datadog/span_sampler_config.cpp",
     "src/datadog/span_sampler.cpp",
+    "src/datadog/string_view.cpp",
     "src/datadog/tag_propagation.cpp",
     "src/datadog/tags.cpp",
     "src/datadog/threaded_event_scheduler.cpp",
@@ -87,6 +88,7 @@ cc_library(
     "src/datadog/span_matcher.h",
     "src/datadog/span_sampler_config.h",
     "src/datadog/span_sampler.h",
+    "src/datadog/string_view.h",
     "src/datadog/tag_propagation.h",
     "src/datadog/tags.h",
     "src/datadog/threaded_event_scheduler.h",
@@ -103,7 +105,11 @@ cc_library(
         "-Werror",
         "-pedantic",
         "-std=c++17",
+        "-DDD_USE_ABSEIL_FOR_ENVOY",
     ],
     strip_include_prefix = "src/",
     visibility = ["//visibility:public"],
+    deps = [
+        "@com_google_absl//absl/strings",
+    ],
 )

CMakeLists.txt

@@ -90,6 +90,7 @@ target_sources(dd_trace_cpp PRIVATE
     src/datadog/span_matcher.cpp
     src/datadog/span_sampler_config.cpp
     src/datadog/span_sampler.cpp
+    src/datadog/string_view.cpp
     src/datadog/tag_propagation.cpp
     src/datadog/tags.cpp
     src/datadog/threaded_event_scheduler.cpp
@@ -145,6 +146,7 @@ target_sources(dd_trace_cpp PUBLIC
   src/datadog/span_matcher.h
   src/datadog/span_sampler_config.h
   src/datadog/span_sampler.h
+  src/datadog/string_view.h
   src/datadog/tag_propagation.h
   src/datadog/tags.h
   src/datadog/threaded_event_scheduler.h

WORKSPACE

@@ -0,0 +1,27 @@
+# The Bazel build is primarily for use by Envoy.
+#
+# Envoy forbids use of std::string_view and std::optional, preferring use of
+# Abseil's absl::string_view and absl::optional instead.
+#
+# In the context of an Envoy build, the Abseil libraries point to whatever
+# versions Envoy uses.
+#
+# To test this library's Bazel build independent of Envoy, we need to specify
+# versions of the Abseil libraries. That is what this file is for.
+
+# These rules are based on <https://abseil.io/docs/cpp/quickstart>,
+# accessed December 6, 2022.
+load("@bazel_tools//tools/build_defs/repo:http.bzl", "http_archive")
+
+http_archive(
+  name = "com_google_absl",
+  urls = ["https://github.com/abseil/abseil-cpp/archive/98eb410c93ad059f9bba1bf43f5bb916fc92a5ea.zip"],
+  sha256 = "aabf6c57e3834f8dc3873a927f37eaf69975d4b28117fc7427dfb1c661542a87",
+  strip_prefix = "abseil-cpp-98eb410c93ad059f9bba1bf43f5bb916fc92a5ea",
+)
+
+http_archive(
+  name = "bazel_skylib",
+  urls = ["https://github.com/bazelbuild/bazel-skylib/releases/download/1.2.1/bazel-skylib-1.2.1.tar.gz"],
+  sha256 = "f7be3474d42aae265405a592bb7da8e171919d74c16f082a5457840f06054728",
+)

WORKSPACE.bazel

@@ -3,8 +3,8 @@
 namespace datadog {
 namespace tracing {
 
-std::string CollectorResponse::key(std::string_view service,
-                                   std::string_view environment) {
+std::string CollectorResponse::key(StringView service,
+                                   StringView environment) {
   std::string result;
   result += "service:";
   result += service;

src/datadog/collector_response.cpp

@@ -14,7 +14,7 @@
 // information.
 
 #include <string>
-#include <string_view>
+#include "string_view.h"
 #include <unordered_map>
 
 #include "rate.h"
@@ -23,8 +23,8 @@ namespace datadog {
 namespace tracing {
 
 struct CollectorResponse {
-  static std::string key(std::string_view service,
-                         std::string_view environment);
+  static std::string key(StringView service,
+                         StringView environment);
   static const std::string key_of_default_rate;
   std::unordered_map<std::string, Rate> sample_rate_by_key;
 };

src/datadog/collector_response.h

@@ -11,7 +11,7 @@
 #include <list>
 #include <memory>
 #include <mutex>
-#include <string_view>
+#include "string_view.h"
 #include <thread>
 #include <unordered_map>
 #include <unordered_set>
@@ -61,7 +61,7 @@ class CurlImpl {
    public:
     ~HeaderWriter();
     curl_slist *release();
-    void set(std::string_view key, std::string_view value) override;
+    void set(StringView key, StringView value) override;
   };
 
   class HeaderReader : public DictReader {
@@ -71,9 +71,9 @@ class CurlImpl {
    public:
     explicit HeaderReader(
         std::unordered_map<std::string, std::string> *response_headers_lower);
-    std::optional<std::string_view> lookup(std::string_view key) const override;
+    std::optional<StringView> lookup(StringView key) const override;
     void visit(
-        const std::function<void(std::string_view key, std::string_view value)>
+        const std::function<void(StringView key, StringView value)>
             &visitor) const override;
   };
 
@@ -88,7 +88,7 @@ class CurlImpl {
                                   void *user_data);
   static bool is_non_whitespace(unsigned char);
   static char to_lower(unsigned char);
-  static std::string_view trim(std::string_view);
+  static StringView trim(StringView);
 
  public:
   explicit CurlImpl(const std::shared_ptr<Logger> &logger);
@@ -426,7 +426,7 @@ curl_slist *CurlImpl::HeaderWriter::release() {
   return list;
 }
 
-void CurlImpl::HeaderWriter::set(std::string_view key, std::string_view value) {
+void CurlImpl::HeaderWriter::set(StringView key, StringView value) {
   buffer_.clear();
   buffer_ += key;
   buffer_ += ": ";
@@ -439,8 +439,8 @@ CurlImpl::HeaderReader::HeaderReader(
     std::unordered_map<std::string, std::string> *response_headers_lower)
     : response_headers_lower_(response_headers_lower) {}
 
-std::optional<std::string_view> CurlImpl::HeaderReader::lookup(
-    std::string_view key) const {
+std::optional<StringView> CurlImpl::HeaderReader::lookup(
+    StringView key) const {
   buffer_.clear();
   std::transform(key.begin(), key.end(), std::back_inserter(buffer_),
                  &to_lower);
@@ -453,7 +453,7 @@ std::optional<std::string_view> CurlImpl::HeaderReader::lookup(
 }
 
 void CurlImpl::HeaderReader::visit(
-    const std::function<void(std::string_view key, std::string_view value)>
+    const std::function<void(StringView key, StringView value)>
         &visitor) const {
   for (const auto &[key, value] : *response_headers_lower_) {
     visitor(key, value);

src/datadog/curl.cpp

@@ -21,7 +21,7 @@ namespace datadog {
 namespace tracing {
 namespace {
 
-const std::string_view traces_api_path = "/v0.4/traces";
+const StringView traces_api_path = "/v0.4/traces";
 
 HTTPClient::URL traces_endpoint(const HTTPClient::URL& agent_url) {
   auto traces_url = agent_url;
@@ -49,10 +49,10 @@ Expected<void> msgpack_encode(
 }
 
 std::variant<CollectorResponse, std::string> parse_agent_traces_response(
-    std::string_view body) try {
+    StringView body) try {
   nlohmann::json response = nlohmann::json::parse(body);
 
-  std::string_view type = response.type_name();
+  StringView type = response.type_name();
   if (type != "object") {
     std::string message;
     message +=
@@ -66,7 +66,7 @@ std::variant<CollectorResponse, std::string> parse_agent_traces_response(
     return message;
   }
 
-  const std::string_view sample_rates_property = "rate_by_service";
+  const StringView sample_rates_property = "rate_by_service";
   const auto found = response.find(sample_rates_property);
   if (found == response.end()) {
     return CollectorResponse{};

src/datadog/datadog_agent.cpp

@@ -11,8 +11,8 @@
 namespace datadog {
 namespace tracing {
 
-Expected<HTTPClient::URL> DatadogAgentConfig::parse(std::string_view input) {
-  const std::string_view separator = "://";
+Expected<HTTPClient::URL> DatadogAgentConfig::parse(StringView input) {
+  const StringView separator = "://";
   const auto after_scheme = std::search(input.begin(), input.end(),
                                         separator.begin(), separator.end());
   if (after_scheme == input.end()) {
@@ -23,8 +23,8 @@ Expected<HTTPClient::URL> DatadogAgentConfig::parse(std::string_view input) {
     return Error{Error::URL_MISSING_SEPARATOR, std::move(message)};
   }
 
-  const std::string_view scheme = range(input.begin(), after_scheme);
-  const std::string_view supported[] = {"http", "https", "unix", "http+unix",
+  const StringView scheme = range(input.begin(), after_scheme);
+  const StringView supported[] = {"http", "https", "unix", "http+unix",
                                         "https+unix"};
   const auto found =
       std::find(std::begin(supported), std::end(supported), scheme);
@@ -42,7 +42,7 @@ Expected<HTTPClient::URL> DatadogAgentConfig::parse(std::string_view input) {
     return Error{Error::URL_UNSUPPORTED_SCHEME, std::move(message)};
   }
 
-  const std::string_view authority_and_path =
+  const StringView authority_and_path =
       range(after_scheme + separator.size(), input.end());
   // If the scheme is for unix domain sockets, then there's no way to
   // distinguish the path-to-socket from the path-to-resource.  Some

src/datadog/datadog_agent_config.cpp

@@ -14,7 +14,7 @@
 #include <chrono>
 #include <memory>
 #include <string>
-#include <string_view>
+#include "string_view.h"
 #include <variant>
 
 #include "expected.h"
@@ -50,7 +50,7 @@ struct DatadogAgentConfig {
   // How often, in milliseconds, to send batches of traces to the Datadog Agent.
   int flush_interval_milliseconds = 2000;
 
-  static Expected<HTTPClient::URL> parse(std::string_view);
+  static Expected<HTTPClient::URL> parse(StringView);
 };
 
 class FinalizedDatadogAgentConfig {