Struct Storage 

pub struct Storage {
    pub logical_log: RwLock<LogicalLog>,
    /* private fields */
}

Fields

logical_log: RwLock<LogicalLog>

Implementations

impl Storage

pub fn new( file: Arc<dyn File>, io: Arc<dyn IO>, encryption_ctx: Option<EncryptionContext>, ) -> Self

Trait Implementations

impl Debug for Storage

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

Formats the value using the given formatter.

impl DurableStorage for Storage

fn should_checkpoint(&self) -> bool

Lock-free: reads shadowed atomics only.

fn serialize_row_version( &self, log_record: &mut LogRecord, row_version: &RowVersion, portable_extension: Option<&[u8]>, ) -> Result<()>

Append one row-version op to log_record’s payload buffer, in the on-disk wire format used by the logical log. Updates op_count.

fn serialize_database_header( &self, log_record: &mut LogRecord, header: &DatabaseHeader, ) -> Result<()>

Append a DatabaseHeader op to log_record’s payload buffer.

fn log_tx( &self, m: LogRecord, on_serialization_complete: OnSerializationComplete<'_>, ) -> Result<(Completion, u64)>

Write a transaction to the logical log without advancing the writer offset.

fn upgrade_header_for_log_tx(&self, m: &LogRecord) -> Result<Option<Completion>>

If m needs a logical-log header upgrade before it can be appended, start that write and return its completion. Callers must wait for this completion and then call log_tx.

fn sync(&self, sync_type: FileSyncType) -> Result<Completion>

fn update_header(&self) -> Result<Completion>

Persist the current logical-log header to durable storage.

fn truncate(&self, checkpointed_through_ts: u64) -> Result<Completion>

Truncate the logical log, discarding frames at or below checkpointed_through_ts (the checkpoint’s published boundary). Frames above the boundary (uncheckpointed concurrent commits) are preserved.

fn reset_to_fresh_header(&self) -> Result<Completion>

Reset the logical log to a fresh header-only file.

fn get_logical_log_file(&self) -> Arc<dyn File>

fn logical_log_offset(&self) -> u64

fn encryption_ctx(&self) -> Option<EncryptionContext>

fn set_checkpoint_threshold(&self, threshold: i64)

Set the checkpoint threshold in bytes of logical-log data written. A negative value disables automatic checkpointing.

fn checkpoint_threshold(&self) -> i64

fn advance_logical_log_offset_after_success(&self, bytes: u64) -> Result<()>

fn restore_logical_log_state_after_recovery( &self, offset: u64, running_crc: u32, )

fn set_header(&self, header: LogHeader)

Set the in-memory log header from a previously-read on-disk header.

fn on_log_write_complete(&self) -> Result<Completion>

Called after a logical-log write completed successfully, before the transaction is made visible by advancing the logical-log offset.

fn discard_pending_log_write(&self) -> Result<()>

fn on_checkpoint_start(&self) -> Result<()>

Called when a checkpoint begins, before any rows are written to the B-tree.

fn on_checkpoint_end(&self, _result: Result<&CheckpointResult>) -> Result<()>

Called after the checkpoint has fully completed: rows are flushed, WAL is truncated, and the logical log is reset.