import { Transport } from './transport.js'; import { MCPMessage } from './types.js'; /** * TCP transport implementation for network MCP communication * Compatible with C++ duckdb_mcp TCP mode */ export declare class TCPTransport extends Transport { private host; private port; private socket?; private connected; private buffer; private messageQueue; private waitingResolvers; private reconnectAttempts; private maxReconnectAttempts; private reconnectDelay; private keepAliveInterval?; constructor(host: string, port: number); connect(): Promise; disconnect(): Promise; send(message: MCPMessage): Promise; receive(): AsyncIterator; isConnected(): boolean; /** * Process the input buffer and extract complete messages */ private processBuffer; /** * Start keep-alive mechanism */ private startKeepAlive; /** * Stop keep-alive mechanism */ private stopKeepAlive; /** * Send a ping message to check connection health */ private sendPing; /** * Attempt to reconnect with exponential backoff */ private attemptReconnect; /** * Wait for the next message */ private waitForMessage; /** * Resolve waiting iterators when new messages arrive or connection closes */ private resolveWaitingIterators; /** * Get socket state (for debugging) */ getSocketState(): string; } //# sourceMappingURL=tcp-transport.d.ts.map