Struct MemoryRecordSnapshot 

pub struct MemoryRecordSnapshot { /* private fields */ }

One pinned committed sequence. Dropping the last owner releases its lease.

Implementations

impl MemoryRecordSnapshot

pub fn sequence(&self) -> CommitSequence

pub fn get(&self, key: &[u8]) -> Option<RecordVersion<SharedRecordValue>>

Return a revision even if its payload is a tombstone.

pub fn scan( &self, prefix: &[u8], after: Option<&[u8]>, limit: usize, control: &StorageReadControl, ) -> VersionResult<BudgetedVec<ScannedRecord>>

Read a bounded ordered page, including tombstones for revision checks.

Trait Implementations

impl CommittedRecordSnapshot for MemoryRecordSnapshot

fn reclamation_epoch(&self) -> Option<u64>

The provider’s tombstone-reclamation epoch captured under the same admission as this snapshot. None means this provider does not supply reclamation-aware observations. Wrappers must forward the original value, never refresh it from current storage.

fn sequence(&self) -> CommitSequence

fn get( &self, key: &[u8], control: &StorageReadControl, ) -> VersionResult<Option<RecordVersion<SharedRecordValue>>>

Return the newest revision at or before this snapshot, including tombstones. Missing identities return None.

fn visit_value_bounded( &self, key: &[u8], max_bytes: usize, control: &StorageReadControl, visit: &mut RecordValueVisitor<'_>, ) -> VersionResult<()>

Check a live value’s encoded size before provider materialization, without changing revision or tombstone visibility. The default rejects unsupported providers rather than materializing through get.

fn scan( &self, prefix: &[u8], after: Option<&[u8]>, limit: usize, control: &StorageReadControl, ) -> VersionResult<BudgetedVec<ScannedRecord>>

Return at most limit unique keys in ascending order, strictly after after, including tombstones. A short page means that the prefix is exhausted at this snapshot; all pages keep the same boundary.

fn visit_prefix( &self, prefix: &[u8], after: Option<&[u8]>, limit: usize, control: &StorageReadControl, visit: &mut RecordScanVisitor<'_>, ) -> VersionResult<()>

Visit ordered versions until the limit, exhaustion or a visitor returning false. Implementations with borrowed pages avoid charging their encoded payloads to the caller’s decode allowance.

fn metadata( &self, key: &[u8], control: &StorageReadControl, ) -> VersionResult<Option<RecordMetadata>>

Read a revision and tombstone marker without materializing its value when the provider supports key-only access.

fn visit_keys( &self, prefix: &[u8], after: Option<&[u8]>, limit: usize, control: &StorageReadControl, visit: &mut RecordKeyVisitor<'_>, ) -> VersionResult<()>

Visit ordered record identities, including tombstones, without fetching values from providers with key-only access.

fn visit_value( &self, key: &[u8], control: &StorageReadControl, visit: &mut RecordValueVisitor<'_>, ) -> VersionResult<()>

Borrow provider-owned bytes for an internal storage visitor. Visitors must not reenter this snapshot or execute SQL/user callbacks.

impl Drop for MemoryRecordSnapshot

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.