import type { DKGAgent } from '@origintrail-official/dkg-agent'; export interface CatchupJobResult { connectedPeers: number; syncCapablePeers: number; peersTried: number; /** * Subset of `peersTried` whose per-peer sync round finished without a * transport failure AND without an explicit ACL denial. Used by the * daemon subscribe job to map the terminal status: `peersTried > 0 * && peersSucceeded === 0 && !denied` → `unreachable` (curator * offline / no peer holds this CG / network couldn't deliver), * distinct from `denied` (curator actively refused). */ peersSucceeded: number; dataSynced: number; sharedMemorySynced: number; denied: boolean; deniedPeers: number; diagnostics?: { noProtocolPeers: number; durable: { fetchedMetaTriples: number; fetchedDataTriples: number; insertedMetaTriples: number; insertedDataTriples: number; bytesReceived: number; resumedPhases: number; emptyResponses: number; metaOnlyResponses: number; dataRejectedMissingMeta: number; rejectedKcs: number; failedPeers: number; }; sharedMemory: { fetchedMetaTriples: number; fetchedDataTriples: number; insertedMetaTriples: number; insertedDataTriples: number; bytesReceived: number; resumedPhases: number; emptyResponses: number; droppedDataTriples: number; failedPeers: number; }; }; } export interface CatchupRunRequest { contextGraphId: string; includeSharedMemory: boolean; } export interface CatchupRunner { run(request: CatchupRunRequest): Promise; close(): Promise; } export declare function createCatchupRunner(agent: DKGAgent): CatchupRunner; export declare function createInlineCatchupRunner(agent: DKGAgent): CatchupRunner; //# sourceMappingURL=catchup-runner.d.ts.map