Struct WorkspaceMultiRootPublisher 

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

SDK-owned publisher over ordinary immutable workspace joins.

Preparation validates pinned inputs and resolutions against a disposable SDK workspace. It never changes the target. Publication then repeats the same deterministic join through the target’s fenced authority CAS.

Implementations

impl<A, O, R> WorkspaceMultiRootPublisher<A, O, R>

pub fn new(resolver: R) -> Self

Creates a publisher over an injected authenticated resolver.

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.

pub const fn resolver(&self) -> &R

Borrows the resolver capability.

Trait Implementations

impl<A, O, R> MultiRootPublisher for WorkspaceMultiRootPublisher<A, O, R>

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

type Error = WorkspaceMultiRootPublisherError<<R as WorkspaceResolver<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.

fn finalize( &self, _operation_id: OperationId, _root_id: WorkspaceRootId, _root: &MultiRootMergeRoot, ) -> impl Future<Output = Result<(), Self::Error>> + StorageFuture

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.