jedarden/miroir
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

style: apply rustfmt to admin_endpoints.rs metrics callback

Browse source
This commit is contained in:
jedarden 2026-05-26 11:04:09 -04:00
parent 8e8de0de92
commit 83c3ecbcac
1 changed files with 39 additions and 23 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

62
crates/miroir-proxy/src/routes/admin_endpoints.rs
View file

@ -3391,32 +3391,48 @@ where
// Create metrics callback for resharding (plan §13.1)
let index_label = index_uid_clone.clone();
let metrics_clone = metrics.clone();
let metrics_callback = std::sync::Arc::new(move |phase: miroir_core::reshard::ReshardPhase, value: u64| {
use miroir_core::reshard::ReshardPhase;
let phase_num = match phase {
ReshardPhase::Idle => 0,
ReshardPhase::ShadowCreated => 1,
ReshardPhase::DualWriteActive => 2,
ReshardPhase::BackfillInProgress => 3,
ReshardPhase::Verifying => 4,
ReshardPhase::Swapped => 5,
ReshardPhase::CleaningUp => 6,
ReshardPhase::Complete => 7,
ReshardPhase::Failed => 8,
};
let metrics_callback = std::sync::Arc::new(
move |phase: miroir_core::reshard::ReshardPhase, value: u64| {
use miroir_core::reshard::ReshardPhase;
let phase_num = match phase {
ReshardPhase::Idle => 0,
ReshardPhase::ShadowCreated => 1,
ReshardPhase::DualWriteActive => 2,
ReshardPhase::BackfillInProgress => 3,
ReshardPhase::Verifying => 4,
ReshardPhase::Swapped => 5,
ReshardPhase::CleaningUp => 6,
ReshardPhase::Complete => 7,
ReshardPhase::Failed => 8,
};
// Update reshard_in_progress gauge
let in_progress = !matches!(phase, ReshardPhase::Idle | ReshardPhase::Complete | ReshardPhase::Failed);
metrics_clone.set_reshard_in_progress(in_progress);
// Update reshard_in_progress gauge
let in_progress = !matches!(
phase,
ReshardPhase::Idle | ReshardPhase::Complete | ReshardPhase::Failed
);
metrics_clone.set_reshard_in_progress(in_progress);
// Update reshard_phase gauge
metrics_clone.set_reshard_phase(&index_label, phase_num);
// Update reshard_phase gauge
metrics_clone.set_reshard_phase(&index_label, phase_num);
// Update documents_backfilled counter during backfill and later phases
if matches!(phase, ReshardPhase::BackfillInProgress | ReshardPhase::Verifying | ReshardPhase::Swapped | ReshardPhase::CleaningUp | ReshardPhase::Complete) {
metrics_clone.inc_reshard_documents_backfilled(&index_label, &index_label, value);
}
});
// Update documents_backfilled counter during backfill and later phases
if matches!(
phase,
ReshardPhase::BackfillInProgress
| ReshardPhase::Verifying
| ReshardPhase::Swapped
| ReshardPhase::CleaningUp
| ReshardPhase::Complete
) {
metrics_clone.inc_reshard_documents_backfilled(
&index_label,
&index_label,
value,
);
}
},
);
let config = miroir_core::reshard::ReshardOrchestratorConfig {
index_uid: index_uid_clone.clone(),