Struct persy::Recover

pub struct Recover { /* private fields */ }

Intermediate recover status to select witch transactions to commit or rollback and list witch transactions are in a intermediate state

Example

let mut recover = Persy::recover("./target/recover_example.persy", Config::new())?;
for (tx_id,status) in recover.list_transactions() {
    // Check the transaction if can be committed using the tx_id
    if true {
        // if so commit the tx
        recover.commit(tx_id);
    } else {
        // otherwise roll back it
        recover.rollback(tx_id);
    }
    // finalize all the transaction marked to finalize and get a persy instance.
}
let persy = recover.finalize()?;

Implementations

impl Recover

pub fn list_transactions(&self) -> Vec<(TransactionId, RecoverStatus)>

List all the transactions found in the log with the current status

pub fn commit(&mut self, tx_id: TransactionId)

Mark to commit a transaction in the log with state prepared commit

pub fn rollback(&mut self, tx_id: TransactionId)

Mark to rollback a transaction that is not yet committed

pub fn status(&self, tx_id: TransactionId) -> Option<RecoverStatus>

Read the status of a transaction in the log

pub fn finalize(self) -> Result<Persy, PE<GenericError>>

Recover all the prepared committed transactions that are not marked to rollback

Examples found in repository

src/open_options.rs (line 157)

    pub fn open<P>(&mut self, path: P) -> Result<Persy, PE<OpenError>>
    where
        P: AsRef<Path>,
    {
        let recover = self.recover(path)?;
        recover.finalize().map_err(|e| PE::PE(OpenError::from(e.error())))
    }