/**
 * Workflow Executor - Executes workflow definitions
 */
import { EventEmitter } from 'events';
import { Workflow, OrchestrationSession, LogLevel } from './types';
import { TerminalRegistry } from '../terminal/registry';
import { DependencyResolver } from '../resolver/dependency-resolver';
import { ContextStore } from '../context/context-store';
/**
 * Workflow executor configuration
 */
export interface WorkflowExecutorConfig {
    maxParallelTasks: number;
    stageTimeout: number;
    taskTimeout: number;
    checkpointInterval: number;
    enableCheckpoints: boolean;
    enableMetrics: boolean;
    enableLogging: boolean;
    logLevel: LogLevel;
}
/**
 * Workflow Executor
 */
export declare class WorkflowExecutor extends EventEmitter {
    private config;
    private sessions;
    private terminalRegistry;
    private dependencyResolver;
    private contextStore;
    private checkpointTimers;
    private executionTimers;
    private logger;
    constructor(terminalRegistry: TerminalRegistry, dependencyResolver: DependencyResolver, contextStore: ContextStore, config?: Partial<WorkflowExecutorConfig>);
    /**
     * Execute workflow
     */
    executeWorkflow(workflow: Workflow, context?: Map<string, any>): Promise<OrchestrationSession>;
    /**
     * Create execution plan
     */
    private createExecutionPlan;
    /**
     * Execute stages
     */
    private executeStages;
    /**
     * Execute stage
     */
    private executeStage;
    /**
     * Execute tasks in parallel
     */
    private executeParallelTasks;
    /**
     * Execute tasks sequentially
     */
    private executeSequentialTasks;
    /**
     * Execute task
     */
    private executeTask;
    /**
     * Select terminal for task
     */
    private selectTerminal;
    /**
     * Prepare task input
     */
    private prepareTaskInput;
    /**
     * Store task output
     */
    private storeTaskOutput;
    /**
     * Execute command on terminal
     */
    private executeCommand;
    /**
     * Query context
     */
    private queryContext;
    /**
     * Update context
     */
    private updateContext;
    /**
     * Wait for condition
     */
    private waitForCondition;
    /**
     * Transform data
     */
    private transformData;
    /**
     * Validate data
     */
    private validateData;
    /**
     * Retry task
     */
    private retryTask;
    /**
     * Evaluate condition
     */
    private evaluateCondition;
    /**
     * Evaluate expression
     */
    private evaluateExpression;
    /**
     * Apply transformation
     */
    private applyTransformation;
    /**
     * Aggregate inputs
     */
    private aggregateInputs;
    /**
     * Find previous terminal
     */
    private findPreviousTerminal;
    /**
     * Calculate critical path
     */
    private calculateCriticalPath;
    /**
     * Calculate stage success rate
     */
    private calculateStageSuccessRate;
    /**
     * Calculate stage retry count
     */
    private calculateStageRetryCount;
    /**
     * Calculate final metrics
     */
    private calculateFinalMetrics;
    /**
     * Initialize metrics
     */
    private initializeMetrics;
    /**
     * Start checkpointing
     */
    private startCheckpointing;
    /**
     * Stop checkpointing
     */
    private stopCheckpointing;
    /**
     * Create checkpoint
     */
    private createCheckpoint;
    /**
     * Clear execution timers
     */
    private clearExecutionTimers;
    /**
     * Log message
     */
    private log;
    /**
     * Emit orchestration event
     */
    private emitEvent;
    /**
     * Get session
     */
    getSession(sessionId: string): OrchestrationSession | undefined;
    /**
     * Cancel session
     */
    cancelSession(sessionId: string): Promise<void>;
    /**
     * Clean up
     */
    destroy(): void;
}
//# sourceMappingURL=workflow-executor.d.ts.map