import { WebSocketServer } from './WebSocketServer.js'; import { OrchestrationEngine } from './OrchestrationEngine.js'; import { IAPMessage } from '../types/index.js'; /** * Dashboard Broadcaster * Handles real-time metrics and state broadcasting to dashboard clients */ export declare class DashboardBroadcaster { private wsServer; private orchestrationEngine; private broadcastInterval; private stateHistory; constructor(wsServer: WebSocketServer, orchestrationEngine: OrchestrationEngine); /** * Start broadcasting metrics to dashboard clients */ start(intervalMs?: number): void; /** * Stop broadcasting */ stop(): void; /** * Setup event listeners for real-time state updates */ private setupEventListeners; /** * Broadcast current metrics to all dashboard clients */ private broadcastMetrics; /** * Broadcast agent connected event */ private broadcastAgentConnected; /** * Broadcast agent disconnected event */ private broadcastAgentDisconnected; /** * Capture state event for time-travel debugging */ private captureStateEvent; /** * Broadcast message to all dashboard clients */ private broadcastToDashboards; /** * Handle dashboard-specific requests */ handleDashboardRequest(connectionId: string, message: IAPMessage): void; /** * Send current metrics to specific connection */ private sendMetrics; /** * Send agents list to specific connection */ private sendAgentsList; /** * Send state history to specific connection */ private sendStateHistory; /** * Get state history */ getStateHistory(): any[]; } //# sourceMappingURL=DashboardBroadcaster.d.ts.map