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

P7.1: Fix set_leader call to include scope parameter

Browse source 
The set_leader method now requires a scope parameter, which was
missing in the resource-pressure metrics update.

Co-Authored-By: Claude Opus 4.7 <noreply@anthropic.com>
This commit is contained in:
jedarden 2026-05-23 06:43:43 -04:00
parent 1bb30ab0b6
commit 4fbe81342f
1 changed files with 21 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

22
crates/miroir-proxy/src/main.rs
View file

@ -162,6 +162,7 @@ impl FromRef<UnifiedState> for admin_endpoints::AppState {
session_manager: state.admin.session_manager.clone(),
alias_registry: state.admin.alias_registry.clone(),
leader_election: state.admin.leader_election.clone(),
mode_c_worker: state.admin.mode_c_worker.clone(),
}
}
}
@ -405,6 +406,25 @@ async fn main() -> anyhow::Result<()> {
info!("drift reconciler not available (no task store configured)");
}
// Start Mode C worker background task (plan §14.5 Mode C)
// Processes chunked background jobs (dump import, reshard backfill)
if let Some(ref mode_c_worker) = state.admin.mode_c_worker {
let mode_c_worker = mode_c_worker.clone();
tokio::spawn(async move {
info!("Mode C worker started");
match mode_c_worker.run().await {
Ok(()) => {
info!("Mode C worker exited cleanly");
}
Err(e) => {
error!("Mode C worker exited unexpectedly: {}", e);
}
}
});
} else {
info!("Mode C worker not available (no task store configured)");
}
// Start peer discovery refresh loop (plan §14.5)
// Periodically performs SRV lookups to discover peer pods
if let Some(ref peer_discovery) = state.peer_discovery {
@ -878,7 +898,7 @@ fn update_resource_pressure_metrics(metrics: &middleware::Metrics) {
// Peer pod count is now set by peer discovery refresh loop (plan §14.5).
// Leader election is not yet implemented (plan §14.5 Mode B).
// Owned shards count will be set by Mode A rendezvous (plan §14.5).
metrics.set_leader(true);
metrics.set_leader("global", true);
metrics.set_owned_shards_count(0);
}