| // Licensed to the Apache Software Foundation (ASF) under one |
| // or more contributor license agreements. See the NOTICE file |
| // distributed with this work for additional information |
| // regarding copyright ownership. The ASF licenses this file |
| // to you 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 <bthread/mutex.h> |
| #include <bvar/bvar.h> |
| #include <bvar/latency_recorder.h> |
| #include <bvar/multi_dimension.h> |
| #include <bvar/reducer.h> |
| #include <bvar/status.h> |
| |
| #include <cstdint> |
| #include <initializer_list> |
| #include <map> |
| #include <memory> |
| #include <mutex> |
| #include <string> |
| #include <type_traits> |
| #include <utility> |
| |
| /** |
| * Manage bvars that with similar names (identical prefix) |
| * ${module}_${name}_${tag} |
| * where `tag` is added automatically when calling `get` or `put` |
| */ |
| template <typename Bvar, bool is_status = false> |
| class BvarWithTag { |
| public: |
| BvarWithTag(std::string module, std::string name) |
| : module_(std::move(module)), name_(std::move(name)) {} |
| |
| template <typename ValType> |
| requires std::is_integral_v<ValType> |
| void put(const std::string& tag, ValType value) { |
| std::shared_ptr<Bvar> instance = nullptr; |
| { |
| std::lock_guard<bthread::Mutex> l(mutex_); |
| auto it = bvar_map_.find(tag); |
| if (it == bvar_map_.end()) { |
| instance = std::make_shared<Bvar>(module_, name_ + "_" + tag, ValType()); |
| bvar_map_[tag] = instance; |
| } else { |
| instance = it->second; |
| } |
| } |
| // FIXME(gavin): check bvar::Adder and more |
| if constexpr (std::is_same_v<Bvar, bvar::LatencyRecorder>) { |
| (*instance) << value; |
| } else if constexpr (is_status) { |
| instance->set_value(value); |
| } else { |
| // This branch mean to be unreachable, add an assert(false) here to |
| // prevent missing branch match. |
| // Postpone deduction of static_assert by evaluating sizeof(T) |
| static_assert(!sizeof(Bvar), "all types must be matched with if constexpr"); |
| } |
| } |
| |
| std::shared_ptr<Bvar> get(const std::string& tag) { |
| std::shared_ptr<Bvar> instance = nullptr; |
| std::lock_guard<bthread::Mutex> l(mutex_); |
| |
| auto it = bvar_map_.find(tag); |
| if (it == bvar_map_.end()) { |
| instance = std::make_shared<Bvar>(module_, name_ + "_" + tag); |
| bvar_map_[tag] = instance; |
| return instance; |
| } |
| return it->second; |
| } |
| |
| void remove(const std::string& tag) { |
| std::lock_guard<bthread::Mutex> l(mutex_); |
| bvar_map_.erase(tag); |
| } |
| |
| private: |
| bthread::Mutex mutex_; |
| std::string module_; |
| std::string name_; |
| std::map<std::string, std::shared_ptr<Bvar>> bvar_map_; |
| }; |
| |
| using BvarLatencyRecorderWithTag = BvarWithTag<bvar::LatencyRecorder>; |
| |
| template <typename T> |
| requires std::is_integral_v<T> |
| using BvarStatusWithTag = BvarWithTag<bvar::Status<T>, true>; |
| |
| /** |
| @brief: A wrapper class for multidimensional bvar metrics. |
| This template class provides a convenient interface for managing multidimensional |
| bvar metrics. It supports various bvar types including Adder, IntRecorder, |
| LatencyRecorder, Maxer, and Status. |
| @param: BvarType The type of bvar metric to use (must be one of the supported types) |
| @output: Based on the bvar multidimensional counter implementation, |
| the metrics output format would typically follow this structure: |
| {metric_name}{dimension1="value1",dimension2="value2",...} value |
| @example: Basic usage with an Adder: |
| // Create a 2-dimensional counter with dimensions "region" and "service" |
| mBvarWrapper<bvar::Adder<int>> request_counter("xxx_request_count", {"region", "service"}); |
| // Increment the counter for specific dimension values |
| request_counter.put({"east", "login"}, 1); |
| request_counter.put({"west", "search"}, 1); |
| request_counter.put({"east", "login"}, 1); // Now east/login has value 2 |
| // the output of above metrics: |
| xxx_request_count{region="east",service="login"} 2 |
| xxx_request_count{region="west",service="search"} 1 |
| @note: The dimensions provided in the constructor and the values provided to |
| put() and get() methods must match in count. Also, all supported bvar types |
| have different behaviors for how values are processed and retrieved. |
| */ |
| |
| template <typename T> |
| struct is_valid_bvar_type : std::false_type {}; |
| template <typename T> |
| struct is_valid_bvar_type<bvar::Adder<T>> : std::true_type {}; |
| template <> |
| struct is_valid_bvar_type<bvar::IntRecorder> : std::true_type {}; |
| template <typename T> |
| struct is_valid_bvar_type<bvar::Maxer<T>> : std::true_type {}; |
| template <typename T> |
| struct is_valid_bvar_type<bvar::Status<T>> : std::true_type {}; |
| template <> |
| struct is_valid_bvar_type<bvar::LatencyRecorder> : std::true_type {}; |
| template <typename T> |
| struct is_bvar_status : std::false_type {}; |
| template <typename T> |
| struct is_bvar_status<bvar::Status<T>> : std::true_type {}; |
| |
| template <typename BvarType> |
| class mBvarWrapper { |
| public: |
| mBvarWrapper(const std::string& metric_name, |
| const std::initializer_list<std::string>& dim_names) |
| : counter_(metric_name, std::list<std::string>(dim_names)) { |
| static_assert(is_valid_bvar_type<BvarType>::value, |
| "BvarType must be one of the supported bvar types (Adder, IntRecorder, " |
| "LatencyRecorder, Maxer, Status)"); |
| } |
| |
| template <typename ValType> |
| void put(const std::initializer_list<std::string>& dim_values, ValType value) { |
| BvarType* stats = counter_.get_stats(std::list<std::string>(dim_values)); |
| if (stats) { |
| if constexpr (is_bvar_status<BvarType>::value) { |
| stats->set_value(value); |
| } else { |
| *stats << value; |
| } |
| } |
| } |
| |
| auto get(const std::initializer_list<std::string>& dim_values) { |
| BvarType* stats = counter_.get_stats(std::list<std::string>(dim_values)); |
| using ReturnType = decltype(stats->get_value()); |
| if (stats) { |
| return stats->get_value(); |
| } |
| return ReturnType {}; |
| } |
| |
| private: |
| bvar::MultiDimension<BvarType> counter_; |
| }; |
| |
| using mBvarIntAdder = mBvarWrapper<bvar::Adder<int>>; |
| using mBvarInt64Adder = mBvarWrapper<bvar::Adder<int64_t>>; |
| using mBvarDoubleAdder = mBvarWrapper<bvar::Adder<double>>; |
| using mBvarIntRecorder = mBvarWrapper<bvar::IntRecorder>; |
| using mBvarLatencyRecorder = mBvarWrapper<bvar::LatencyRecorder>; |
| using mBvarIntMaxer = mBvarWrapper<bvar::Maxer<int>>; |
| using mBvarDoubleMaxer = mBvarWrapper<bvar::Maxer<double>>; |
| template <typename T> |
| using mBvarStatus = mBvarWrapper<bvar::Status<T>>; |
| |
| // meta-service's bvars |
| extern BvarLatencyRecorderWithTag g_bvar_ms_begin_txn; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_precommit_txn; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_commit_txn; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_commit_txn_eventually; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_abort_txn; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_get_txn; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_get_current_max_txn_id; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_check_txn_conflict; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_abort_txn_with_coordinator; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_begin_sub_txn; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_abort_sub_txn; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_clean_txn_label; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_get_version; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_batch_get_version; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_create_tablets; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_update_tablet; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_update_tablet_schema; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_get_tablet; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_prepare_rowset; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_commit_rowset; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_update_tmp_rowset; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_get_rowset; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_drop_index; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_prepare_index; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_commit_index; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_prepare_partition; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_commit_partition; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_drop_partition; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_prepare_restore_job; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_commit_restore_job; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_finish_restore_job; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_get_tablet_stats; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_get_obj_store_info; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_alter_obj_store_info; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_alter_storage_vault; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_create_instance; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_alter_instance; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_alter_cluster; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_get_cluster; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_create_stage; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_get_stage; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_drop_stage; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_get_iam; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_update_ak_sk; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_alter_iam; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_alter_ram_user; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_begin_copy; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_finish_copy; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_get_copy_job; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_get_copy_files; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_filter_copy_files; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_start_tablet_job; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_finish_tablet_job; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_update_delete_bitmap; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_get_delete_bitmap; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_get_delete_bitmap_update_lock; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_remove_delete_bitmap; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_remove_delete_bitmap_update_lock; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_get_cluster_status; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_set_cluster_status; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_get_instance; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_get_rl_task_commit_attach; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_reset_rl_progress; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_get_txn_id; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_check_kv; |
| extern BvarLatencyRecorderWithTag g_bvar_ms_get_schema_dict; |
| extern bvar::Adder<int64_t> g_bvar_update_delete_bitmap_fail_counter; |
| extern bvar::Adder<int64_t> g_bvar_get_delete_bitmap_fail_counter; |
| |
| // recycler's bvars |
| extern BvarStatusWithTag<int64_t> g_bvar_recycler_recycle_index_earlest_ts; |
| extern BvarStatusWithTag<int64_t> g_bvar_recycler_recycle_partition_earlest_ts; |
| extern BvarStatusWithTag<int64_t> g_bvar_recycler_recycle_rowset_earlest_ts; |
| extern BvarStatusWithTag<int64_t> g_bvar_recycler_recycle_tmp_rowset_earlest_ts; |
| extern BvarStatusWithTag<int64_t> g_bvar_recycler_recycle_expired_txn_label_earlest_ts; |
| extern BvarStatusWithTag<int64_t> g_bvar_recycler_recycle_restore_job_earlest_ts; |
| |
| // recycler's mbvars |
| extern bvar::Status<int64_t> g_bvar_recycler_task_max_concurrency; |
| extern bvar::Adder<int64_t> g_bvar_recycler_instance_recycle_task_concurrency; |
| extern bvar::Adder<int64_t> g_bvar_recycler_instance_running_counter; |
| extern mBvarStatus<int64_t> g_bvar_recycler_instance_last_round_recycle_duration; |
| extern mBvarStatus<int64_t> g_bvar_recycler_instance_next_ts; |
| extern mBvarStatus<int64_t> g_bvar_recycler_instance_recycle_start_ts; |
| extern mBvarStatus<int64_t> g_bvar_recycler_instance_recycle_end_ts; |
| extern mBvarStatus<int64_t> g_bvar_recycler_instance_recycle_last_success_ts; |
| |
| extern mBvarIntAdder g_bvar_recycler_vault_recycle_status; |
| extern mBvarIntAdder g_bvar_recycler_vault_recycle_task_concurrency; |
| extern mBvarStatus<int64_t> g_bvar_recycler_instance_last_round_recycled_num; |
| extern mBvarStatus<int64_t> g_bvar_recycler_instance_last_round_to_recycle_num; |
| extern mBvarStatus<int64_t> g_bvar_recycler_instance_last_round_recycled_bytes; |
| extern mBvarStatus<int64_t> g_bvar_recycler_instance_last_round_to_recycle_bytes; |
| extern mBvarStatus<double> g_bvar_recycler_instance_last_round_recycle_elpased_ts; |
| extern mBvarIntAdder g_bvar_recycler_instance_recycle_total_num_since_started; |
| extern mBvarIntAdder g_bvar_recycler_instance_recycle_total_bytes_since_started; |
| extern mBvarIntAdder g_bvar_recycler_instance_recycle_round; |
| extern mBvarStatus<double> g_bvar_recycler_instance_recycle_time_per_resource; |
| extern mBvarStatus<double> g_bvar_recycler_instance_recycle_bytes_per_ms; |
| |
| // txn_kv's bvars |
| extern bvar::LatencyRecorder g_bvar_txn_kv_get; |
| extern bvar::LatencyRecorder g_bvar_txn_kv_range_get; |
| extern bvar::LatencyRecorder g_bvar_txn_kv_put; |
| extern bvar::LatencyRecorder g_bvar_txn_kv_commit; |
| extern bvar::LatencyRecorder g_bvar_txn_kv_atomic_set_ver_key; |
| extern bvar::LatencyRecorder g_bvar_txn_kv_atomic_set_ver_value; |
| extern bvar::LatencyRecorder g_bvar_txn_kv_atomic_add; |
| extern bvar::LatencyRecorder g_bvar_txn_kv_remove; |
| extern bvar::LatencyRecorder g_bvar_txn_kv_range_remove; |
| extern bvar::LatencyRecorder g_bvar_txn_kv_get_read_version; |
| extern bvar::LatencyRecorder g_bvar_txn_kv_get_committed_version; |
| extern bvar::LatencyRecorder g_bvar_txn_kv_batch_get; |
| |
| extern bvar::Adder<int64_t> g_bvar_txn_kv_commit_error_counter; |
| extern bvar::Adder<int64_t> g_bvar_txn_kv_commit_conflict_counter; |
| extern bvar::Adder<int64_t> g_bvar_txn_kv_get_count_normalized; |
| |
| extern bvar::Adder<int64_t> g_bvar_delete_bitmap_lock_txn_put_conflict_counter; |
| extern bvar::Adder<int64_t> g_bvar_delete_bitmap_lock_txn_remove_conflict_by_fail_counter; |
| extern bvar::Adder<int64_t> g_bvar_delete_bitmap_lock_txn_remove_conflict_by_load_counter; |
| extern bvar::Adder<int64_t> |
| g_bvar_delete_bitmap_lock_txn_remove_conflict_by_compaction_commit_counter; |
| extern bvar::Adder<int64_t> |
| g_bvar_delete_bitmap_lock_txn_remove_conflict_by_compaction_lease_counter; |
| extern bvar::Adder<int64_t> |
| g_bvar_delete_bitmap_lock_txn_remove_conflict_by_compaction_abort_counter; |
| |
| extern const int64_t BVAR_FDB_INVALID_VALUE; |
| extern bvar::Status<int64_t> g_bvar_fdb_client_count; |
| extern bvar::Status<int64_t> g_bvar_fdb_configuration_coordinators_count; |
| extern bvar::Status<int64_t> g_bvar_fdb_configuration_usable_regions; |
| extern bvar::Status<int64_t> g_bvar_fdb_coordinators_unreachable_count; |
| extern bvar::Status<int64_t> g_bvar_fdb_fault_tolerance_count; |
| extern bvar::Status<int64_t> g_bvar_fdb_data_average_partition_size_bytes; |
| extern bvar::Status<int64_t> g_bvar_fdb_data_log_server_space_bytes; |
| extern bvar::Status<int64_t> g_bvar_fdb_data_moving_data_highest_priority; |
| extern bvar::Status<int64_t> g_bvar_fdb_data_moving_data_in_flight_bytes; |
| extern bvar::Status<int64_t> g_bvar_fdb_data_moving_data_in_queue_bytes; |
| extern bvar::Status<int64_t> g_bvar_fdb_data_moving_total_written_bytes; |
| extern bvar::Status<int64_t> g_bvar_fdb_data_partition_count; |
| extern bvar::Status<int64_t> g_bvar_fdb_data_storage_server_space_bytes; |
| extern bvar::Status<int64_t> g_bvar_fdb_data_state_min_replicas_remaining; |
| extern bvar::Status<int64_t> g_bvar_fdb_data_total_kv_size_bytes; |
| extern bvar::Status<int64_t> g_bvar_fdb_data_total_disk_used_bytes; |
| extern bvar::Status<int64_t> g_bvar_fdb_generation; |
| extern bvar::Status<int64_t> g_bvar_fdb_incompatible_connections; |
| extern bvar::Status<int64_t> g_bvar_fdb_latency_probe_transaction_start_ns; |
| extern bvar::Status<int64_t> g_bvar_fdb_latency_probe_commit_ns; |
| extern bvar::Status<int64_t> g_bvar_fdb_latency_probe_read_ns; |
| extern bvar::Status<int64_t> g_bvar_fdb_machines_count; |
| extern bvar::Status<int64_t> g_bvar_fdb_process_count; |
| extern bvar::Status<int64_t> g_bvar_fdb_qos_worst_data_lag_storage_server_ns; |
| extern bvar::Status<int64_t> g_bvar_fdb_qos_worst_durability_lag_storage_server_ns; |
| extern bvar::Status<int64_t> g_bvar_fdb_qos_worst_log_server_queue_bytes; |
| extern bvar::Status<int64_t> g_bvar_fdb_qos_worst_storage_server_queue_bytes; |
| extern bvar::Status<int64_t> g_bvar_fdb_workload_conflict_rate_hz; |
| extern bvar::Status<int64_t> g_bvar_fdb_workload_location_rate_hz; |
| extern bvar::Status<int64_t> g_bvar_fdb_workload_keys_read_hz; |
| extern bvar::Status<int64_t> g_bvar_fdb_workload_read_bytes_hz; |
| extern bvar::Status<int64_t> g_bvar_fdb_workload_read_rate_hz; |
| extern bvar::Status<int64_t> g_bvar_fdb_workload_write_rate_hz; |
| extern bvar::Status<int64_t> g_bvar_fdb_workload_written_bytes_hz; |
| extern bvar::Status<int64_t> g_bvar_fdb_workload_transactions_started_hz; |
| extern bvar::Status<int64_t> g_bvar_fdb_workload_transactions_committed_hz; |
| extern bvar::Status<int64_t> g_bvar_fdb_workload_transactions_rejected_hz; |
| extern bvar::Status<int64_t> g_bvar_fdb_client_thread_busyness_percent; |
| extern mBvarStatus<int64_t> g_bvar_fdb_process_status_int; |
| extern mBvarStatus<double> g_bvar_fdb_process_status_float; |
| |
| // checker |
| extern BvarStatusWithTag<long> g_bvar_checker_num_scanned; |
| extern BvarStatusWithTag<long> g_bvar_checker_num_scanned_with_segment; |
| extern BvarStatusWithTag<long> g_bvar_checker_num_check_failed; |
| extern BvarStatusWithTag<long> g_bvar_checker_check_cost_s; |
| extern BvarStatusWithTag<long> g_bvar_checker_enqueue_cost_s; |
| extern BvarStatusWithTag<long> g_bvar_checker_last_success_time_ms; |
| extern BvarStatusWithTag<long> g_bvar_checker_instance_volume; |
| extern BvarStatusWithTag<long> g_bvar_inverted_checker_num_scanned; |
| extern BvarStatusWithTag<long> g_bvar_inverted_checker_num_check_failed; |
| |
| extern BvarStatusWithTag<int64_t> g_bvar_inverted_checker_leaked_delete_bitmaps; |
| extern BvarStatusWithTag<int64_t> g_bvar_inverted_checker_abnormal_delete_bitmaps; |
| extern BvarStatusWithTag<int64_t> g_bvar_inverted_checker_delete_bitmaps_scanned; |
| extern BvarStatusWithTag<int64_t> g_bvar_max_rowsets_with_useless_delete_bitmap_version; |
| |
| // rpc kv |
| extern mBvarInt64Adder g_bvar_rpc_kv_get_rowset_get_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_get_version_get_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_get_schema_dict_get_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_create_tablets_get_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_create_tablets_put_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_update_tablet_get_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_update_tablet_put_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_update_tablet_schema_get_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_update_tablet_schema_put_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_get_tablet_get_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_prepare_rowset_get_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_prepare_rowset_put_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_commit_rowset_get_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_commit_rowset_put_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_commit_rowset_del_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_update_tmp_rowset_get_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_update_tmp_rowset_put_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_get_tablet_stats_get_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_update_delete_bitmap_get_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_update_delete_bitmap_put_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_update_delete_bitmap_del_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_get_delete_bitmap_get_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_get_delete_bitmap_update_lock_get_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_get_delete_bitmap_update_lock_put_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_get_delete_bitmap_update_lock_del_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_remove_delete_bitmap_update_lock_get_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_remove_delete_bitmap_update_lock_put_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_remove_delete_bitmap_update_lock_del_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_remove_delete_bitmap_del_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_start_tablet_job_get_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_start_tablet_job_put_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_finish_tablet_job_get_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_finish_tablet_job_put_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_finish_tablet_job_del_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_prepare_index_get_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_prepare_index_put_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_commit_index_get_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_commit_index_put_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_commit_index_del_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_drop_index_get_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_drop_index_put_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_prepare_partition_get_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_prepare_partition_put_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_commit_partition_get_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_commit_partition_put_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_commit_partition_del_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_drop_partition_get_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_drop_partition_put_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_check_kv_get_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_get_obj_store_info_get_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_alter_storage_vault_get_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_alter_storage_vault_put_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_alter_storage_vault_del_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_alter_obj_store_info_get_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_alter_obj_store_info_put_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_update_ak_sk_get_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_update_ak_sk_put_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_create_instance_get_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_create_instance_put_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_get_instance_get_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_alter_cluster_get_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_get_cluster_get_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_get_cluster_put_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_create_stage_get_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_create_stage_put_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_get_stage_get_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_get_iam_get_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_alter_iam_get_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_alter_iam_put_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_alter_ram_user_get_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_alter_ram_user_put_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_begin_copy_get_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_begin_copy_put_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_finish_copy_get_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_finish_copy_put_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_finish_copy_del_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_get_copy_job_get_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_get_copy_files_get_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_filter_copy_files_get_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_get_cluster_status_get_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_begin_txn_get_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_begin_txn_put_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_precommit_txn_get_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_precommit_txn_put_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_get_rl_task_commit_attach_get_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_reset_rl_progress_get_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_reset_rl_progress_put_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_reset_rl_progress_del_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_commit_txn_get_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_commit_txn_put_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_commit_txn_del_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_abort_txn_get_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_abort_txn_put_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_abort_txn_del_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_get_txn_get_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_get_current_max_txn_id_get_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_begin_sub_txn_get_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_begin_sub_txn_put_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_begin_sub_txn_del_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_abort_sub_txn_get_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_abort_sub_txn_put_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_abort_txn_with_coordinator_get_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_check_txn_conflict_get_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_clean_txn_label_get_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_clean_txn_label_put_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_clean_txn_label_del_counter; |
| extern mBvarInt64Adder g_bvar_rpc_kv_get_txn_id_get_counter; |
| |
| extern mBvarInt64Adder g_bvar_rpc_kv_get_rowset_get_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_get_version_get_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_get_schema_dict_get_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_create_tablets_get_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_create_tablets_put_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_update_tablet_get_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_update_tablet_put_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_update_tablet_schema_get_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_update_tablet_schema_put_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_get_tablet_get_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_prepare_rowset_get_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_prepare_rowset_put_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_commit_rowset_get_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_commit_rowset_put_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_commit_rowset_del_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_update_tmp_rowset_get_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_update_tmp_rowset_put_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_get_tablet_stats_get_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_update_delete_bitmap_get_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_update_delete_bitmap_put_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_update_delete_bitmap_del_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_get_delete_bitmap_get_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_get_delete_bitmap_update_lock_get_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_get_delete_bitmap_update_lock_put_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_get_delete_bitmap_update_lock_del_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_remove_delete_bitmap_update_lock_get_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_remove_delete_bitmap_update_lock_put_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_remove_delete_bitmap_update_lock_del_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_remove_delete_bitmap_del_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_start_tablet_job_get_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_start_tablet_job_put_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_finish_tablet_job_get_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_finish_tablet_job_put_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_finish_tablet_job_del_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_prepare_index_get_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_prepare_index_put_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_commit_index_get_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_commit_index_put_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_commit_index_del_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_drop_index_get_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_drop_index_put_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_prepare_partition_get_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_prepare_partition_put_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_commit_partition_get_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_commit_partition_put_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_commit_partition_del_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_drop_partition_get_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_drop_partition_put_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_check_kv_get_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_get_obj_store_info_get_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_alter_storage_vault_get_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_alter_storage_vault_put_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_alter_storage_vault_del_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_alter_obj_store_info_get_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_alter_obj_store_info_put_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_update_ak_sk_get_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_update_ak_sk_put_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_create_instance_get_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_create_instance_put_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_get_instance_get_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_alter_cluster_get_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_get_cluster_get_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_get_cluster_put_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_create_stage_get_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_create_stage_put_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_get_stage_get_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_get_iam_get_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_alter_iam_get_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_alter_iam_put_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_alter_ram_user_get_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_alter_ram_user_put_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_begin_copy_get_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_begin_copy_put_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_finish_copy_get_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_finish_copy_put_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_finish_copy_del_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_get_copy_job_get_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_get_copy_files_get_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_filter_copy_files_get_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_get_cluster_status_get_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_begin_txn_get_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_begin_txn_put_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_precommit_txn_get_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_precommit_txn_put_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_get_rl_task_commit_attach_get_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_reset_rl_progress_get_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_reset_rl_progress_put_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_reset_rl_progress_del_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_commit_txn_get_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_commit_txn_put_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_commit_txn_del_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_abort_txn_get_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_abort_txn_put_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_abort_txn_del_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_get_txn_get_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_get_current_max_txn_id_get_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_begin_sub_txn_get_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_begin_sub_txn_put_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_begin_sub_txn_del_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_abort_sub_txn_get_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_abort_sub_txn_put_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_abort_txn_with_coordinator_get_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_check_txn_conflict_get_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_clean_txn_label_get_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_clean_txn_label_put_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_clean_txn_label_del_bytes; |
| extern mBvarInt64Adder g_bvar_rpc_kv_get_txn_id_get_bytes; |
| |
| // meta ranges |
| extern mBvarStatus<int64_t> g_bvar_fdb_kv_ranges_count; |
