Struct AsyncProximityHead 

pub struct AsyncProximityHead<S: AsyncStore> { /* private fields */ }

Durable named-head orchestration for async proximity maps.

The head owns validation reuse, a long-lived authenticated search runtime, expected-head CAS, and bounded conflict retry. Immutable map bytes remain readable through the underlying AsyncStore without this manager.

Implementations

impl<S> AsyncProximityHead<S>

where S: AsyncStore + AsyncManifestStore + Clone, <S as AsyncStore>::Error: Send + Sync, <S as AsyncManifestStore>::Error: Send + Sync,

pub fn new(store: S, name: impl Into<Vec<u8>>) -> Self

pub fn with_runtime( store: S, name: impl Into<Vec<u8>>, runtime: Arc<SearchRuntime>, ) -> Self

pub fn with_limits(self, limits: ContentGraphLimits) -> Self

pub fn with_max_conflict_retries(self, retries: usize) -> Self

pub fn runtime(&self) -> &Arc<SearchRuntime>

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

pub async fn open(&self) -> Result<Option<AsyncProximitySnapshot<S>>, Error>

Open the current head, reusing a validation receipt only when the named manifest CID is unchanged on this manager and store instance.

pub async fn build_if_absent( &self, config: ProximityConfig, records: impl IntoIterator<Item = ProximityRecord>, options: AsyncProximityBuildOptions, created_at_millis: u64, metadata: BTreeMap<Vec<u8>, Vec<u8>>, ) -> Result<AsyncProximityHeadCommit<S, ProximityBuildStats>, Error>

Build a canonical map and install it only when the named head is absent.

pub async fn publish_descriptor_if_absent( &self, descriptor: Cid, logical_version: u64, created_at_millis: u64, metadata: BTreeMap<Vec<u8>, Vec<u8>>, ) -> Result<AsyncProximityHeadCommit<S, ()>, Error>

Validate and install an already-published proximity descriptor when the named head is absent. This is useful when construction and durable head publication are separate application stages.

pub async fn mutate_with_retry( &self, mutations: impl IntoIterator<Item = ProximityMutation>, created_at_millis: u64, metadata: BTreeMap<Vec<u8>, Vec<u8>>, ) -> Result<AsyncProximityHeadCommit<S, ProximityMutationStats>, Error>

Apply a mutation batch against the current validated head and atomically publish the resulting descriptor. Conflicts reopen fresh state and retry up to the configured bound.