Struct ExprTreeStores 

pub struct ExprTreeStores { /* private fields */ }

Typed source/control/derived stores plus explicit Table/Dir mount descriptors.

Implementations

impl ExprTreeStores

pub fn new(root_dir: DirId) -> Result<Self, StoreError>

Compose a tree over an existing root directory.

pub fn reopen( root_dir: DirId, source: BTreeMap<CellId, SourceEntry>, control: BTreeMap<String, ControlEntry>, derived: BTreeMap<CellId, DerivedEntry>, mounts: Vec<MountDescriptor>, ) -> Result<Self, StoreError>

Reopen persisted stores, validating the mount table before accepting it.

pub fn root_dir(&self) -> &DirId

Root directory required by the mounted namespace owner.

pub fn source_entry(&self, id: &CellId) -> Option<&SourceEntry>

Authored source entries only.

pub fn control_entry(&self, key: &str) -> Option<&ControlEntry>

Operational control entries only.

pub fn derived_entry(&self, id: &CellId) -> Option<&DerivedEntry>

Rebuildable derived entries only.

pub fn mounts(&self) -> impl Iterator<Item = &MountDescriptor>

All current explicit mounts.

pub fn return_value_without_mounting(&self, _resource: MountResource) -> usize

Return a Table or Dir value to the caller without mutating the namespace.

pub fn mount(&mut self, descriptor: MountDescriptor) -> Result<(), StoreError>

Explicitly mount a Table or Dir descriptor.

pub fn unmount( &mut self, path: &TablePath, ) -> Result<MountDescriptor, StoreError>

Removes and returns one explicit mount descriptor.

pub fn observe_mount_epoch( &mut self, path: &TablePath, epoch: MountEpoch, ) -> Result<(), StoreError>

Record a mounted backend epoch in the control store.

pub fn prepare_source_control_commit( source_writes: BTreeMap<CellId, SourceEntry>, control_writes: BTreeMap<String, ControlEntry>, ) -> PendingCommit

Prepare a recoverable source/control commit.

The transaction boundary is exactly source plus control. Recovery replays the same pending record until both sides are durable. Derived entries are rebuildable and are not part of this boundary.

pub fn commit_source(&mut self, pending: &mut PendingCommit)

Persist the source side of a prepared commit.

pub fn commit_control(&mut self, pending: &mut PendingCommit)

Persist the control side of a source-committed commit.

pub fn recover_commit(&mut self, pending: &mut PendingCommit)

Finish or replay a partially persisted source/control commit.

pub fn put_derived(&mut self, id: CellId, entry: DerivedEntry)

Store a rebuildable derived value outside source entries.

pub fn put_control(&mut self, key: impl Into<String>, entry: ControlEntry)

Store an operational control value outside source entries.

pub fn remove_source(&mut self, id: &CellId) -> Option<SourceEntry>

Removes authored source for a deleted cell.

Trait Implementations

impl Clone for ExprTreeStores

fn clone(&self) -> ExprTreeStores

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ExprTreeStores

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

Formats the value using the given formatter.

impl Eq for ExprTreeStores

impl PartialEq for ExprTreeStores

fn eq(&self, other: &ExprTreeStores) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for ExprTreeStores