Struct UpdateOnlyEdgeShard 

pub struct UpdateOnlyEdgeShard<S: UniversalRead + 'static> { /* private fields */ }

A batch writer over the segments of one shard directory, generic over the backend S.

Compared to EdgeShard, there is no WAL, no optimizers, and no EdgeConfig — the write target’s own segment config is the only configuration a write needs.

Implementations

impl<S: UniversalRead + 'static> UpdateOnlyEdgeShard<S>

pub fn apply_batch( &self, operations: impl IntoIterator<Item = (u64, CollectionUpdateOperations)>, ) -> OperationResult<UpdateBatchOutcome>

Apply a batch of update operations, each paired with the operation number to record as its version. Operations are expected in ascending operation-number order; see UpdateBatchPlan::build for what is rejected.

Atomic in the sense that matters without a WAL: applied in full or the error is returned, and re-applying a batch that partially landed skips the points that already carry its version.

impl UpdateOnlyEdgeShard<MmapFile>

pub fn open_mmap(path: &Path) -> OperationResult<Self>

Open a writer over local memory-mapped files, discovering segments by scanning the segments/ directory — the writer owns the directory it writes to, so there is no manifest to agree with.

impl<S: UniversalRead + 'static> UpdateOnlyEdgeShard<S>

pub fn open( fs: S::Fs, path: &Path, enumerator: impl SegmentEnumerator + 'static, ) -> OperationResult<Self>

where S::Fs: UniversalReadFs<File = S>,

Open a writer over the shard directory at path, using fs as the read backend and enumerator to discover the segments.

Segments are opened in parallel on the shard’s thread pool, each over its own prefetching CachedFs (see [UpdateOnlySegment::open]) — the same shape as the read-only follower’s load — and entirely cold: no point data is fetched until a batch reads a point. A segment that fails to load is an error, not a skip — a writer that misses a segment would resolve a point against a stale copy of itself, or duplicate it.

impl<S: UniversalRead + 'static> UpdateOnlyEdgeShard<S>

pub fn preview_batch( &self, operations: impl IntoIterator<Item = (u64, CollectionUpdateOperations)>, ) -> OperationResult<UpdateBatchPreview>

Resolve a batch without writing anything: what apply_batch would do, reported per point.

Runs the same resolution code path as the real apply — the same operations are rejected, the same points read — so the report cannot drift from the apply’s behavior.

impl<S: UniversalRead + 'static> UpdateOnlyEdgeShard<S>

pub fn path(&self) -> &Path

pub fn segments_count(&self) -> usize

Number of segments the writer has open.

pub fn segment_configs(&self) -> Vec<SegmentConfigInfo>

Every segment’s config, cloned out, with the write target marked. Order is unspecified. The write target’s config is the schema a write must conform to: the named vectors a point carries, and their shapes.