Struct ShardedCsrIndex 

pub struct ShardedCsrIndex { /* private fields */ }

Per-tenant partitioned CSR index.

Holds one CsrIndex per tenant on the owning Data Plane core. Handlers resolve the caller’s tenant to a partition up front; all downstream graph operations (algorithms, MATCH, traversal) run against that single partition and cannot reach any other tenant’s state.

Implementations

impl ShardedCsrIndex

pub fn new() -> Self

Construct an empty sharded index with no partitions.

pub fn partition(&self, tid: TenantId) -> Option<&CsrIndex>

Shared access to a tenant’s partition, if it exists.

Returns None if the tenant has never inserted any graph data. Callers expecting a read-only view of a possibly-empty partition should treat None as “empty” rather than as an error.

pub fn partition_mut(&mut self, tid: TenantId) -> Option<&mut CsrIndex>

Mutable access to a tenant’s partition, if it exists.

pub fn get_or_create(&mut self, tid: TenantId) -> &mut CsrIndex

Mutable access to a tenant’s partition, creating an empty one on first use.

This is the canonical write-path entry point: insertion handlers call this once to resolve the partition, then operate on the returned &mut CsrIndex exactly as they would on a standalone instance.

pub fn drop_partition(&mut self, tid: TenantId) -> bool

Drop a tenant’s entire graph state.

Returns true if a partition existed and was removed, false if the tenant had no graph state. Used by tenant-purge flows — O(1) structural deletion replaces the former “range-scan and erase every key with the {tid}: prefix” approach, which was both slow and coupled to the lexical encoding.

pub fn drop_collection(&mut self, _tid: TenantId, _collection: &str)

Collection-scoped in-memory reclaim.

The CSR is collection-agnostic in memory: a tenant’s partition holds edges from all collections in a single adjacency structure. There is no per-collection sub-partition to drop. As a result this method is intentionally a no-op — collection-scoped edge removal from persistent storage is handled by [EdgeStore::purge_collection], and the stale in-memory CSR state is eliminated on the next tenant drop_partition call (triggered by tenant deletion) or on server restart (CSR is rebuilt from the now-clean EdgeStore).

pub fn contains_partition(&self, tid: TenantId) -> bool

Whether a partition exists for the tenant.

pub fn partition_count(&self) -> usize

Number of tenants with graph state on this core.

pub fn iter(&self) -> Iter<'_, TenantId, CsrIndex>

Iterate all (tenant, partition) pairs. Used for checkpointing, memory accounting, and administrative views that genuinely need to see every tenant’s state.

pub fn iter_mut(&mut self) -> IterMut<'_, TenantId, CsrIndex>

Mutable iteration over all partitions. Used by compact() and similar maintenance passes that apply per-partition without needing tenant routing.

pub fn compact_all(&mut self) -> Result<(), GraphError>

Compact every partition. Mirrors CsrIndex::compact but across the full set — maintenance handlers call this once per core.

Errors

Returns the first GraphError::MemoryBudget encountered if any partition has a memory governor installed and the budget is exhausted. Partitions already compacted before the error are not rolled back.

pub fn install_partition(&mut self, tid: TenantId, csr: CsrIndex)

Replace an existing partition (or install a new one) with the given CsrIndex. Used by the rebuild path — after rebuilding a tenant’s CSR from persistent edge storage, this installs it atomically.

pub fn entry(&mut self, tid: TenantId) -> Entry<'_, TenantId, CsrIndex>

Access or create a partition via the Entry API, for cases that need conditional initialization with a non-default constructor.

Trait Implementations

impl Default for ShardedCsrIndex

fn default() -> Self

Returns the “default value” for a type.