import type { IntegrationProgressEvent, IntegrationRunFilter, IntegrationRunSnapshot } from './types.js'; /** * Read API for the progress artifacts. Frontend / health-check / resumption code * uses this to inspect ongoing or completed runs without touching the emitter. * * Implementation is purely file-system reads; no shared state with the emitter * (an emitter in another process can write while this reader tails). */ export declare class IntegrationProgressReader { private readonly rootDir; constructor(rootDir?: string); /** List runs, newest-first by mtime. */ ListRuns(filter?: IntegrationRunFilter, limit?: number): Promise; /** Read snapshot of a single run. Returns undefined if runID not found. */ GetRun(runID: string): Promise; /** Tail events since a given sequence. */ Tail(runID: string, sinceSeq?: number): Promise; /** Find the latest checkpoint for a run (for resumption). */ LatestCheckpoint(runID: string): Promise; /** Find all in-flight (non-terminated) runs — for restart-resumption discovery. */ FindInFlight(): Promise; private safeReadDir; private safeReadFile; private safeReadJSON; private runMtime; private readProgressTail; private countLines; private aggregateCountsFromTail; private aggregateWarningsFromTail; /** Reconstruct a {@link SyncWarning} from a persisted `'warning'` event. */ private warningFromEvent; } //# sourceMappingURL=IntegrationProgressReader.d.ts.map