/** * Daily Index Generation Pipeline (SMI-593) * * Orchestrates the daily skill indexing process across multiple sources. * * @see pipeline-types.ts for type definitions */ import { type ISkillParser, type ISkillRepository } from '../sources/SourceIndexer.js'; export type { PipelineStatus, PipelineSourceConfig, PipelineConfig, PipelineProgress, SourceResult, PipelineResult, PipelineSummary, } from './pipeline-types.js'; import type { PipelineSourceConfig, PipelineConfig, PipelineProgress, PipelineResult } from './pipeline-types.js'; /** * Daily Index Pipeline * * Orchestrates skill indexing across multiple sources with: * - Concurrent source processing * - Progress tracking and callbacks * - Error handling and recovery * - Run state management */ export declare class DailyIndexPipeline { private currentRun; private scorer; get isRunning(): boolean; get currentRunId(): string | null; run(config: PipelineConfig): Promise; cancel(): boolean; getProgress(): PipelineProgress | null; private processSource; private emitProgress; private buildResult; private generateRunId; } export declare function createScheduledPipeline(config: Omit, options: { intervalMs: number; runImmediately?: boolean; onRunComplete?: (result: PipelineResult) => void; }): { start: () => void; stop: () => void; isRunning: () => boolean; getLastResult: () => PipelineResult | null; }; export declare function runDailyIndex(sources: PipelineSourceConfig[], parser: ISkillParser, repository: ISkillRepository, options?: { continueOnError?: boolean; maxConcurrentSources?: number; onProgress?: (progress: PipelineProgress) => void; }): Promise; //# sourceMappingURL=DailyIndexPipeline.d.ts.map