Struct StatsResponse 

pub struct StatsResponse {
    pub total_tasks: usize,
    pub total_runs: usize,
    pub attempts_total: u64,
    pub runs_by_state: StatsRunsByState,
    pub latest_sequence: u64,
}

Stats response payload.

This struct represents the stable schema for the stats endpoint response. Fields should not be modified without careful consideration of external dependencies that may rely on this contract.

Fields

total_tasks: usize

Total number of tasks tracked.

This is derived from the authoritative task projection in the storage reducer.

total_runs: usize

Total number of runs tracked.

This is derived from the authoritative run instance projection in the storage reducer.

attempts_total: u64

Total number of attempts across all runs.

This is computed as the sum of RunInstance::attempt_count() from all run instances in the authoritative projection. This provides a count of all attempts that have been started for all runs.

runs_by_state: StatsRunsByState

Counts of runs by state.

Each state is counted from the authoritative run instance state projection. The map is sorted by state name for deterministic output.

latest_sequence: u64

Latest sequence number processed from the WAL.

This reflects the most recent event sequence number applied to the projection state.

Implementations

impl StatsResponse

pub fn from_projection(projection: &ReplayReducer) -> Self

Creates a new stats response from the projection state.

This function derives stats from the authoritative ReplayReducer state, counting runs by their current state. Empty state results in zero counts.

Arguments

• projection - The authoritative projection state from bootstrap

Trait Implementations

impl Clone for StatsResponse

fn clone(&self) -> StatsResponse

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StatsResponse

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

Formats the value using the given formatter.

impl Serialize for StatsResponse

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.