Struct ParticipantHandler 

pub struct ParticipantHandler { /* private fields */ }

Handler for transaction participants with storage integration.

Implementations

impl ParticipantHandler

pub fn new(node_id: NodeId) -> Self

Create a new participant handler.

pub fn set_validation_callback(&self, callback: ValidationCallback)

Set the validation callback for prepare phase.

pub fn set_commit_callback(&self, callback: CommitCallback)

Set the commit callback for commit phase.

pub fn set_abort_callback(&self, callback: AbortCallback)

Set the abort callback for abort/rollback phase.

pub fn handle_prepare( &self, txn_id: &TransactionId, operations: Vec<TransactionOperation>, ) -> TwoPhaseMessage

Handle prepare request with full storage integration.

pub fn handle_prepare_with_validation<F>( &self, txn_id: &TransactionId, operations: Vec<TransactionOperation>, validator: F, ) -> TwoPhaseMessage

where F: FnOnce(&[TransactionOperation]) -> bool,

Handle prepare with validation function.

pub fn handle_commit(&self, txn_id: &TransactionId) -> TwoPhaseMessage

Handle commit request with storage integration.

pub fn handle_abort(&self, txn_id: &TransactionId) -> TwoPhaseMessage

Handle abort request with proper cleanup.

pub fn get_locked_keys(&self, txn_id: &TransactionId) -> Vec<String>

Get currently locked keys for a transaction.

pub fn is_key_locked(&self, key: &str) -> Option<TransactionId>

Check if a key is locked by any transaction.

pub fn is_prepared(&self, txn_id: &TransactionId) -> bool

Check if a transaction is prepared.

pub fn is_committed(&self, txn_id: &TransactionId) -> bool

Check if a transaction is committed.

pub fn pending_count(&self) -> usize

Get pending prepare count.