import { PipelineConfig, PipeResult, Row } from '../core/index.cjs';
export { AmbiguousProducerError, CardinalityBand, ColumnContext, ColumnProfileLike, ColumnType, CycleError, Decision, DedupeStage, EnableWasmOptions, ExecutionPlan, FindingLike, LoadStage, MIN_CONFIDENCE, ManifestRecordLike, OnError, PipeContext, PipeStatus, PipeWasmBackend, Pipeline, PipelineOptions, PlannedStage, Reporter, Resolver, Router, Runner, ScanStage, Stage, StageInfo, StageRegistry, StageResult, StageSpec, StageStatus, TransformStage, UnknownNeedError, WiringError, buildConfigFromContexts, buildContextsFromCheck, buildDefaultRegistry, classifyByName, defaultRegistry, disableWasm, distinctNonNull, enableWasm, enrichContextsFromFlow, isWasmEnabled, makeColumnContext, makeDecision, makePipeContext, makePipelineConfig, makeStageSpec, normalizeDtype, nullRateOf, piiRouter, rowCountGate, runDf, runStages, severityGate, stage } from '../core/index.cjs';
export { TOOLS as MCP_TOOLS, handleTool as mcpHandleTool, startMcpServer } from './mcp/server.cjs';
export { AGENT_CARD, AgentSkill, StartA2aOptions, runServer as runA2aServer, startA2aServer } from './a2a/server.cjs';
import { createServer } from 'node:http';
import 'goldenmatch/core';

/**
 * Node `run(source)` — load a CSV file into rows and run the pipeline.
 * Port of goldenpipe/_api.run (the file path) + pipeline.py CSV loading.
 *
 * Node-only: reads from the filesystem.
 */

interface RunOptions {
    /** Path to a YAML pipeline config. When set, it wins over the default chain. */
    config?: string | PipelineConfig | undefined;
}
/** Run a pipeline on a CSV file. Zero-config or from a YAML config path. */
declare function run(source: string, options?: RunOptions): Promise<PipeResult>;

/**
 * Minimal CSV reader for the node `run(source)` path.
 * Handles quoted fields, embedded commas, embedded newlines, and "" escapes.
 *
 * Node-only: reads from the filesystem.
 */

/** Parse a CSV string into Row[]. First line is the header. */
declare function parseCsv(content: string): Row[];
/** Read and parse a CSV file. */
declare function readCsv(path: string): Row[];

/**
 * YAML config loading and normalization.
 * Port of goldenpipe/config/loader.py.
 *
 * Node-only: reads a file and parses YAML via the optional `yaml` peer dep.
 */

/** Load and validate a pipeline config from a YAML file path. */
declare function loadConfig(path: string): Promise<PipelineConfig>;
/** Normalize a parsed YAML object into a validated PipelineConfig. */
declare function normalizeConfig(raw: unknown): PipelineConfig;

/**
 * api/server.ts -- GoldenPipe REST API server.
 *
 * Node-only: uses node:http, node:path. NOT edge-safe.
 *
 * Port of goldenpipe/api/server.py (FastAPI). Mirrors the sibling GoldenFlow TS
 * API server for structure. Endpoints:
 *   GET  /health     - liveness probe
 *   GET  /stages     - list registered stages with produces/consumes
 *   POST /validate    - validate pipeline wiring ({ pipeline, stages })
 *   POST /run         - run a pipeline on a CSV ({ source })
 *
 * /stages and /validate delegate to the MCP tool handler; /run calls the
 * file-based `run` directly so the response can include per-stage timing
 * (parity with the Python REST endpoint).
 */

declare function createApp(): ReturnType<typeof createServer>;
declare function runServer(port?: number, host?: string): ReturnType<typeof createServer>;

export { PipeResult, PipelineConfig, Row, type RunOptions, createApp as createApiApp, loadConfig, normalizeConfig, parseCsv, readCsv, run, runServer as runApiServer };