Struct Source 

pub struct Source<A, O> { /* private fields */ }

Cloneable handle to one exact attached native directory.

Implementations

impl<A: AsyncAuthorityStore, O: AsyncObjectStore> Source<A, O>

pub async fn state(&self) -> SourceState

Returns the current fail-closed semantic state.

pub async fn acknowledge_materialization( &self, key: IdempotencyKey, ) -> Result<ReconcileOutcome<A, O>, SourceError>

Re-establishes a clean source baseline after the core materializer has installed a published workspace generation into the attached root.

A fresh checkout is opened at authenticated workspace HEAD and a full bounded rescan proves the resulting host tree. Any concurrent host change is captured as a later generation instead of being discarded.

pub async fn reconcile(&self) -> Result<ReconcileOutcome<A, O>, SourceError>

Captures one bounded contiguous watcher interval and publishes it. A clean interval still advances authority ordering to atomically prove that its acknowledged workspace generation was current.

Errors

Rejects pinned sources and propagates exact native/canonical failures.

pub async fn reconcile_with_key( &self, key: IdempotencyKey, ) -> Result<ReconcileOutcome<A, O>, SourceError>

Captures and publishes one watcher interval under a stable retry key.

An exact retry returns the original durable outcome, including after a process restart. Reusing the key for another lifecycle operation is an idempotency conflict.

Errors

Rejects pinned sources, conflicting retry identities, and exact native/canonical failures.

pub async fn rescan(&self) -> Result<ReconcileOutcome<A, O>, SourceError>

Rebuilds one complete authenticated baseline while preserving events that arrive concurrently with the scan.

Errors

Returns native, capture, authority, or storage failures without acknowledging an incomplete interval.

pub async fn rescan_with_key( &self, key: IdempotencyKey, ) -> Result<ReconcileOutcome<A, O>, SourceError>

Rebuilds a complete baseline under a stable retry key.

Errors

Returns conflicting retry identities and exact native/canonical failures.

pub async fn seal(&self) -> Result<Generation<A, O>, SourceError>

Produces an immutable generation whose bytes no longer depend on the attached directory.

Errors

Fails unless a complete authenticated rescan and publication succeeds.

pub async fn seal_with_key( &self, key: IdempotencyKey, ) -> Result<Generation<A, O>, SourceError>

Seals the source under a stable retry key.

Errors

Returns conflicting retry identities and fails unless the original or recovered operation reached a clean sealed generation.

Trait Implementations

impl<A, O> Clone for Source<A, O>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.