omni_orchestrator/initialization/
start_leader_election.rs

1use colored::Colorize;
2use crate::LeaderElection;
3use std::sync::Arc;
4use crate::RwLock;
5use crate::SharedState;
6
7pub fn start_leader_election(shared_state: Arc<RwLock<SharedState>>, node_id: Arc<str>) {
8    // Initialize and start leader election
9    log::info!("{}", "Initializing leader election process".green());
10    let _leader_election = LeaderElection::new(node_id, shared_state.clone());
11    log::info!("{}", "✓ Leader election initialized".green());
12}