Struct IncrementalCounts 

pub struct IncrementalCounts { /* private fields */ }

A running tally of the gh records logged since a fixed instant, refreshed by reading only what was appended since the previous refresh.

Equivalent to aggregate over [since, ∞), minus the cost: construction reads no records, and each refresh reads only the complete lines appended after the last one. A line still being written (no trailing newline yet) is left for the next refresh, so a record is counted once, whole. That is the one way the two differ over the same bytes: aggregate counts a final line with no newline if it happens to parse, this waits for the newline.

Implementations

impl IncrementalCounts

pub fn start(path: PathBuf) -> Self

Starts tallying the log at path from now: records already in it are never read, and the tally begins at zero.

The log’s extent is taken before the clock is read. A record stamped at or after since was therefore appended after the baseline, so the bytes the next refresh reads contain every record the window admits. Reading them in the other order could skip a record stamped just after the clock read but appended before the baseline.

pub fn since(&self) -> DateTime<Utc>

The instant the window opened: records stamped before it are not counted.

pub fn counts(&self) -> &GhCounts

The tally as of the last refresh.

pub fn refresh(&mut self, stop: impl FnMut() -> bool) -> bool

Reads the records appended since the last call into the tally.

stop is checked before every line; once it returns true the refresh ends there, leaving the tally and cursor consistent at that line, so the next refresh resumes without losing or repeating anything. It is how a caller on a blocking thread — which cannot be cancelled from outside — gives up on a long read, e.g. the rebuild after the log was replaced.

Returns true when the tally is current as of the last complete line, and false when it may be behind: stop fired, or the log could not be read (logged at debug; best-effort like the rest of the log stack).

Trait Implementations

impl Debug for IncrementalCounts

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

Formats the value using the given formatter.