import { WebSocketServer } from './WebSocketServer';
import { SubconsciousEngine } from './SubconsciousEngine';
import { OrchestrationMetrics } from '../types';
/**
 * Orchestration Engine
 * Integrates WebSocket Server and Subconscious Engine
 * Implements the complete request flow: Request → Semantic Check → Route/Cache → Response
 */
export declare class OrchestrationEngine {
    private wsServer;
    private subconsciousEngine;
    private dashboardWebSocket;
    private metrics;
    private requestLatencies;
    private taskRequestors;
    private taskDescriptions;
    private dashboardBroadcaster;
    private connectedAgents;
    constructor(wsServer: WebSocketServer, subconsciousEngine: SubconsciousEngine);
    /**
     * Set dashboard broadcaster reference
     */
    setDashboardBroadcaster(broadcaster: any): void;
    /**
     * Link the Dashboard WebSocket server so we can emit dashboard-specific events
     */
    setDashboardWebSocket(server: any): void;
    /**
     * Get all connected agents
     */
    getConnectedAgents(): any[];
    /**
     * Setup event handlers for WebSocket server
     */
    private setupEventHandlers;
    /**
     * Handle incoming message from agent
     */
    private handleMessage;
    /**
     * Handle agent handshake
     */
    private handleHandshake;
    /**
     * Handle task request with semantic short-circuiting
     */
    private handleTaskRequest;
    /**
     * Handle task response from agent and cache it
     */
    private handleTaskResponse;
    /**
     * Handle agent discovery request
     */
    private handleDiscover;
    /**
     * Handle ping message
     */
    private handlePing;
    /**
     * Find agent with required capabilities
     */
    private findCapableAgent;
    /**
     * Check if message is dashboard-specific
     */
    private isDashboardMessage;
    /**
     * Validate IAP message structure
     */
    private isValidIAPMessage;
    /**
     * Send message to connection
     */
    private sendMessage;
    /**
     * Send error message
     */
    private sendError;
    /**
     * Record request latency
     */
    private recordLatency;
    /**
     * Get orchestration metrics
     */
    getMetrics(): OrchestrationMetrics & {
        cacheStats: any;
    };
    /**
     * Print metrics summary
     */
    printMetrics(): void;
    /**
     * Reset all metrics (for cache clear)
     */
    resetMetrics(): void;
    /**
     * Pause agent processing
     */
    pauseProcessing(): void;
    /**
     * Resume agent processing
     */
    resumeProcessing(): void;
}
//# sourceMappingURL=OrchestrationEngine.d.ts.map