Struct LoopHistory 

pub struct LoopHistory { /* private fields */ }

Loop history manager for a single loop.

Wraps an append-only JSONL file for recording loop events.

Implementations

impl LoopHistory

pub fn new(path: impl AsRef<Path>) -> Self

Create a new loop history at the given path.

pub fn from_context(context: &LoopContext) -> Self

Create a loop history from a loop context.

pub fn path(&self) -> &Path

Get the path to the history file.

pub fn append(&self, event: HistoryEvent) -> Result<(), HistoryError>

Append an event to the history file.

This is thread-safe via file locking.

pub fn read_all(&self) -> Result<Vec<HistoryEvent>, HistoryError>

Read all events from the history file.

pub fn last_iteration(&self) -> Result<Option<u32>, HistoryError>

Find the last completed iteration number.

Returns None if no iterations have been completed.

pub fn is_completed(&self) -> Result<bool, HistoryError>

Check if the loop completed successfully.

pub fn get_prompt(&self) -> Result<Option<String>, HistoryError>

Get the original prompt that started the loop.

pub fn summary(&self) -> Result<HistorySummary, HistoryError>

Get summary statistics about the loop.

pub fn record_started(&self, prompt: &str) -> Result<(), HistoryError>

Record loop started event.

pub fn record_iteration_started( &self, iteration: u32, ) -> Result<(), HistoryError>

Record iteration started event.

pub fn record_event_published( &self, topic: &str, payload: &str, ) -> Result<(), HistoryError>

Record event published event.

pub fn record_iteration_completed( &self, iteration: u32, success: bool, ) -> Result<(), HistoryError>

Record iteration completed event.

pub fn record_completed(&self, reason: &str) -> Result<(), HistoryError>

Record loop completed event.

pub fn record_resumed(&self, from_iteration: u32) -> Result<(), HistoryError>

Record loop resumed event.

pub fn record_terminated(&self, signal: &str) -> Result<(), HistoryError>

Record loop terminated event.

pub fn record_merge_queued(&self) -> Result<(), HistoryError>

Record merge queued event.

pub fn record_merge_started(&self, pid: u32) -> Result<(), HistoryError>

Record merge started event.

pub fn record_merge_completed(&self, commit: &str) -> Result<(), HistoryError>

Record merge completed event.

pub fn record_merge_failed(&self, reason: &str) -> Result<(), HistoryError>

Record merge failed event.

pub fn record_discarded(&self, reason: &str) -> Result<(), HistoryError>

Record loop discarded event.