Struct TransactionState 

pub struct TransactionState { /* private fields */ }

State machine for transaction lifecycle

Implementations

impl TransactionState

pub fn new() -> Self

Create a new transaction state

pub fn is_idle(&self) -> bool

Check if the state is idle (no active transaction)

pub fn is_active(&self) -> bool

Check if there’s an active transaction

pub fn state(&self) -> SinkState

Get the current state

pub fn current_transaction(&self) -> Option<&TransactionId>

Get the current transaction ID

pub fn write_count(&self) -> u64

Get the write count for the current transaction

pub fn record_count(&self) -> u64

Get the record count for the current transaction

pub fn begin(&mut self, tx_id: TransactionId) -> Result<(), SinkError>

Begin a new transaction

Errors

Returns an error if a transaction is already active.

pub fn begin_new(&mut self) -> Result<TransactionId, SinkError>

Generate a new transaction ID and begin

Errors

Returns an error if a transaction is already active.

pub fn record_write(&mut self, record_count: u64) -> Result<(), SinkError>

Record a write operation

Errors

Returns an error if there’s no active transaction.

pub fn commit(&mut self, tx_id: &TransactionId) -> Result<(), SinkError>

Commit the current transaction

Errors

Returns an error if the transaction ID doesn’t match or if there’s no active transaction.

pub fn rollback(&mut self, tx_id: &TransactionId) -> Result<(), SinkError>

Rollback the current transaction

Errors

Returns an error if the transaction ID doesn’t match.

pub fn force_rollback(&mut self)

Force rollback without validation (for recovery)

pub fn mark_error(&mut self)

Mark the state as error

Trait Implementations

impl Debug for TransactionState

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

Formats the value using the given formatter.

impl Default for TransactionState

fn default() -> Self

Returns the “default value” for a type.