Struct StateMachineExecutor 

pub struct StateMachineExecutor { /* private fields */ }

State machine executor with event batching.

Processes multiple events efficiently with minimal overhead.

Implementations

impl StateMachineExecutor

pub fn new(batch_size: usize) -> Self

Create new executor.

pub fn queue(&mut self, conn_id: u64, event: ConnectionEvent)

Queue an event for processing.

pub fn process( &mut self, pool: &mut ConnectionPool, ) -> Vec<(u64, TransitionAction)>

Process all queued events against a connection pool.

pub fn process_with<F>(&mut self, pool: &mut ConnectionPool, callback: F)

where F: FnMut(u64, TransitionAction),

Process events with a callback for each action.

pub fn has_pending(&self) -> bool

Check if executor has pending events.

pub fn pending_count(&self) -> usize

Get pending event count.

pub fn clear(&mut self)

Clear pending events.

Trait Implementations

impl Default for StateMachineExecutor

fn default() -> Self

Returns the “default value” for a type.