Implement bridge wrapper for tracer

Author: avsej

CMakeLists.txt

@@ -75,15 +75,20 @@ set(couchbase_cxx_client_FILES
     core/agent_group.cxx
     core/agent_group_config.cxx
     core/analytics_query_options.cxx
+    core/app_telemetry_address.cxx
+    core/app_telemetry_meter.cxx
+    core/app_telemetry_reporter.cxx
     core/bucket.cxx
+    core/chrono_utils.cxx
     core/cluster.cxx
     core/cluster_agent.cxx
     core/cluster_agent_config.cxx
+    core/cluster_credentials.cxx
     core/cluster_options.cxx
     core/collections_component.cxx
+    core/columnar/backoff_calculator.cxx
     core/columnar/columnar_agent.cxx
     core/columnar/columnar_agent_config.cxx
-    core/columnar/backoff_calculator.cxx
     core/columnar/columnar_error.cxx
     core/columnar/error_codes.cxx
     core/columnar/management_component.cxx
@@ -105,14 +110,13 @@ set(couchbase_cxx_client_FILES
     core/impl/binary_collection.cxx
     core/impl/boolean_field_query.cxx
     core/impl/boolean_query.cxx
-    core/impl/public_bucket.cxx
     core/impl/bucket_manager.cxx
-    core/impl/public_cluster.cxx
     core/impl/collection.cxx
     core/impl/collection_manager.cxx
     core/impl/common_error_category.cxx
     core/impl/configuration_profiles_registry.cxx
     core/impl/conjunction_query.cxx
+    core/impl/crypto.cxx
     core/impl/date_range.cxx
     core/impl/date_range_facet.cxx
     core/impl/date_range_facet_result.cxx
@@ -141,7 +145,6 @@ set(couchbase_cxx_client_FILES
     core/impl/internal_term_facet_result.cxx
     core/impl/key_value_error_category.cxx
     core/impl/key_value_error_context.cxx
-    core/impl/public_logger.cxx
     core/impl/lookup_in_replica.cxx
     core/impl/management_error_category.cxx
     core/impl/match_all_query.cxx
@@ -157,6 +160,11 @@ set(couchbase_cxx_client_FILES
     core/impl/observe_seqno.cxx
     core/impl/phrase_query.cxx
     core/impl/prefix_query.cxx
+    core/impl/public_bucket.cxx
+    core/impl/public_cluster.cxx
+    core/impl/public_logger.cxx
+    core/impl/public_scan_result.cxx
+    core/impl/public_transaction_get_result.cxx
     core/impl/query.cxx
     core/impl/query_error_category.cxx
     core/impl/query_error_context.cxx
@@ -166,7 +174,6 @@ set(couchbase_cxx_client_FILES
     core/impl/replica_utils.cxx
     core/impl/retry_action.cxx
     core/impl/retry_reason.cxx
-    core/impl/public_scan_result.cxx
     core/impl/scope.cxx
     core/impl/search.cxx
     core/impl/search_error_category.cxx
@@ -206,13 +213,11 @@ set(couchbase_cxx_client_FILES
     core/impl/transaction_error_category.cxx
     core/impl/transaction_get_multi_replicas_from_preferred_server_group_spec.cxx
     core/impl/transaction_get_multi_spec.cxx
-    core/impl/public_transaction_get_result.cxx
     core/impl/transaction_op_error_category.cxx
     core/impl/vector_query.cxx
     core/impl/vector_search.cxx
     core/impl/view_error_category.cxx
     core/impl/wildcard_query.cxx
-    core/impl/crypto.cxx
     core/io/config_tracker.cxx
     core/io/dns_client.cxx
     core/io/dns_config.cxx
@@ -225,6 +230,7 @@ set(couchbase_cxx_client_FILES
     core/io/mcbp_session.cxx
     core/io/streams.cxx
     core/key_value_config.cxx
+    core/log_entry.cxx
     core/logger/custom_rotating_file_sink.cxx
     core/logger/logger.cxx
     core/management/analytics_link_azure_blob_external.cxx
@@ -241,6 +247,7 @@ set(couchbase_cxx_client_FILES
     core/mcbp/queue_request.cxx
     core/mcbp/server_duration.cxx
     core/meta/version.cxx
+    core/metric_measurement.cxx
     core/metrics/logging_meter.cxx
     core/metrics/meter_wrapper.cxx
     core/n1ql_query_options.cxx
@@ -339,6 +346,7 @@ set(couchbase_cxx_client_FILES
     core/operations/management/view_index_get_all.cxx
     core/operations/management/view_index_upsert.cxx
     core/origin.cxx
+    core/orphan_reporter.cxx
     core/platform/base64.cc
     core/platform/dirutils.cc
     core/platform/random.cc
@@ -395,10 +403,10 @@ set(couchbase_cxx_client_FILES
     core/seed_config.cxx
     core/signal_bridge.cxx
     core/signal_data.cxx
-    core/metric_measurement.cxx
-    core/chrono_utils.cxx
     core/topology/capabilities.cxx
     core/topology/configuration.cxx
+    core/trace_span.cxx
+    core/tracing/file_tracer.cxx
     core/tracing/threshold_logging_tracer.cxx
     core/tracing/tracer_wrapper.cxx
     core/transactions/active_transaction_record.cxx
@@ -436,11 +444,6 @@ set(couchbase_cxx_client_FILES
     core/utils/url_codec.cxx
     core/view_query_options.cxx
     core/websocket_codec.cxx
-    core/app_telemetry_address.cxx
-    core/app_telemetry_meter.cxx
-    core/app_telemetry_reporter.cxx
-    core/cluster_credentials.cxx
-    core/orphan_reporter.cxx
 )
 
 set(couchbase_cxx_client_LIBRARIES)

core/log_entry.cxx

@@ -0,0 +1,68 @@
+/* -*- Mode: C++; tab-width: 4; c-basic-offset: 4; indent-tabs-mode: nil -*- */
+/*
+ *   Copyright 2025-Current Couchbase, Inc.
+ *
+ *   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.
+ */
+
+#include "log_entry.hxx"
+
+#include <tao/json.hpp>
+#include <tao/json/contrib/traits.hpp>
+
+namespace tao::json
+{
+template<>
+struct traits<couchbase::core::signal_attribute> {
+  template<template<typename...> class Traits>
+  static void assign(basic_value<Traits>& v, const couchbase::core::signal_attribute& attr)
+  {
+    v = {
+      { "name", attr.name },
+      { "value", attr.value },
+    };
+  }
+};
+
+template<>
+struct traits<couchbase::core::log_entry> {
+  template<template<typename...> class Traits>
+  static void assign(basic_value<Traits>& v, const couchbase::core::log_entry& entry)
+  {
+    v = {
+      { "timestamp", entry.timestamp },
+      { "severity", entry.severity },
+      { "message", entry.message },
+      {
+        "context",
+        {
+          { "trace_id", entry.context.trace_id },
+          { "span_id", entry.context.span_id },
+        },
+      },
+      { "attributes", entry.attributes },
+    };
+  }
+};
+} // namespace tao::json
+
+namespace couchbase::core
+{
+
+auto
+to_string(const log_entry& data) -> std::string
+{
+  tao::json::value json = data;
+  return tao::json::to_string(json);
+}
+} // namespace couchbase::core

core/log_entry.hxx

@@ -37,6 +37,9 @@ struct log_entry {
   std::vector<signal_attribute> attributes{};
 };
 
+auto
+to_string(const log_entry& data) -> std::string;
+
 inline auto
 operator==(const log_entry& lhs, const log_entry& rhs) -> bool
 {

core/metric_measurement.cxx

@@ -17,8 +17,34 @@
 
 #include "metric_measurement.hxx"
 
+#include <tao/json.hpp>
+
+namespace tao::json
+{
+template<>
+struct traits<couchbase::core::metric_measurement> {
+  template<template<typename...> class Traits>
+  static void assign(basic_value<Traits>& v, const couchbase::core::metric_measurement& measurement)
+  {
+    v = basic_value<Traits>::object({});
+    v["name"] = measurement.name();
+
+    if (measurement.is_int64()) {
+      v["value"] = measurement.as_int64();
+    } else if (measurement.is_double()) {
+      v["value"] = measurement.as_double();
+    }
+  }
+};
+} // namespace tao::json
+
 namespace couchbase::core
 {
+[[nodiscard]] auto
+metric_measurement::name() const noexcept -> const std::string&
+{
+  return name_;
+}
 
 [[nodiscard]] auto
 metric_measurement::is_double() const noexcept -> bool
@@ -62,4 +88,10 @@ metric_measurement::try_as_int64() && -> std::optional<std::int64_t>
   return std::nullopt;
 }
 
+auto
+to_string(const metric_measurement& data) -> std::string
+{
+  tao::json::value json = data;
+  return tao::json::to_string(json);
+}
 } // namespace couchbase::core

core/metric_measurement.hxx

@@ -52,6 +52,8 @@ public:
   auto operator=(const metric_measurement&) -> metric_measurement& = default;
   auto operator=(metric_measurement&&) -> metric_measurement& = default;
 
+  [[nodiscard]] auto name() const noexcept -> const std::string&;
+
   [[nodiscard]] auto is_double() const noexcept -> bool;
   [[nodiscard]] auto as_double() const -> double;
   [[nodiscard]] auto try_as_double() && -> std::optional<double>;
@@ -75,6 +77,9 @@ private:
   std::variant<double, std::int64_t> value_;
 };
 
+auto
+to_string(const metric_measurement& data) -> std::string;
+
 inline auto
 operator==(const metric_measurement& lhs, const metric_measurement& rhs) -> bool
 {

core/signal_data.cxx

@@ -154,4 +154,18 @@ signal_data::try_as_log_entry() && -> std::optional<log_entry>
   }
   return std::nullopt;
 }
+
+auto
+to_string(const signal_data& data) -> std::string
+{
+  return std::visit(
+    [](const auto& value) -> std::string {
+      if constexpr (std::is_same_v<std::decay_t<decltype(value)>, std::monostate>) {
+        return "{}";
+      } else {
+        return to_string(value);
+      }
+    },
+    data.record_);
+};
 } // namespace couchbase::core

core/signal_data.hxx

@@ -88,11 +88,15 @@ public:
   }
 
   friend auto operator==(const signal_data& lhs, const signal_data& rhs) -> bool;
+  friend auto to_string(const signal_data& data) -> std::string;
 
 private:
   std::variant<std::monostate, trace_span, metric_measurement, log_entry> record_{};
 };
 
+auto
+to_string(const signal_data& data) -> std::string;
+
 inline auto
 operator==(const signal_data& lhs, const signal_data& rhs) -> bool
 {

core/trace_span.cxx

@@ -0,0 +1,83 @@
+/* -*- Mode: C++; tab-width: 4; c-basic-offset: 4; indent-tabs-mode: nil -*- */
+/*
+ *   Copyright 2025-Current Couchbase, Inc.
+ *
+ *   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.
+ */
+
+#include "trace_span.hxx"
+
+#include <tao/json.hpp>
+#include <tao/json/contrib/traits.hpp>
+
+namespace tao::json
+{
+template<>
+struct traits<couchbase::core::signal_attribute> {
+  template<template<typename...> class Traits>
+  static void assign(basic_value<Traits>& v, const couchbase::core::signal_attribute& attr)
+  {
+    v = {
+      { "name", attr.name },
+      { "value", attr.value },
+    };
+  }
+};
+
+template<>
+struct traits<couchbase::core::trace_event> {
+  template<template<typename...> class Traits>
+  static void assign(basic_value<Traits>& v, const couchbase::core::trace_event& event)
+  {
+    v = {
+      { "name", event.name },
+      { "timestamp", event.timestamp },
+      { "attributes", event.attributes },
+    };
+  }
+};
+
+template<>
+struct traits<couchbase::core::trace_span> {
+  template<template<typename...> class Traits>
+  static void assign(basic_value<Traits>& v, const couchbase::core::trace_span& span)
+  {
+    v = {
+      { "name", span.name },
+      {
+        "context",
+        {
+          { "trace_id", span.context.trace_id },
+          { "span_id", span.context.span_id },
+        },
+      },
+      { "parent_id", span.parent_id },
+      { "start_time", span.start_time },
+      { "end_time", span.end_time },
+      { "attributes", span.attributes },
+      { "events", span.events },
+    };
+  }
+};
+} // namespace tao::json
+
+namespace couchbase::core
+{
+
+auto
+to_string(const trace_span& data) -> std::string
+{
+  tao::json::value json = data;
+  return tao::json::to_string(json);
+}
+} // namespace couchbase::core