Struct PartitionedSessionFactoryInput 

pub struct PartitionedSessionFactoryInput<A, G, W> { /* private fields */ }

Exact architecture, partition, communication manifest, and payload work received by a partition-runtime factory.

This value is assembled only after the architecture has been checked against its partition and the payload tasks have been re-derived from that same architecture/partition pair. A factory consumes all four authorities together instead of receiving independently assembled runtime inputs.

Implementations

impl<A, G, W> PartitionedSessionFactoryInput<A, G, W>

pub fn materialization_tasks(&self) -> &[ReplicatedTextMaterializationTask]

Exact architecture-owned payload tasks for this rank.

pub fn into_parts( self, ) -> (A, ArchitecturePartition<G, W>, CommunicationManifest, Vec<ReplicatedTextMaterializationTask>)

Consumes the causal handoff into the values needed to build the rank-local runtime.