import type { DatasetOrchestrationRepository } from "./orchestration-repository.js";
import { type CapabilityProfile, type ProcessingPlan } from "./types.js";
import { type DatasetOrchestrationDependencies, type DatasetResult, type RegisteredSource } from "./orchestration-types.js";
export declare class DatasetOrchestrationError extends Error {
    readonly code: string;
    readonly boundary: DatasetResult["diagnostics"][number]["boundary"];
    readonly retryable: boolean;
    constructor(code: string, message: string, boundary?: DatasetResult["diagnostics"][number]["boundary"], retryable?: boolean);
}
export declare class DatasetOrchestrationService {
    private readonly repo;
    private readonly deps;
    constructor(repo: DatasetOrchestrationRepository, deps: DatasetOrchestrationDependencies);
    private now;
    private offlineRemote;
    source(source: RegisteredSource): Promise<DatasetResult<unknown>>;
    private context;
    check(id: string, offline?: boolean): Promise<DatasetResult<unknown>>;
    preview(id: string, count?: number, offline?: boolean, signal?: AbortSignal): Promise<DatasetResult<unknown>>;
    plan(input: {
        id: string;
        sourceId: string;
        profile: CapabilityProfile;
        schemas: ProcessingPlan["schemas"];
        policy: ProcessingPlan["policy"];
        backend?: "local" | "fortemi-core";
        fallback?: "local";
        estimates?: ProcessingPlan["estimates"];
        approvals?: ProcessingPlan["approvals"];
        reconciliation?: ProcessingPlan["reconciliation"];
        steps: ProcessingPlan["steps"];
        artifactClasses: ProcessingPlan["artifactClasses"];
        createdBy: string;
        offline?: boolean;
    }): Promise<DatasetResult<unknown>>;
    ingest(input: {
        planId: string;
        planDigest: string;
        idempotencyKey: string;
        approvalIds?: string[];
        reconciliationApproval?: {
            previewDigest: string;
            threshold: number;
        };
        signal?: AbortSignal;
    }): Promise<DatasetResult<unknown>>;
    status(runId: string): Promise<DatasetResult<unknown>>;
    show(id: string): Promise<DatasetResult<unknown>>;
    verify(runId: string): Promise<DatasetResult<unknown>>;
    query(artifactId: string): Promise<DatasetResult<unknown>>;
    lineage(runId: string): Promise<DatasetResult<unknown>>;
    export(artifactId: string): Promise<DatasetResult<unknown>>;
    cancel(runId: string): Promise<DatasetResult<unknown>>;
    retry(runId: string, signal?: AbortSignal): Promise<DatasetResult<unknown>>;
}
//# sourceMappingURL=orchestration-service.d.ts.map