import type { LocalFlatSqlPinLedgerEntry } from './local-flatsql';
export interface PublishedSegmentForSync {
    cid?: string | null;
    rowCount?: number | null;
    index?: number | null;
    byteCount?: number | null;
}
export interface PublishedSegmentSyncItem<T extends PublishedSegmentForSync> {
    segment: T;
    cumulativeRows: number;
    segmentEnd: number;
    skipRecords: 0;
}
export interface PublishedSegmentMaterializedRowCountInput {
    cid?: string | null;
    standardId: string;
    expectedRows?: number | null;
    materializedRows: number;
}
export interface PublishedSegmentCheckpointInput {
    unpersistedBytes: number;
    checkpointBytes: number;
    completedRows: number;
    totalRows: number;
}
export interface PublishedSnapshotResetInput {
    retentionPolicy?: string | null;
    localRows: number;
    completedRows: number;
    totalRows: number;
}
export interface PublishedSnapshotProbeStartStatusInput {
    hasPublishedManifest: boolean;
    currentStatus?: string | null;
}
export interface PublishedSegmentBatchOptions {
    maxBatchBytes: number;
    maxBatchSegments: number;
}
export interface PublishedSegmentBatchItem<T extends PublishedSegmentForSync> {
    items: Array<PublishedSegmentSyncItem<T>>;
    byteCount: number;
    preferredSourceIndex: number;
}
export interface PublishedSegmentRetentionOptions {
    retentionPolicy?: string | null;
    manifestHead?: string | null;
}
export declare function pendingPublishedSegmentItems<T extends PublishedSegmentForSync>(segments: T[], completedCids: ReadonlySet<string>): Array<PublishedSegmentSyncItem<T>>;
export declare function completedPublishedSegmentCids(entries: LocalFlatSqlPinLedgerEntry[]): Set<string>;
export declare function completedPublishedRowsForSegments<T extends PublishedSegmentForSync>(segments: T[], completedCids: ReadonlySet<string>): number;
export declare function assertPublishedSegmentMaterializedRowCount(input: PublishedSegmentMaterializedRowCountInput): void;
export declare function shouldPersistPublishedSegmentCheckpoint(input: PublishedSegmentCheckpointInput): boolean;
export declare function shouldResetPublishedSnapshotStore(input: PublishedSnapshotResetInput): boolean;
export declare function publishedSnapshotProbeStartStatus(input: PublishedSnapshotProbeStartStatusInput): 'synced' | 'syncing';
export declare function publishedSegmentsForRetention<T extends PublishedSegmentForSync & {
    cursor?: string | null;
    nextCursor?: string | null;
    previousHead?: string | null;
    feedHead?: string | null;
}>(segments: T[], options: PublishedSegmentRetentionOptions): T[];
export declare function publishedSegmentBatchItems<T extends PublishedSegmentForSync>(items: Array<PublishedSegmentSyncItem<T>>, options: PublishedSegmentBatchOptions): Array<PublishedSegmentBatchItem<T>>;
//# sourceMappingURL=published-segment-sync.d.ts.map