ROADMAP v0.3.0 - WAL entry for ROLLBACK durability (write rollback marker to WAL)
(&self, transaction_id: TransactionId)
| 536 | /// Mark a transaction as rolled back |
| 537 | #[allow(dead_code)] // ROADMAP v0.3.0 - WAL entry for ROLLBACK durability (write rollback marker to WAL) |
| 538 | pub fn mark_rolled_back(&self, transaction_id: TransactionId) -> Result<(), WALError> { |
| 539 | let seq = self.next_global_sequence(); |
| 540 | let entry = WALEntry::new( |
| 541 | WALEntryType::Rollback, |
| 542 | transaction_id, |
| 543 | seq, |
| 544 | 0, // Rollback doesn't have a txn sequence |
| 545 | Some(OperationType::Rollback), |
| 546 | format!("Transaction {} rolled back", transaction_id.id()), |
| 547 | ); |
| 548 | |
| 549 | self.write_entry(entry) |
| 550 | } |
| 551 | |
| 552 | /// Rotate to a new WAL file |
| 553 | fn rotate_wal_file(&self) -> Result<(), WALError> { |
nothing calls this directly
no test coverage detected