Struct IndexedMap 

pub struct IndexedMap<'a, S>
where
    S: Store + ManifestStore + TransactionalStore,
{ /* private fields */ }

Strict coordinator for one source map and its active secondary indexes.

Implementations

impl<S> IndexedMap<'_, S>

where S: Store + ManifestStore + TransactionalStore,

pub fn export_current(&self) -> Result<IndexedSnapshotBundle, Error>

Export the exact catalog-selected current source and all active index trees.

pub fn import_current( &self, bundle: &IndexedSnapshotBundle, expected_source: Option<&MapVersionId>, ) -> Result<IndexedVersion, Error>

Verify and atomically install a current indexed snapshot for this exact source ID.

expected_source == None means the destination source must be absent.

impl<'a, S> IndexedMap<'a, S>

where S: Store + ManifestStore + TransactionalStore,

pub fn id(&self) -> &[u8]

Stable source-map identifier.

pub fn registry(&self) -> &SecondaryIndexRegistry

Borrow runtime definitions supplied when this handle was opened.

pub fn source(&self) -> VersionedMap<'_, S>

Open the underlying source as a read-only raw map handle.

pub fn get(&self, key: &[u8]) -> Result<Option<Vec<u8>>, Error>

Read one source key from the current durable head.

pub fn health(&self) -> Result<IndexedMapHealth, Error>

Re-run bounded structural startup validation and return exact health state.

pub fn metrics(&self) -> IndexedMapMetricsSnapshot

Snapshot cumulative logical work counters for this handle.

impl<S> IndexedMap<'_, S>

where S: Store + ManifestStore + TransactionalStore + Clone + Send + Sync,

pub fn ensure_index( &self, name: impl AsRef<[u8]>, ) -> Result<IndexBuildResult, Error>

Build a runtime definition against a pinned source snapshot and atomically activate it.

pub fn verify_index( &self, name: impl AsRef<[u8]>, source_version: &MapVersionId, ) -> Result<IndexVerification, Error>

Rebuild and compare one exact retained source/index checkpoint without publishing roots.

pub fn verify_all( &self, source_version: &MapVersionId, ) -> Result<Vec<IndexVerification>, Error>

Verify every generation currently selected by the catalog at one source version.

pub fn repair_index( &self, name: impl AsRef<[u8]>, source_version: &MapVersionId, ) -> Result<IndexVerification, Error>

Rebuild and atomically correct one selected checkpoint when semantic drift exists.

pub fn replace_index( &self, name: impl AsRef<[u8]>, new_definition: SecondaryIndex, ) -> Result<IndexBuildResult, Error>

Shadow-build and atomically replace one active definition generation.

pub fn deactivate_index( &self, name: impl AsRef<[u8]>, ) -> Result<IndexedVersion, Error>

Remove one active selection while retaining its descriptors, checkpoints, and roots.

pub fn apply(&self, mutations: Vec<Mutation>) -> Result<IndexedVersion, Error>

Apply source mutations while maintaining every active index atomically.

pub fn apply_if( &self, expected: Option<&MapVersionId>, mutations: Vec<Mutation>, ) -> Result<IndexedMapUpdate, Error>

Conditionally apply source mutations when the expected source version is current.

pub fn put( &self, key: impl Into<Vec<u8>>, value: impl Into<Vec<u8>>, ) -> Result<IndexedVersion, Error>

Insert or replace one source record and maintain all active indexes.

pub fn delete(&self, key: impl Into<Vec<u8>>) -> Result<IndexedVersion, Error>

Delete one source record and maintain all active indexes.

pub fn edit( &self, edit: impl FnOnce(&mut IndexedMapEditor), ) -> Result<IndexedVersion, Error>

Collect several source edits and publish one coordinated version.

impl<S> IndexedMap<'_, S>

where S: Store + ManifestStore + ManifestStoreScan + TransactionalStore + Clone + Send + Sync,

pub fn keep_last(&self, count: usize) -> Result<IndexedRetentionResult, Error>

Retain the newest source versions and their complete transitive index closure.

count == 0 still retains the current source. This removes named roots and catalog checkpoint records only; content-addressed nodes require a separate store-global GC plan/sweep.

impl<S> IndexedMap<'_, S>

where S: Store + NodeStoreScan + ManifestStore + ManifestStoreScan + TransactionalStore,

pub fn plan_indexed_gc(&self) -> Result<GcPlan, Error>

Plan node GC from every remaining named root in the shared store.

impl<'a, S> IndexedMap<'a, S>

where S: Store + ManifestStore + TransactionalStore,

pub fn snapshot(&self) -> Result<IndexedSnapshot<'a, S>, Error>

Pin the current catalog first, then reopen every selected immutable root.

pub fn snapshot_at( &self, source_version: &MapVersionId, ) -> Result<IndexedSnapshot<'a, S>, Error>

Reopen exact checkpoints for a retained source using current generations.

pub fn snapshot_by_id( &self, id: &IndexedSnapshotId, ) -> Result<IndexedSnapshot<'a, S>, Error>

Reopen the exact retained catalog/source pair represented by id.