rust/greptimedb
1
0
Fork 0
mirror of https://github.com/GreptimeTeam/greptimedb.git synced 2026-05-15 12:30:38 +00:00
Code Issues Packages Projects Releases Wiki Activity

refactor: GcStats

Browse Source 
Signed-off-by: discord9 <discord9@163.com>
This commit is contained in:
discord9
2026-02-04 16:21:02 +08:00
parent e07a26db64
commit 60e5b8bdc6
2 changed files with 23 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
src/meta-client/src/client/procedure.rs
View File

@@ -300,11 +300,12 @@ impl Inner {
)
.await?;
let stats = resp.stats.unwrap_or_default();
Ok(MetaGcResponse {
processed_regions: resp.processed_regions,
need_retry_regions: resp.need_retry_regions,
deleted_files: resp.deleted_files,
deleted_indexes: resp.deleted_indexes,
processed_regions: stats.processed_regions,
need_retry_regions: stats.need_retry_regions,
deleted_files: stats.deleted_files,
deleted_indexes: stats.deleted_indexes,
})
}
@@ -335,11 +336,12 @@ impl Inner {
)
.await?;
let stats = resp.stats.unwrap_or_default();
Ok(MetaGcResponse {
processed_regions: resp.processed_regions,
need_retry_regions: resp.need_retry_regions,
deleted_files: resp.deleted_files,
deleted_indexes: resp.deleted_indexes,
processed_regions: stats.processed_regions,
need_retry_regions: stats.need_retry_regions,
deleted_files: stats.deleted_files,
deleted_indexes: stats.deleted_indexes,
})
}

22
src/meta-srv/src/service/procedure.rs
View File

@@ -17,7 +17,7 @@ use std::time::Duration;
use api::v1::meta::reconcile_request::Target;
use api::v1::meta::{
DdlTaskRequest as PbDdlTaskRequest, DdlTaskResponse as PbDdlTaskResponse, GcRegionsRequest,
GcRegionsResponse, GcTableRequest, GcTableResponse, MigrateRegionRequest,
GcRegionsResponse, GcStats, GcTableRequest, GcTableResponse, MigrateRegionRequest,
MigrateRegionResponse, ProcedureDetailRequest, ProcedureDetailResponse, ProcedureStateResponse,
QueryProcedureRequest, ReconcileCatalog, ReconcileDatabase, ReconcileRequest,
ReconcileResponse, ReconcileTable, ResolveStrategy, procedure_service_server,
@@ -422,20 +422,24 @@ fn gc_report_to_response(
fn gc_response_to_regions_pb(resp: GcResponse) -> GcRegionsResponse {
GcRegionsResponse {
processed_regions: resp.processed_regions,
need_retry_regions: resp.need_retry_regions,
deleted_files: resp.deleted_files,
deleted_indexes: resp.deleted_indexes,
stats: Some(GcStats {
processed_regions: resp.processed_regions,
need_retry_regions: resp.need_retry_regions,
deleted_files: resp.deleted_files,
deleted_indexes: resp.deleted_indexes,
}),
..Default::default()
}
}
fn gc_response_to_table_pb(resp: GcResponse) -> GcTableResponse {
GcTableResponse {
processed_regions: resp.processed_regions,
need_retry_regions: resp.need_retry_regions,
deleted_files: resp.deleted_files,
deleted_indexes: resp.deleted_indexes,
stats: Some(GcStats {
processed_regions: resp.processed_regions,
need_retry_regions: resp.need_retry_regions,
deleted_files: resp.deleted_files,
deleted_indexes: resp.deleted_indexes,
}),
..Default::default()
}
}