Struct ResultGroup 

pub struct ResultGroup { /* private fields */ }

An aggregated set of child task results for a group or chord header.

The group preserves child registration order so that ResultGroup::collected_values and ResultGroup::results return values in a deterministic, caller-meaningful order.

Implementations

impl ResultGroup

pub fn new(group_id: TaskId, children: Vec<TaskId>) -> Self

Create a new result group for group_id with the given child task ids, in order. Duplicate ids are de-duplicated while preserving the first occurrence’s position.

pub fn empty(group_id: TaskId) -> Self

Create an empty result group with no children yet registered.

pub fn group_id(&self) -> TaskId

The group / chord identifier.

pub fn child_ids(&self) -> &[TaskId]

The child task ids in registration order.

pub fn len(&self) -> usize

Number of registered children.

pub fn is_empty(&self) -> bool

Returns true if no children are registered.

pub fn add_child(&mut self, task_id: TaskId)

Register an additional child task id, appended to the end of the order.

No-op if the child is already registered (order is preserved).

pub fn add_child_with_result( &mut self, task_id: TaskId, result: TaskResultValue, )

Register an additional child together with its result.

pub fn set_result(&mut self, task_id: TaskId, result: TaskResultValue)

Set (or replace) the latest result for a child.

If the child was not previously registered it is appended to the ordering so its value still participates in collection.

pub fn result_for(&self, task_id: TaskId) -> Option<&TaskResultValue>

Borrow the latest result for a specific child, if reported.

pub fn children(&self) -> Vec<GroupChild>

Build a snapshot of all children (with their results) in order.

pub fn reported_count(&self) -> usize

Number of children that have reported any result (terminal or not).

pub fn completed_count(&self) -> usize

Number of children that have reached a terminal/ready state.

pub fn successful_count(&self) -> usize

Number of children that succeeded.

pub fn failed_count(&self) -> usize

Number of children that failed or were rejected.

pub fn revoked_count(&self) -> usize

Number of children that were revoked.

pub fn completion_ratio(&self) -> f64

Fraction of children that are complete, in [0.0, 1.0].

An empty group is considered fully complete (1.0).

pub fn ready(&self) -> bool

Returns true if all registered children are terminal (ready).

An empty group is trivially ready.

pub fn successful(&self) -> bool

Returns true if the group is ready and every child succeeded.

pub fn failed(&self) -> bool

Returns true if the group is ready and at least one child did not succeed (failed, revoked, or rejected).

pub fn status(&self) -> GroupStatus

Compute the aggregate GroupStatus (readiness + success/failure rollup).

pub fn results(&self) -> Vec<Option<TaskResultValue>>

The ordered list of latest results, one entry per registered child in registration order. Children that have not reported are None.

pub fn collected_values(&self) -> Option<Vec<Value>>

The ordered collected success values.

• Returns Some(values) (in registration order) only if the group is ready and every child succeeded.
• Returns None if the group is not yet ready or any child did not produce a success value — mirroring the semantics of a chord header, which only fires when all members succeed.

pub fn successful_values(&self) -> Vec<Value>

Collect the success values of the children that did succeed, ignoring the rest, in registration order. Unlike Self::collected_values this never returns None and is useful for partial / best-effort rollups.

pub fn error_messages(&self) -> Vec<String>

Collect the error messages of all non-successful children, in registration order.

Trait Implementations

impl Clone for ResultGroup

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ResultGroup

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

Formats the value using the given formatter.