import type { DatabaseSync } from 'node:sqlite';
import type { KnowledgeSourceChange, KnowledgeSourceItem, KnowledgeSourceItemInput, KnowledgeSyncRun, KnowledgeSyncRunStatus, KnowledgeSynthesisPipeline, KnowledgeSynthesisStatus } from '../../knowledge/types.js';
import type { MemoryEvidence, MemoryEvidenceRelation } from '../../agent/memory/types.js';
export declare function startKnowledgeSyncRun(input: {
    sourceInstanceId: string;
    cursorBefore?: string;
    nowMs?: number;
}): KnowledgeSyncRun;
export declare function finishKnowledgeSyncRun(input: {
    runId: string;
    status: Exclude<KnowledgeSyncRunStatus, 'running'>;
    cursorAfter?: string;
    itemsSeen?: number;
    itemsCreated?: number;
    itemsUpdated?: number;
    warnings?: string[];
    error?: string;
    nowMs?: number;
}): KnowledgeSyncRun;
export declare function listKnowledgeSyncRuns(options?: {
    sourceInstanceId?: string;
    status?: KnowledgeSyncRunStatus;
    limit?: number;
}): KnowledgeSyncRun[];
export declare function getKnowledgeSourceCursor(sourceInstanceId: string, collectionScope: string): string | undefined;
export declare function setKnowledgeSourceCursor(sourceInstanceId: string, collectionScope: string, cursor: string | undefined): void;
export declare function upsertKnowledgeSourceItems(inputs: KnowledgeSourceItemInput[], nowMs?: number): {
    items: KnowledgeSourceItem[];
    created: number;
    updated: number;
    unchanged: number;
};
export declare function getKnowledgeSourceItem(itemId: string): KnowledgeSourceItem | null;
export declare function listKnowledgeSourceChanges(options?: {
    sourceInstanceId?: string;
    afterSequence?: number;
    limit?: number;
}): KnowledgeSourceChange[];
export declare function getKnowledgeConsumerWatermark(consumerId: string, sourceInstanceId: string): number;
export declare function setKnowledgeConsumerWatermark(consumerId: string, sourceInstanceId: string, sequence: number, nowMs?: number): void;
export declare function listKnowledgeSourceItems(options?: {
    sourceInstanceId?: string;
    collectionScope?: string;
    itemType?: string;
    synthesisStatus?: KnowledgeSynthesisStatus;
    occurredAfterMs?: number;
    occurredBeforeMs?: number;
    orderBy?: 'recency_desc' | 'occurred_asc';
    includeDeleted?: boolean;
    limit?: number;
    offset?: number;
}): KnowledgeSourceItem[];
export declare function pruneBoundedKnowledgeSourceItems(sourceInstanceId: string, olderThanMs: number): number;
export declare function setKnowledgeSourceItemSynthesisStatus(itemIds: string[], status: KnowledgeSynthesisStatus, nowMs?: number): number;
export declare function claimKnowledgeSourceItems(options: {
    workerId: string;
    sourceInstanceId?: string;
    synthesisPipeline?: KnowledgeSynthesisPipeline;
    limit?: number;
    leaseMs?: number;
    retryDelayMs?: number;
    maxAttempts?: number;
    nowMs?: number;
}): KnowledgeSourceItem[];
export declare function completeKnowledgeSourceItemSynthesis(input: {
    itemId: string;
    workerId: string;
    status: 'completed' | 'failed' | 'ignored';
    error?: string;
    nowMs?: number;
}): boolean;
export interface AttachMemoryEvidenceInput {
    recordId: string;
    sourceItemId?: string;
    relation?: MemoryEvidenceRelation;
    excerpt?: string;
    confidence?: number;
    observedAt?: string;
    sessionKey?: string;
    turnId?: string;
    toolCallId?: string;
    nowMs?: number;
}
export declare function attachMemoryEvidence(input: AttachMemoryEvidenceInput): MemoryEvidence;
export declare function replaceMemoryEvidenceForRecord(db: DatabaseSync, recordId: string, evidence: MemoryEvidence[], nowMs?: number): void;
export declare function deleteMemoryEvidenceForRecord(recordId: string, relation?: MemoryEvidenceRelation): number;
export declare function listMemoryEvidence(recordId: string): MemoryEvidence[];
export declare function listMemoryEvidenceForRecords(recordIds: string[]): Map<string, MemoryEvidence[]>;