import type { Phase, PhaseProgress, SinkConfig, SinkRecord, SinkStats } from './types.js';
type PhaseRunner = (records: SinkRecord[], config: SinkConfig, onProgress?: (progress: PhaseProgress) => void) => Promise<SinkRecord[]>;
/**
 * Register a phase runner. Called by each phase module on import.
 */
export declare function registerPhase(phase: Phase, runner: PhaseRunner): void;
export interface PipelineOptions {
    phases: Phase[];
    config: SinkConfig;
    onProgress?: (phase: Phase, progress: PhaseProgress) => void;
}
/**
 * Run the processing pipeline across specified phases.
 */
export declare function runPipeline(records: SinkRecord[], options: PipelineOptions): Promise<{
    records: SinkRecord[];
    stats: SinkStats;
}>;
export {};