replication_group_id -> db_replication_id

percona · Mar 20, 2024 · b567438 · b567438
1 parent 294c654
commit b567438
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 12 deletions.
diff --git a/components/percona_telemetry/data_provider.cc b/components/percona_telemetry/data_provider.cc
@@ -351,7 +351,7 @@ bool DataProvider::collect_group_replication_info(
 
     rapidjson::Value replication_group_id;
     replication_group_id.SetString(result[0][1].c_str(), allocator);
-    gr_json.AddMember(rapidjson::StringRef("replication_group_id"),
+    gr_json.AddMember(rapidjson::StringRef("db_replication_id"),
                       replication_group_id, allocator);
 
     rapidjson::Value single_primary_mode;

diff --git a/components/percona_telemetry/data_provider.h b/components/percona_telemetry/data_provider.h
@@ -10,7 +10,6 @@
 #include <mysql/components/services/mysql_command_services.h>
 #include <mysql/components/services/security_context.h>
 
-//>> ugly part start
 #ifdef RAPIDJSON_NO_SIZETYPEDEFINE
 #include "my_rapidjson_size_t.h"
 #endif
@@ -27,7 +26,6 @@ using RapidJsonWritterType = rapidjson::PrettyWriter<rapidjson::StringBuffer>;
 #endif
 
 #include <rapidjson/stringbuffer.h>
-// ugly part end <<
 
 using Row = std::vector<std::string>;
 using QueryResult = std::vector<Row>;
@@ -54,7 +52,6 @@ class DataProvider {
 
   void thread_access_begin();
   void thread_access_end();
-  const std::string &get_database_instance_id();
   std::string get_report();
 
  private:
@@ -73,6 +70,8 @@ class DataProvider {
   bool collect_async_replication_info(rapidjson::Document *document);
   bool collect_metrics(rapidjson::Document *document);
 
+  const std::string &get_database_instance_id();
+
   SERVICE_TYPE(mysql_command_factory) & command_factory_service_;
   SERVICE_TYPE(mysql_command_options) & command_options_service_;
   SERVICE_TYPE(mysql_command_query) & command_query_service_;

diff --git a/components/percona_telemetry/worker.cc b/components/percona_telemetry/worker.cc
@@ -50,14 +50,6 @@ void Worker::worker_thd_fn() {
   // The server is probably still initializing if the grace period is low, so
   // we need to wait up to the point when database connection can be done
 
-  // We do it only once, as it is constant
-  std::string db_id = data_provider_.get_database_instance_id();
-
-  if (!db_id.length()) {
-    logger_.warning("get_database_instance_id() failed");
-    // and what now? fallback or game over?
-  }
-
   logger_.info("Scrape interval: %d seconds", config_.scrape_interval());
   logger_.info("History keep interval: %d seconds",
                config_.history_keep_interval());