export type ConnectedKnowledgePipelineOptions = {
    agentId: string;
    workspaceId: string;
    workerId?: string;
    batchSize?: number;
};
export type KnowledgeSynthesisBatchResult = {
    claimed: number;
    completed: number;
    ignored: number;
    failed: number;
    recordIds: string[];
};
export type ConnectedKnowledgePruneResult = {
    rawDeleted: number;
    derivedDeleted: number;
};
export declare class ConnectedKnowledgePipeline {
    private readonly options;
    private readonly workerId;
    private readonly batchSize;
    constructor(options: ConnectedKnowledgePipelineOptions);
    processPending(sourceInstanceId?: string): Promise<KnowledgeSynthesisBatchResult>;
    pruneBoundedRetention(sourceInstanceId: string, olderThanMs: number): ConnectedKnowledgePruneResult;
}