/** * Dashboard WebSocket Server * Real-time event streaming for dashboard using Socket.io * Emits metrics, agent updates, and cache events */ import { Server as SocketIOServer } from 'socket.io'; import http from 'http'; import { OrchestrationEngine } from './OrchestrationEngine'; export declare class DashboardWebSocketServer { private io; private orchestrationEngine; private server; private broadcastInterval; private port; private eventLog; constructor(httpServer: http.Server, port?: number); /** * Setup Socket.io event handlers */ private setupHandlers; /** * Set orchestration engine reference */ setOrchestrationEngine(engine: OrchestrationEngine): void; /** * Start broadcasting metrics */ startBroadcasting(intervalMs?: number): void; /** * Stop broadcasting */ stopBroadcasting(): void; /** * Emit agent joined event */ emitAgentJoined(agentId: string, agentName: string, capabilities: string[]): void; /** * Emit agent left event */ emitAgentLeft(agentId: string): void; /** * Emit agent error event */ emitAgentError(agentId: string, errorMessage: string): void; /** * Emit cache hit event */ emitCacheHit(queryHash: string, latency: number, tokensSaved: number, costSaved: number): void; /** * Emit cache miss event */ emitCacheMiss(queryHash: string, latency: number): void; /** * Get event log (keep last 1000 events) */ getEventLog(): any[]; /** * Log event internally */ private logEvent; /** * Clear event log */ clearEventLog(): void; /** * Get Socket.io instance */ getIO(): SocketIOServer; } //# sourceMappingURL=DashboardWebSocketServer.d.ts.map