Struct RabiaEngine 

pub struct RabiaEngine<SM, NT, PL>
where
    SM: StateMachine + 'static,
    NT: NetworkTransport + 'static,
    PL: PersistenceLayer + 'static,
{ /* private fields */ }

Implementations

impl<SM, NT, PL> RabiaEngine<SM, NT, PL>

where SM: StateMachine + 'static, NT: NetworkTransport + 'static, PL: PersistenceLayer + 'static,

pub fn new( node_id: NodeId, config: RabiaConfig, cluster_config: ClusterConfig, state_machine: SM, network: NT, persistence: PL, command_rx: EngineCommandReceiver, ) -> Self

impl<SM, PL> RabiaEngine<SM, TcpNetwork, PL>

where SM: StateMachine + 'static, PL: PersistenceLayer + 'static,

pub async fn new_with_tcp( node_id: NodeId, config: RabiaConfig, cluster_config: ClusterConfig, state_machine: SM, persistence: PL, command_rx: EngineCommandReceiver, ) -> Result<Self>

Create a new RabiaEngine with integrated TCP networking

impl<SM, NT, PL> RabiaEngine<SM, NT, PL>

where SM: StateMachine + 'static, NT: NetworkTransport + 'static, PL: PersistenceLayer + 'static,

pub fn get_leader(&self) -> Option<NodeId>

Get the current leader node ID

pub fn is_leader(&self) -> bool

Check if this node is the current leader

pub fn get_leadership_info(&self) -> LeadershipInfo

Get current leadership information

pub fn update_cluster_membership( &mut self, nodes: HashSet<NodeId>, ) -> Option<NodeId>

Update cluster membership and determine new leader

pub async fn run(self) -> Result<()>

Trait Implementations

impl<SM, NT, PL> NetworkEventHandler for RabiaEngine<SM, NT, PL>

where SM: StateMachine + 'static, NT: NetworkTransport + 'static, PL: PersistenceLayer + 'static,

fn on_node_connected<'life0, 'async_trait>( &'life0 self, node_id: NodeId, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn on_node_disconnected<'life0, 'async_trait>( &'life0 self, node_id: NodeId, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn on_network_partition<'life0, 'async_trait>( &'life0 self, active_nodes: HashSet<NodeId>, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn on_quorum_lost<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn on_quorum_restored<'life0, 'async_trait>( &'life0 self, active_nodes: HashSet<NodeId>, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,