Struct ResultAggregator 

pub struct ResultAggregator { /* private fields */ }

Bounded completion-receipt result store.

Implementations

impl ResultAggregator

pub fn new() -> Self

pub fn with_limits(limits: ResultLimits) -> Result<Self, DistributedError>

pub fn store_result( &self, expected_revision: u64, receipt: &CompletionReceipt, bytes: Vec<u8>, ) -> Result<Transition<StoreResultOutcome>, DistributedError>

Store a result only with a completion receipt. Exact same-byte replay is idempotent; a different receipt or bytes for an occupied task ID fails. Receipt provenance remains scoped to the caller-enforced coordinator epoch.

pub fn aggregate_results( &self, task_ids: &[&str], ) -> Result<Vec<AggregatedResult>, DistributedError>

Aggregate all requested results in exact input order. Missing or repeated task IDs are explicit errors rather than silent filtering.

pub fn get_result( &self, task_id: &str, ) -> Result<Option<Vec<u8>>, DistributedError>

pub fn revision(&self) -> Result<u64, DistributedError>

pub fn result_count(&self) -> Result<usize, DistributedError>

pub fn total_bytes(&self) -> Result<usize, DistributedError>

Trait Implementations

impl Clone for ResultAggregator

fn clone(&self) -> ResultAggregator

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for ResultAggregator

fn default() -> Self

Returns the “default value” for a type.