Struct GlobalResultAssembler 

pub struct GlobalResultAssembler { /* private fields */ }

Coordinator-owned atomic result assembler.

Implementations

impl GlobalResultAssembler

pub fn new( expected_ranges: impl IntoIterator<Item = String>, plan: AssemblyPlan, budget: DistributedReadBudget, ) -> Result<Self, DistributedReadAssemblyError>

pub fn push_range( &mut self, input: RangeAssemblerInput, ) -> Result<(), DistributedReadAssemblyError>

Register all buffered payloads for one range. Callers must not open a client stream before Self::prepare returns successfully.

pub fn prepare( &mut self, ) -> Result<PreparedResult, DistributedReadAssemblyError>

Validate all terminal acknowledgements and atomically materialize the final result. On every error, coordinator-owned payloads are discarded.

pub fn open_prepared_stream( &self, ) -> Result<PreparedResultStream, DistributedReadAssemblyError>

pub fn terminal_status(&self) -> AssemblerTerminalStatus

pub fn close(&mut self)

Idempotently discard preparation and prepared-result state.