Skip to main content

uqa_storage/key_value/inverted_index/
storage.rs

1//
2// Unified Query Algebra
3//
4// Copyright (c) 2023-2026 Cognica, Inc.
5//
6
7//! Physical occurrence projections supply fixed reads and atomic evaluated changes.
8
9use super::{Arc, KeyValueStore, StorageBackendResult};
10use crate::key_value::{KeyValueMutation, KeyValueReadScope};
11
12/// Storage for the ordered occurrence format. A provider may project these keys from native rows instead of storing independent byte values. The reader must include the requested table's occurrence namespaces, preserve controlled reads and retained snapshots, and invoke each callback exactly once. Predecessor namespaces require existence checks and atomic retirement during source rebuilds, not value decoding. Mutations publish all projected changes atomically with the original read preconditions.
13pub trait OccurrenceStorage: Send + Sync {
14    fn read(&self, operation: &mut KeyValueReadScope<'_>) -> StorageBackendResult<()>;
15    fn mutate(&self, operation: &mut KeyValueMutation<'_>) -> StorageBackendResult<()>;
16}
17
18pub(super) struct KeyValueOccurrences(pub(super) Arc<dyn KeyValueStore>);
19
20impl OccurrenceStorage for KeyValueOccurrences {
21    fn read(&self, operation: &mut KeyValueReadScope<'_>) -> StorageBackendResult<()> {
22        self.0.with_read_view(operation)
23    }
24    fn mutate(&self, operation: &mut KeyValueMutation<'_>) -> StorageBackendResult<()> {
25        self.0.with_mutation(operation)
26    }
27}