Struct SourceObservationRegistry 

pub(crate) struct SourceObservationRegistry {
    process_nonce: [u8; 16],
    entries: Mutex<HashMap<SourceBinding, Arc<SourceObservationEntry>>>,
}

Bounded process-local registry shared by every clone of one MCP server.

Fields

process_nonce: [u8; 16]

Random identity distinguishing epochs created by this process.

entries: Mutex<HashMap<SourceBinding, Arc<SourceObservationEntry>>>

Bounded observers keyed by exact source binding.

Implementations

impl SourceObservationRegistry

pub(crate) fn with_verified_read<T, F>( &self, database: &Path, root: &Path, config: Option<&Path>, control: &IndexWorkControl, query: F, ) -> Result<VerifiedReadOutcome<T>, CliError>

where F: FnMut(&AtlasStore, VerifiedReadStamp) -> Result<T, CliError>,

Run one complete query inside a source-epoch and SQLite-generation boundary.

fn entry( &self, binding: SourceBinding, ) -> Result<Option<Arc<SourceObservationEntry>>, CliError>

Reuse or admit the bounded observer for an exact source binding.

fn with_observed_read<T, F>( &self, entry: &SourceObservationEntry, control: &IndexWorkControl, query: F, ) -> Result<VerifiedReadOutcome<T>, CliError>

where F: FnMut(&AtlasStore, VerifiedReadStamp) -> Result<T, CliError>,

Retry a query until one observed epoch remains valid through acceptance.

fn prepare_observed_store( &self, entry: &SourceObservationEntry, control: &IndexWorkControl, work: &mut VerifiedReadWork, ) -> Result<(AtlasStore, VerifiedSourceEpoch), CliError>

Open a snapshot backed by a current epoch or establish a new exact epoch.

fn accepts_observed_result( entry: &SourceObservationEntry, epoch: &VerifiedSourceEpoch, control: &IndexWorkControl, ) -> Result<bool, CliError>

Confirm that no source, policy, or observer event invalidated a query result.

fn with_exact_fallback<T, F>( &self, binding: &SourceBinding, control: &IndexWorkControl, query: F, ) -> Result<VerifiedReadOutcome<T>, CliError>

where F: FnMut(&AtlasStore, VerifiedReadStamp) -> Result<T, CliError>,

Exact-per-call compatibility path when a native observer cannot be admitted.

Trait Implementations

impl Debug for SourceObservationRegistry

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

Formats the value using the given formatter.

impl Default for SourceObservationRegistry

fn default() -> Self

Returns the “default value” for a type.