Struct ReplayBuffer 

pub struct ReplayBuffer { /* private fields */ }

Per-job ring of Events used to replay history when daemon attach targets a finished or in-flight job. Bounded both in jobs tracked (oldest job dropped when full) and in events per job (oldest event per job dropped when full).

Implementations

impl ReplayBuffer

pub fn new(cap_jobs: usize, cap_per_job: usize) -> Self

pub fn start_job(&mut self, job_id: JobId)

Begin a new job’s history. Drops the oldest tracked job if at capacity. Idempotent for repeated JobStarted events on the same id (which shouldn’t happen but we tolerate it).

pub fn append(&mut self, job_id: JobId, ev: Event)

Append an event to the named job’s ring. Silently ignored if the job’s entry has been evicted.

pub fn events_for(&self, job_id: JobId) -> Option<Vec<Event>>