/**
 * High-Performance Time Series Ingestion Engine
 *
 * Handles ingestion of time series data at scale with features like:
 * - Batch processing and streaming ingestion
 * - Write-ahead logging for durability
 * - Deduplication and validation
 * - Protocol adapters (Prometheus, InfluxDB, StatsD)
 * - Backpressure handling
 * - Real-time metrics and monitoring
 */
import type { TimeSeriesPoint } from '../../../types/timeseries';
import type { IngestionEngine, IngestionConfig, StreamOptions, IngestionStats, TimeSeriesStorageAdapter } from '../interfaces';
export declare class TimeSeriesIngestionEngine implements IngestionEngine {
    private config;
    private storageAdapter;
    private writeBuffer;
    private flushTimer;
    private stats;
    private writeAheadLog;
    private deduplicationCache;
    private pendingBatches;
    constructor(config: IngestionConfig, storageAdapter: TimeSeriesStorageAdapter);
    private initializeStats;
    private startFlushTimer;
    writePoint(point: TimeSeriesPoint): Promise<void>;
    writeBatch(points: TimeSeriesPoint[]): Promise<void>;
    createWriteStream(): WritableStream<TimeSeriesPoint>;
    createIngestionStream(options?: StreamOptions): Promise<WritableStream<TimeSeriesPoint>>;
    writePrometheusMetrics(metrics: string): Promise<void>;
    writeInfluxDBLine(line: string): Promise<void>;
    writeStatsD(metric: string): Promise<void>;
    getIngestionStats(): Promise<IngestionStats>;
    private validatePoint;
    private isDuplicate;
    private generatePointKey;
    private flushBuffer;
    private processBatch;
    private updateBufferUtilization;
    private waitForBatchCapacity;
    private parsePrometheusMetrics;
    private parsePrometheusLine;
    private parseInfluxDBLine;
    private parseInfluxDBSingleLine;
    private parseStatsDMetric;
    close(): Promise<void>;
}
//# sourceMappingURL=ingestion-engine.d.ts.map