Define observability interface between core SDK and the wrapper

Author: avsej

CMakeLists.txt

@@ -81,6 +81,7 @@ set(couchbase_cxx_client_FILES
     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
@@ -102,6 +103,7 @@ set(couchbase_cxx_client_FILES
     core/dispatcher.cxx
     core/document_id.cxx
     core/error_context/key_value.cxx
+    core/file_signal_sink.cxx
     core/free_form_http_request.cxx
     core/http_component.cxx
     core/impl/analytics.cxx
@@ -233,6 +235,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
@@ -249,6 +252,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
@@ -402,8 +406,11 @@ set(couchbase_cxx_client_FILES
     core/scan_result.cxx
     core/search_query_options.cxx
     core/seed_config.cxx
+    core/signal_bridge.cxx
+    core/signal_data.cxx
     core/topology/capabilities.cxx
     core/topology/configuration.cxx
+    core/trace_span.cxx
     core/tracing/threshold_logging_tracer.cxx
     core/tracing/tracer_wrapper.cxx
     core/tracing/wrapper_sdk_tracer.cxx

core/chrono_utils.cxx

@@ -0,0 +1,63 @@
+/* -*- 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 "chrono_utils.hxx"
+
+#include <array>
+#include <chrono>
+#include <stdexcept>
+
+namespace couchbase::core
+{
+auto
+to_iso8601_utc(std::time_t time_in_seconds, std::int64_t microseconds) -> std::string
+{
+  std::tm tm{};
+#if defined(_MSC_VER)
+  gmtime_s(&tm, &time_in_seconds);
+#else
+  gmtime_r(&time_in_seconds, &tm);
+#endif
+
+  std::array<char, 100> buffer{};
+  auto rc = std::snprintf(buffer.data(),
+                          buffer.size(),
+                          "%04d-%02d-%02dT%02d:%02d:%02d.%06lldZ",
+                          tm.tm_year + 1900,
+                          tm.tm_mon + 1,
+                          tm.tm_mday,
+                          tm.tm_hour,
+                          tm.tm_min,
+                          tm.tm_sec,
+                          static_cast<long long>(microseconds));
+  auto bytes_written = static_cast<std::size_t>(rc);
+  if (rc < 0 || bytes_written >= buffer.size()) {
+    throw std::range_error("unable to format date: not enough memory in the buffer");
+  }
+  return { buffer.data(), bytes_written };
+}
+
+auto
+to_iso8601_utc(const std::chrono::system_clock::time_point& time_point) -> std::string
+{
+  const auto duration{ time_point.time_since_epoch() };
+  const auto seconds{ std::chrono::duration_cast<std::chrono::seconds>(duration) };
+  const auto micros{ std::chrono::duration_cast<std::chrono::microseconds>(duration - seconds) };
+
+  return to_iso8601_utc(std::chrono::system_clock::to_time_t(time_point), micros.count());
+}
+} // namespace couchbase::core

core/chrono_utils.hxx

@@ -0,0 +1,30 @@
+/* -*- 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.
+ */
+
+#pragma once
+
+#include <chrono>
+#include <string>
+
+namespace couchbase::core
+{
+auto
+to_iso8601_utc(std::time_t time_in_seconds, std::int64_t microseconds = 0) -> std::string;
+
+auto
+to_iso8601_utc(const std::chrono::system_clock::time_point& time_point) -> std::string;
+} // namespace couchbase::core