import { GreprApiClient } from './api-client.js';
import { FormattableCommandOptions } from '../types.js';
import { SchemaCreateJob } from '../openapi/openApiTypes.js';
/**
 * Utility class for executing streaming jobs
 * Can be used by both BaseCommand and JobCrudCommand for synchronous job execution
 */
export declare class StreamingJobExecutor {
    private formatter;
    private apiClient;
    private heartbeatManager;
    private streamParser;
    private outputFileStream;
    private outputFileError;
    private completionStarted;
    private stats;
    private showJobState;
    constructor();
    /**
     * Execute a streaming job
     */
    execute(jobDefinition: SchemaCreateJob, options: FormattableCommandOptions): Promise<void>;
    private resolveFormat;
    private setupFormatter;
    private setupEventHandlers;
    private completeJob;
    private handleJobCompletion;
    private handleError;
    private setupGracefulShutdown;
    private printFinalState;
    /**
     * Exit only after queued stdout/stderr writes have reached their destination.
     * process.stdout is asynchronous when piped, so exiting straight after a write
     * truncates whatever the consumer has not read yet.
     */
    private exitAfterFlush;
    private flushStream;
    private createOutputFileStream;
    private writeOutput;
    private closeOutputFileStream;
    private formatDuration;
    createApiClient(options: FormattableCommandOptions): GreprApiClient;
    private initializeComponents;
    private processJobStream;
}
//# sourceMappingURL=streaming-job-executor.d.ts.map