rust/greptimedb
1
0
Fork 0
mirror of https://github.com/GreptimeTeam/greptimedb.git synced 2026-01-06 13:22:57 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore: remove region id to reduce time series (#6506)

Browse Source
This commit is contained in:
localhost
2025-07-10 20:33:06 +08:00
committed by GitHub
parent ffe0da0405
commit dd7da3d2c2
2 changed files with 4 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/datanode/src/metrics.rs
View File

@@ -27,14 +27,14 @@ lazy_static! {
pub static ref HANDLE_REGION_REQUEST_ELAPSED: HistogramVec = register_histogram_vec!( pub static ref HANDLE_REGION_REQUEST_ELAPSED: HistogramVec = register_histogram_vec!(
"greptime_datanode_handle_region_request_elapsed", "greptime_datanode_handle_region_request_elapsed",
"datanode handle region request elapsed", "datanode handle region request elapsed",
&[REGION_ID, REGION_REQUEST_TYPE] &[REGION_REQUEST_TYPE]
) )
.unwrap(); .unwrap();
/// The number of rows in region request received by region server, labeled with request type. /// The number of rows in region request received by region server, labeled with request type.
pub static ref REGION_CHANGED_ROW_COUNT: IntCounterVec = register_int_counter_vec!( pub static ref REGION_CHANGED_ROW_COUNT: IntCounterVec = register_int_counter_vec!(
"greptime_datanode_region_changed_row_count", "greptime_datanode_region_changed_row_count",
"datanode region changed row count", "datanode region changed row count",
&[REGION_ID, REGION_REQUEST_TYPE] &[REGION_REQUEST_TYPE]
) )
.unwrap(); .unwrap();
/// The elapsed time since the last received heartbeat. /// The elapsed time since the last received heartbeat.

5
src/datanode/src/region_server.rs
View File

@@ -968,9 +968,8 @@ impl RegionServerInner {
request: RegionRequest, request: RegionRequest,
) -> Result<RegionResponse> { ) -> Result<RegionResponse> {
let request_type = request.request_type(); let request_type = request.request_type();
let region_id_str = region_id.to_string();
let _timer = crate::metrics::HANDLE_REGION_REQUEST_ELAPSED let _timer = crate::metrics::HANDLE_REGION_REQUEST_ELAPSED
.with_label_values(&[&region_id_str, request_type]) .with_label_values(&[request_type])
.start_timer(); .start_timer();
let region_change = match &request { let region_change = match &request {
@@ -1010,7 +1009,7 @@ impl RegionServerInner {
// Update metrics // Update metrics
if matches!(region_change, RegionChange::Ingest) { if matches!(region_change, RegionChange::Ingest) {
crate::metrics::REGION_CHANGED_ROW_COUNT crate::metrics::REGION_CHANGED_ROW_COUNT
.with_label_values(&[&region_id_str, request_type]) .with_label_values(&[request_type])
.inc_by(result.affected_rows as u64); .inc_by(result.affected_rows as u64);
} }
// Sets corresponding region status to ready. // Sets corresponding region status to ready.