mirror of
https://github.com/scylladb/scylladb.git
synced 2026-04-28 12:17:02 +00:00
d6afd42342
This patch allows registering a stats object per table. The per-table stats object needs its metrics registry to be part of the table's lifecycle, but there could be a scenario in which a table is already deleted while some Alternator operations are still in progress. To handle this, the patch separates the registry from the metrics holder. It is safe to modify a parameter that is not registered. Metrics registration is performed via functions instead of the constructor. The registration accepts a keyspace and table name as parameters. The per-table metrics use an alternator_table prefix to distinguish them from their per-shard equivalents. The metrics are aggregated and reported once per node. Metrics that do not make sense to report per table (such as create and delete) are not registered. All metrics are marked with skip_when_empty. Signed-off-by: Amnon Heiman <amnon@scylladb.com>
114 lines
4.0 KiB
C++
114 lines
4.0 KiB
C++
/*
|
|
* Copyright 2019-present ScyllaDB
|
|
*/
|
|
|
|
/*
|
|
* SPDX-License-Identifier: LicenseRef-ScyllaDB-Source-Available-1.0
|
|
*/
|
|
|
|
#pragma once
|
|
|
|
#include <cstdint>
|
|
|
|
#include <seastar/core/metrics_registration.hh>
|
|
#include "utils/histogram.hh"
|
|
#include "utils/estimated_histogram.hh"
|
|
#include "cql3/stats.hh"
|
|
|
|
namespace alternator {
|
|
|
|
// Object holding per-shard statistics related to Alternator.
|
|
// While this object is alive, these metrics are also registered to be
|
|
// visible by the metrics REST API, with the "alternator" prefix.
|
|
class stats {
|
|
public:
|
|
// Count of DynamoDB API operations by types
|
|
struct {
|
|
uint64_t batch_get_item = 0;
|
|
uint64_t batch_write_item = 0;
|
|
uint64_t batch_get_item_batch_total = 0;
|
|
uint64_t batch_write_item_batch_total = 0;
|
|
uint64_t create_backup = 0;
|
|
uint64_t create_global_table = 0;
|
|
uint64_t create_table = 0;
|
|
uint64_t delete_backup = 0;
|
|
uint64_t delete_item = 0;
|
|
uint64_t delete_table = 0;
|
|
uint64_t describe_backup = 0;
|
|
uint64_t describe_continuous_backups = 0;
|
|
uint64_t describe_endpoints = 0;
|
|
uint64_t describe_global_table = 0;
|
|
uint64_t describe_global_table_settings = 0;
|
|
uint64_t describe_limits = 0;
|
|
uint64_t describe_table = 0;
|
|
uint64_t describe_time_to_live = 0;
|
|
uint64_t get_item = 0;
|
|
uint64_t list_backups = 0;
|
|
uint64_t list_global_tables = 0;
|
|
uint64_t list_tables = 0;
|
|
uint64_t list_tags_of_resource = 0;
|
|
uint64_t put_item = 0;
|
|
uint64_t query = 0;
|
|
uint64_t restore_table_from_backup = 0;
|
|
uint64_t restore_table_to_point_in_time = 0;
|
|
uint64_t scan = 0;
|
|
uint64_t tag_resource = 0;
|
|
uint64_t transact_get_items = 0;
|
|
uint64_t transact_write_items = 0;
|
|
uint64_t untag_resource = 0;
|
|
uint64_t update_continuous_backups = 0;
|
|
uint64_t update_global_table = 0;
|
|
uint64_t update_global_table_settings = 0;
|
|
uint64_t update_item = 0;
|
|
uint64_t update_table = 0;
|
|
uint64_t update_time_to_live = 0;
|
|
uint64_t list_streams = 0;
|
|
uint64_t describe_stream = 0;
|
|
uint64_t get_shard_iterator = 0;
|
|
uint64_t get_records = 0;
|
|
|
|
|
|
utils::timed_rate_moving_average_summary_and_histogram put_item_latency;
|
|
utils::timed_rate_moving_average_summary_and_histogram get_item_latency;
|
|
utils::timed_rate_moving_average_summary_and_histogram delete_item_latency;
|
|
utils::timed_rate_moving_average_summary_and_histogram update_item_latency;
|
|
utils::timed_rate_moving_average_summary_and_histogram batch_write_item_latency;
|
|
utils::timed_rate_moving_average_summary_and_histogram batch_get_item_latency;
|
|
utils::timed_rate_moving_average_summary_and_histogram get_records_latency;
|
|
|
|
utils::estimated_histogram batch_get_item_histogram{22}; // a histogram that covers the range 1 - 100
|
|
utils::estimated_histogram batch_write_item_histogram{22}; // a histogram that covers the range 1 - 100
|
|
} api_operations;
|
|
// Miscellaneous event counters
|
|
uint64_t total_operations = 0;
|
|
uint64_t unsupported_operations = 0;
|
|
uint64_t reads_before_write = 0;
|
|
uint64_t write_using_lwt = 0;
|
|
uint64_t shard_bounce_for_lwt = 0;
|
|
uint64_t requests_blocked_memory = 0;
|
|
uint64_t requests_shed = 0;
|
|
uint64_t rcu_half_units_total = 0;
|
|
// wcu can results from put, update, delete and index
|
|
// Index related will be done on top of the operation it comes with
|
|
enum wcu_types {
|
|
PUT_ITEM,
|
|
UPDATE_ITEM,
|
|
DELETE_ITEM,
|
|
INDEX,
|
|
NUM_TYPES
|
|
};
|
|
|
|
uint64_t wcu_total[NUM_TYPES] = {0};
|
|
// CQL-derived stats
|
|
cql3::cql_stats cql_stats;
|
|
};
|
|
|
|
struct table_stats {
|
|
table_stats(const sstring& ks, const sstring& table);
|
|
seastar::metrics::metric_groups _metrics;
|
|
lw_shared_ptr<stats> _stats;
|
|
};
|
|
void register_metrics(seastar::metrics::metric_groups& metrics, const stats& stats);
|
|
|
|
}
|