Struct ProtocolStateMachine

pub struct ProtocolStateMachine { /* private fields */ }

Protocol state manager

Implementations

impl ProtocolStateMachine

pub fn new(protocol_version: ProtocolVersion) -> Self

Create a new protocol state machine

pub fn with_config( protocol_version: ProtocolVersion, config: StateMachineConfig, ) -> Self

Create with custom configuration

pub fn current_state(&self) -> &ProtocolState

Get current state

pub fn active_sessions(&self) -> usize

Get active sessions count

pub fn protocol_version(&self) -> &ProtocolVersion

Get protocol version

pub fn uptime(&self) -> Duration

Get state machine uptime

pub fn transition_to( &mut self, new_state: ProtocolState, reason: String, ) -> Result<(), StateError>

Transition to a new state

pub fn create_session( &mut self, peer_id: Vec<u8>, protocol_version: ProtocolVersion, capabilities: Vec<String>, ) -> Result<Uuid, StateError>

Create a new session

pub fn update_session_state( &mut self, session_id: Uuid, new_state: ProtocolState, ) -> Result<(), StateError>

Update session state

pub fn get_session(&self, session_id: &Uuid) -> Option<&SessionInfo>

Get session information

pub fn remove_session(&mut self, session_id: &Uuid) -> Option<SessionInfo>

Remove a session

pub fn process_message( &mut self, message: &Message, session_id: Option<Uuid>, ) -> Result<(), StateError>

Process a protocol message and update state accordingly

pub fn get_state_history(&self) -> &[StateTransition]

Get state transition history

pub fn get_sessions(&self) -> &HashMap<Uuid, SessionInfo>

Get all active sessions

pub fn is_healthy(&self) -> bool

Check if the state machine is in a healthy state

pub fn get_metrics(&self) -> StateMachineMetrics

Get state machine metrics

Trait Implementations

impl Debug for ProtocolStateMachine

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl StateManager for ProtocolStateMachine

fn init() -> Result<ProtocolStateMachine, StateError>

Initialize protocol state.

fn transition(&mut self, new_state: ProtocolState) -> Result<(), StateError>

Transition to a new state.

fn get_state(&self) -> &ProtocolState

Get current state.

fn validate_transition(&self, new_state: &ProtocolState) -> bool

Validate state transition.