ralph-agent-loop 0.4.0

A Rust CLI for managing AI agent loops with a structured JSON task queue
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61

//! Parallel run statistics aggregation.
//!
//! Responsibilities:
//! - Track attempted, succeeded, and failed worker counts for one parallel run.
//! - Provide a small, intention-revealing API instead of threading raw counters through helpers.
//!
//! Not handled here:
//! - Worker state persistence.
//! - Notification or webhook delivery.
//!
//! Invariants/assumptions:
//! - Each finished worker records exactly one terminal outcome.

#[derive(Debug, Clone, Default)]
pub(super) struct ParallelRunStats {
    attempted: usize,
    succeeded: usize,
    failed: usize,
}

impl ParallelRunStats {
    pub(super) fn record_success(&mut self) {
        self.attempted += 1;
        self.succeeded += 1;
    }

    pub(super) fn record_failure(&mut self) {
        self.attempted += 1;
        self.failed += 1;
    }

    pub(super) fn attempted(&self) -> usize {
        self.attempted
    }

    pub(super) fn succeeded(&self) -> usize {
        self.succeeded
    }

    pub(super) fn failed(&self) -> usize {
        self.failed
    }
}

#[cfg(test)]
mod tests {
    use super::ParallelRunStats;

    #[test]
    fn stats_accumulate_successes_and_failures() {
        let mut stats = ParallelRunStats::default();

        stats.record_success();
        stats.record_failure();
        stats.record_success();

        assert_eq!(stats.attempted(), 3);
        assert_eq!(stats.succeeded(), 2);
        assert_eq!(stats.failed(), 1);
    }
}