/** * AG-UI Streaming Connector * Handles communication with agents using the AG-UI protocol over SSE */ import type { TrajectoryStep } from '../../../types/index.js'; import type { AGUIEvent } from '../../../types/agui.js'; import { BaseConnector } from '../../../services/connectors/base/BaseConnector.js'; import type { ConnectorAuth, ConnectorRequest, ConnectorResponse, ConnectorProgressCallback, ConnectorRawEventCallback } from '../../../services/connectors/types.js'; import { AgentRequestPayload } from '../../../services/agent/payloadBuilder.js'; /** * AG-UI Streaming Connector * Uses Server-Sent Events (SSE) to stream agent responses in AG-UI format */ export declare class AGUIStreamingConnector extends BaseConnector { readonly type: "agui-streaming"; readonly name = "AG-UI Streaming"; traceContext: { propagateHeader: boolean; }; readonly supportsStreaming = true; /** * Build AG-UI payload from standard request */ buildPayload(request: ConnectorRequest): AgentRequestPayload; /** * Execute the request using SSE streaming */ execute(endpoint: string, request: ConnectorRequest, auth: ConnectorAuth, onProgress?: ConnectorProgressCallback, onRawEvent?: ConnectorRawEventCallback): Promise; /** * Parse raw AG-UI events into trajectory steps * Used for re-processing stored raw events */ parseResponse(rawEvents: AGUIEvent[]): TrajectoryStep[]; /** * Health check for AG-UI endpoint * Tries to connect without sending a full request */ healthCheck(endpoint: string, auth: ConnectorAuth): Promise; } /** * Default instance for convenience */ export declare const aguiStreamingConnector: AGUIStreamingConnector; //# sourceMappingURL=AGUIStreamingConnector.d.ts.map