Struct DistributedFs 

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

Shared constructors for the semantic handles of one filesystem deployment.

Implementations

impl<A, O, S> DistributedFs<A, O, S>

pub const fn new(fs: Fs<A, O>, store: S) -> Self

Composes an existing filesystem and durable semantic-state store.

pub async fn workspace( &self, workspace_id: WorkspaceId, ) -> Result<Workspace<A, O>, WorkspaceLineageError<S::Error>>

where A: AsyncAuthorityStore, O: AsyncObjectStore, S: WorkspaceLineageStore + Clone,

Resolves one workspace by authenticated durable identity.

pub fn contexts(&self) -> WorkspaceContextRegistry<S>

where S: WorkspaceContextStore + Clone,

Constructs the durable recursive context handle.

pub fn lineage(&self) -> WorkspaceGraph<S>

where S: WorkspaceLineageStore + Clone,

Constructs the authenticated direct-workspace lineage handle.

pub fn git(&self, workspace_id: WorkspaceId) -> GitCompatRepository<S>

where S: Clone,

Constructs one root’s Git-shaped compatibility view.

pub async fn attach_lazy<D: DemandSource + 'static>( &self, name: impl AsRef<str>, source: Arc<D>, ) -> Result<LazyWorkspace<A, O, D, S>, LazyWorkspaceError>

where A: AsyncAuthorityStore, O: AsyncObjectStore, S: LazyWorkspaceStore + Clone,

Attaches an unresolved source without enumerating or reading its tree.

pub async fn attach_lazy_with_config<D: DemandSource + 'static>( &self, name: impl AsRef<str>, source: Arc<D>, config: VolumeConfig, ) -> Result<LazyWorkspace<A, O, D, S>, LazyWorkspaceError>

where A: AsyncAuthorityStore, O: AsyncObjectStore, S: LazyWorkspaceStore + Clone,

Attaches an unresolved source to a workspace with exact filesystem semantics.

pub async fn open_lazy<D: DemandSource + 'static>( &self, workspace: Workspace<A, O>, source: Arc<D>, ) -> Result<LazyWorkspace<A, O, D, S>, LazyWorkspaceError>

where A: AsyncAuthorityStore, O: AsyncObjectStore, S: LazyWorkspaceStore + Clone,

Reopens an existing workspace against its unresolved source.

pub fn publications<P: MultiRootPublisher, R: MultiRootPublicationAuthorizer>( &self, publisher: P, authorizer: R, ) -> MultiRootPublicationCoordinator<S, P, R>

where S: MultiRootPublicationStore + Clone,

Composes the SDK-owned all-roots publication state machine.

impl<P, O, S> DistributedFs<StreamAuthorityStore<P>, O, S>

pub fn operations( &self, ) -> OperationWindowCoordinator<StreamOperationWindowStore<P>>

Constructs operation windows on the same authority stream that fences generation publication.

Keeping the lease gate and workspace authority on one provider makes it impossible to construct a coordinator whose leases cannot authorize the publications they protect.

Trait Implementations

impl<A, O, S: Clone> Clone for DistributedFs<A, O, S>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<A, O, S> WorkspaceResolver<A, O> for DistributedFs<A, O, S>

where A: AsyncAuthorityStore + Send + Sync, O: AsyncObjectStore + Send + Sync, S: WorkspaceLineageStore + Clone,

type Error = WorkspaceLineageError<<S as WorkspaceLineageStore>::Error>

Resolver failure.

async fn resolve( &self, workspace_id: WorkspaceId, ) -> Result<Workspace<A, O>, Self::Error>

Opens the exact workspace or fails closed.