Struct TransactionalProcessor 

pub struct TransactionalProcessor { /* private fields */ }

Transactional processing manager

Implementations

impl TransactionalProcessor

pub fn new(config: TransactionalConfig) -> Self

Create a new transactional processor

pub async fn begin_transaction( &self, isolation_level: Option<IsolationLevel>, ) -> Result<String>

Begin a new transaction

pub async fn add_events( &self, transaction_id: &str, events: Vec<StreamEvent>, ) -> Result<()>

Add events to a transaction

pub async fn prepare_transaction(&self, transaction_id: &str) -> Result<bool>

Prepare transaction (first phase of two-phase commit)

pub async fn commit_transaction(&self, transaction_id: &str) -> Result<()>

Commit transaction (second phase of two-phase commit)

pub async fn abort_transaction(&self, transaction_id: &str) -> Result<()>

Abort transaction

pub fn is_event_processed(&self, event: &StreamEvent) -> bool

Check if an event has been processed (idempotency check)

pub fn mark_event_processed(&self, event: &StreamEvent)

Mark an event as processed

pub async fn create_checkpoint(&self) -> Result<String>

Create a checkpoint

pub fn get_transaction_status( &self, transaction_id: &str, ) -> Option<TransactionState>

Get transaction status

pub fn get_stats(&self) -> TransactionalStats

Get statistics

pub async fn recover_from_checkpoint(&self, checkpoint_id: &str) -> Result<()>

Recover from checkpoint

pub async fn shutdown(&mut self) -> Result<()>

Shutdown the transactional processor

Trait Implementations

impl Drop for TransactionalProcessor

fn drop(&mut self)

Executes the destructor for this type.