import type { CompileKnowledgeSourceInput, CompiledKnowledgeSource } from './knowledge-compiler.js';
import type { KnowledgeStore } from './knowledge-store.js';
import type { SourceCatalog } from './source-catalog.js';
import { type ProviderExecutionReceiptV1 } from '@devflow-tools/sdk';
export interface KnowledgeDurableQueue {
    enqueueWork(input: {
        idempotencyKey: string;
        kind: 'knowledge.ingest';
        projectRoot: string;
        sourceHash: string;
        taskSpecHash?: string;
        payload: Record<string, unknown>;
    }): {
        id: string;
        maxAttempts: number;
        sourceHash?: string;
        taskSpecHash?: string;
    };
    acquireProjectMutationLease(input: {
        projectRoot: string;
        mutationKind: string;
        owner: string;
        leaseMs: number;
        sourceHash?: string;
        now?: number;
    }): boolean;
    releaseProjectMutationLease(projectRoot: string, mutationKind: string, owner: string): boolean;
    cancelStaleWork(input: {
        id: string;
        owner: string;
        sourceHash?: string;
        taskSpecHash?: string;
        reason?: string;
        now?: number;
    }): boolean;
    completeWork(id: string, owner: string, now?: number): boolean;
}
export interface KnowledgeIngestWorkItem {
    id: string;
    state: string;
    leaseOwner?: string;
    sourceHash?: string;
    taskSpecHash?: string;
}
export declare function enqueueKnowledgeIngest(queue: KnowledgeDurableQueue, input: {
    projectRoot: string;
    sourceId: string;
    markdown: string;
    taskSpecHash?: string;
}): {
    id: string;
    sourceHash?: string;
    taskSpecHash?: string;
    maxAttempts: number;
};
export declare function executeKnowledgeIngest(input: {
    queue: KnowledgeDurableQueue;
    store: KnowledgeStore;
    catalog: SourceCatalog;
    item: KnowledgeIngestWorkItem;
    owner: string;
    compile: CompileKnowledgeSourceInput;
    currentSourceHash: string;
    currentTaskSpecHash?: string;
    providerReceipt?: ProviderExecutionReceiptV1;
    providerRequestHash?: string;
    leaseMs?: number;
    now?: number;
    index?: (compiled: CompiledKnowledgeSource) => Promise<Float32Array[] | void>;
}): Promise<{
    status: 'published' | 'cancelled' | 'busy';
    pageId?: string;
    snapshotId?: string;
}>;
//# sourceMappingURL=knowledge-ingest-runtime.d.ts.map