Struct PartitionedExecutionPlan 

pub struct PartitionedExecutionPlan { /* private fields */ }

Immutable rank-local execution and communication plan.

Implementations

impl PartitionedExecutionPlan

pub fn new( graph: ExecutionGraph, group_contracts: Vec<(ArchitectureGroupKind, bool)>, drivers: Vec<Option<LayeredPartitionDriver>>, routes: Vec<PartitionBoundaryRoute>, publication: Option<PartitionOutputPublication>, commit_barrier: Option<CollectiveGroupId>, wire: PipelineWireContract, ) -> Result<Self, PartitionExecutionError>

Validates group slots, local ownership, route dependencies, and output ownership.

pub fn drivers(&self) -> &[Option<LayeredPartitionDriver>]

Rank-local execution drivers in architecture-group order.

pub fn routes(&self) -> &[PartitionBoundaryRoute]

Architecture-selected point-to-point boundary routes.

pub const fn publication(&self) -> Option<PartitionOutputPublication>

Selected output publication, including its exact opaque session group.

pub fn publication_authority( &self, manifest: &CommunicationManifest, ) -> Result<Option<PartitionOutputAuthority>, PartitionExecutionError>

Resolves architecture-selected publication authority without backend topology inference.

pub const fn commit_barrier(&self) -> Option<CollectiveGroupId>

Exact opaque session group used for post-publication commit synchronization.

Trait Implementations

impl Clone for PartitionedExecutionPlan

fn clone(&self) -> PartitionedExecutionPlan

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PartitionedExecutionPlan

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.