Struct MaterializingWorkspaceMultiRootPublisher 

pub struct MaterializingWorkspaceMultiRootPublisher<A, O, R, M> { /* private fields */ }

Workspace publisher composed with an injected physical materializer.

Logical publication happens first under the durable all-roots decision. If materialization is interrupted, retry discovers the exact generation from the workspace idempotency record and resumes the same materializer.

Implementations

impl<A, O, R, M> MaterializingWorkspaceMultiRootPublisher<A, O, R, M>

pub fn new(resolver: R, materializer: M) -> Self

Creates one composed logical and physical publisher.

pub fn with_merge_drivers(self, registry: Arc<MergeDriverRegistry>) -> Self

Uses one immutable-input driver registry for conflict resolution.

pub fn with_root_merge_drivers( self, root_id: WorkspaceRootId, registry: Arc<MergeDriverRegistry>, ) -> Self

Overrides merge-driver selection for one root in a multi-root plan.

Trait Implementations

impl<A, O, R, M> MultiRootPublisher for MaterializingWorkspaceMultiRootPublisher<A, O, R, M>

where A: AsyncAuthorityStore, O: AsyncObjectStore, R: WorkspaceResolver<A, O>, M: MultiRootMaterializer<A, O>,

type Error = MaterializingWorkspaceMultiRootPublisherError<<R as WorkspaceResolver<A, O>>::Error, <M as MultiRootMaterializer<A, O>>::Error>

Publisher error.

async fn prepare( &self, operation_id: OperationId, root_id: WorkspaceRootId, root: &MultiRootMergeRoot, resolutions: &BTreeMap<ConflictKey, MergeResolution>, ) -> Result<MultiRootPrepare, Self::Error>

Atomically validates and reserves the exact pinned target. Repeating this call for one operation must return the same live reservation.

async fn release( &self, operation_id: OperationId, root_id: WorkspaceRootId, fence: &MultiRootFence, ) -> Result<(), Self::Error>

Releases a reservation when validation fails before a commit decision.

async fn project_conflict( &self, operation_id: OperationId, root_id: WorkspaceRootId, root: &MultiRootMergeRoot, conflict: Option<&MergePlan>, ) -> Result<GenerationId, Self::Error>

Projects one root into its durable conflicted working state.

async fn abort_conflict( &self, operation_id: OperationId, root_id: WorkspaceRootId, root: &MultiRootMergeRoot, projected_generation: GenerationId, ) -> Result<GenerationId, Self::Error>

Restores one projected root to its exact pre-merge generation.

async fn declare_conflicts( &self, operation_id: OperationId, root_id: WorkspaceRootId, root: &MultiRootMergeRoot, conflict: &MergePlan, paths: &[String], ) -> Result<BTreeSet<ConflictKey>, Self::Error>

Validates explicitly staged conflict paths and returns their exact keys.

async fn finish_conflict( &self, operation_id: OperationId, root_id: WorkspaceRootId, root: &MultiRootMergeRoot, projected_generation: GenerationId, ) -> Result<MultiRootConflictFinish, Self::Error>

Captures the current resolved working generation during continue.

async fn publish( &self, operation_id: OperationId, root_id: WorkspaceRootId, root: &MultiRootMergeRoot, resolutions: &BTreeMap<ConflictKey, MergeResolution>, fence: &MultiRootFence, ) -> Result<MultiRootPublishRoot, Self::Error>

Idempotently rolls one root forward after the durable commit decision.

async fn finalize( &self, operation_id: OperationId, root_id: WorkspaceRootId, _root: &MultiRootMergeRoot, ) -> Result<(), Self::Error>

Reclaims terminal per-root recovery state after the all-roots Applied decision is durable. It must be idempotent because restart recovery retries cleanup independently of logical publication.