Struct RecordRead 

pub struct RecordRead<'a> { /* private fields */ }

Borrowed Key/Value adapter over an already captured committed/private record view. It does not open or advance a session.

Implementations

impl<'a> RecordRead<'a>

pub fn new( view: &'a MergedRecordSnapshot, database: DatabaseId, control: &'a StorageReadControl, ) -> Self

Trait Implementations

impl KeyValueRead for RecordRead<'_>

fn control(&self) -> &StorageReadControl

fn marker_fingerprint( &self, key: &[u8], ) -> StorageBackendResult<Option<[u8; 32]>>

Versioned identity of both committed and private inputs to one shared change marker. Unlike a final record revision, a private marker cannot hide a changed committed input. Unsupported providers return None.

fn revision( &self, prefixes: &[&[u8]], ) -> StorageBackendResult<KeyValueReadRevision>

fn record_revision( &self, key: &[u8], ) -> StorageBackendResult<Option<KeyValueReadRevision>>

Identity of one live record on this fixed view. Unlike a view revision, unrelated commits do not change it. Compare identities only for the same logical key; missing records and tombstones return None. Providers without exact committed/private record provenance must reject this capability.

fn retained_source( &self, key: &[u8], ) -> StorageBackendResult<Option<Arc<dyn KeyValueRead + Send + Sync>>>

Read source attached to this exact private metadata replacement. Absence never authorizes opening a newer snapshot. Committed values have no attachment; provider wrappers translate the metadata key but preserve the source’s own key space and controls.

fn retain( &self, _prefixes: &[&[u8]], ) -> StorageBackendResult<Arc<dyn KeyValueRead + Send + Sync>>

Retain this committed/private boundary after the callback returns. Callers may only read the selected prefixes. The default copies selected bytes under this reader’s allowance; versioned providers retain their existing visibility owners without loading values.

fn visit_value( &self, key: &[u8], visit: &mut ValueReadVisitor<'_>, ) -> StorageBackendResult<()>

fn visit_prefix( &self, prefix: &[u8], visit: &mut KeyValueReadVisitor<'_>, ) -> StorageBackendResult<()>

fn visit_value_budgeted( &self, key: &[u8], control: &StorageReadControl, visit: &mut ValueReadVisitor<'_>, ) -> StorageBackendResult<()>

Visit one value on this same boundary, charging temporary provider buffers to the supplied query allowance.

fn visit_values( &self, keys: &mut KeyValueReadKeyIterator<'_>, visit: &mut KeyValuePointVisitor<'_>, ) -> StorageBackendResult<()>

Borrow requested values in input order on this boundary. Key production and callbacks are internal and must not reenter persistence. A false visitor or an error stops before producing the next key; defaults require only ordinary point reads.

fn visit_key_presence( &self, keys: &mut KeyValueReadKeyIterator<'_>, visit: &mut KeyPresenceVisitor<'_>, ) -> StorageBackendResult<()>

Probe requested identities in input order without loading their values. The default uses the existing key-only scan capability; versioned readers reuse private selection cursors.

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

Check a value’s encoded size before provider materialization on this same committed/private view.

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

Visit at most limit values in key order, strictly after after, without advancing this read boundary.

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

Visit at most limit live keys in ascending order, strictly after after, without reading their values or advancing this boundary. Capable wrappers must preserve this key-only contract.

fn contains_prefix_budgeted( &self, prefix: &[u8], control: &StorageReadControl, ) -> StorageBackendResult<bool>

Probe live keys on this boundary without materializing their values.

fn get(&self, key: &[u8]) -> StorageBackendResult<Option<BudgetedVec<u8>>>