CXXCBC-626: App Telemetry (#712)

Author: avsej

.cppcheck_suppressions.txt

@@ -19,6 +19,7 @@ unusedFunction:*
 unusedStructMember:*
 unusedVariable:*
 useStlAlgorithm:*
+unusedPrivateFunction:*
 
 # these are not very useful
 checkersReport:*
@@ -34,3 +35,4 @@ variableScope:*/test/test_*
 
 # do not scan third-party code
 *:*/_deps/*
+

CMakeLists.txt

@@ -438,6 +438,11 @@ set(couchbase_cxx_client_FILES
     core/utils/split_string.cxx
     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
 )
 
 set(couchbase_cxx_client_LIBRARIES)

core/app_telemetry_address.cxx

@@ -0,0 +1,55 @@
+/* -*- Mode: C++; tab-width: 4; c-basic-offset: 4; indent-tabs-mode: nil -*- */
+/*
+ * Copyright 2024-Present 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
+ *
+ *     https://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 "app_telemetry_address.hxx"
+
+#include "topology/configuration.hxx"
+
+#include <algorithm>
+#include <random>
+
+namespace couchbase::core
+{
+auto
+get_app_telemetry_addresses(const topology::configuration& config,
+                            bool use_tls,
+                            const std::string& network) -> std::vector<app_telemetry_address>
+{
+  std::vector<app_telemetry_address> addresses;
+  addresses.reserve(config.nodes.size());
+  for (const auto& node : config.nodes) {
+    if (auto app_telemetry_path = node.app_telemetry_path; app_telemetry_path) {
+      auto node_uuid = node.node_uuid;
+      if (node_uuid.empty()) {
+        continue;
+      }
+
+      if (auto port = node.port_or(network, service_type::management, use_tls, 0); port != 0) {
+        addresses.push_back({
+          node.hostname_for(network),
+          std::to_string(port),
+          app_telemetry_path.value(),
+          node_uuid,
+        });
+      }
+    }
+  }
+
+  static thread_local std::default_random_engine gen{ std::random_device{}() };
+  std::shuffle(addresses.begin(), addresses.end(), gen);
+  return addresses;
+}
+
+} // namespace couchbase::core

core/app_telemetry_address.hxx

@@ -0,0 +1,39 @@
+/* -*- Mode: C++; tab-width: 4; c-basic-offset: 4; indent-tabs-mode: nil -*- */
+/*
+ * Copyright 2024-Present 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
+ *
+ *     https://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 <string>
+#include <vector>
+
+namespace couchbase::core
+{
+namespace topology
+{
+struct configuration;
+} // namespace topology
+
+struct app_telemetry_address {
+  std::string hostname;
+  std::string service;
+  std::string path;
+  std::string host_uuid;
+};
+
+auto
+get_app_telemetry_addresses(const topology::configuration& config,
+                            bool use_tls,
+                            const std::string& network) -> std::vector<app_telemetry_address>;
+} // namespace couchbase::core