/// <reference types="node" />
/// <reference types="node" />
import EventEmitter from 'events';
import { ClientApi } from './openapi';
import { Options, APIConfiguration } from './types';
import { Repository } from './repository';
export declare class StreamProcessor {
    static readonly CONNECTED = 1;
    static readonly RETRYING = 2;
    static readonly CLOSED = 3;
    static readonly SSE_TIMEOUT_MS = 30000;
    private readonly apiKey;
    private readonly jwtToken;
    private readonly environment;
    private readonly cluster;
    private readonly api;
    private readonly apiConfiguration;
    private readonly repository;
    private readonly retryDelayMs;
    private readonly headers;
    private readonly httpsCa;
    private options;
    private request;
    private eventBus;
    private readyState;
    private log;
    private retryAttempt;
    private retryTimeout;
    constructor(api: ClientApi, apiKey: string, apiConfiguration: APIConfiguration, environment: string, jwtToken: string, options: Options, cluster: string, eventBus: EventEmitter, repository: Repository, headers: Record<string, string>, httpsCa: Buffer);
    start(): void;
    private getRandomRetryDelayMs;
    private cleanupConnection;
    private connect;
    private processData;
    private processLine;
    private msgProcessor;
    connected(): boolean;
    close(): void;
}