Class TcpConnectionPool

Connection pool for parallel TCP operations Load-aware distribution - prefers connected clients with capacity

Index

Constructors

Methods

addRef close connect getConnectedCount getHealth getPoolSize isClosed isConnected onReconnect release send sendParallel setPoolKey

Constructors

constructor

new TcpConnectionPool(options?: PoolOptions): TcpConnectionPool
Parameters
- options: PoolOptions = {}
Returns TcpConnectionPool
- Defined in client/tcpPool.ts:28

Methods

addRef

addRef(): void
Increment reference count (for shared pools)

Returns void
- Defined in client/tcpPool.ts:155

close

close(): void
Close all connections

Returns void
- Defined in client/tcpPool.ts:173

connect

connect(): Promise<void>
Connect all clients in pool

Returns Promise<void>
- Defined in client/tcpPool.ts:78

getConnectedCount

getConnectedCount(): number
Get number of connected clients

Returns number
- Defined in client/tcpPool.ts:145

getHealth

getHealth(): {
    avgLatencyMs: number;
    clients: ConnectionHealth[];
    connectedCount: number;
    healthy: boolean;
    totalCommands: number;
    totalCount: number;
    totalErrors: number;
}
Get aggregated health metrics for the pool

Returns {
    avgLatencyMs: number;
    clients: ConnectionHealth[];
    connectedCount: number;
    healthy: boolean;
    totalCommands: number;
    totalCount: number;
    totalErrors: number;
}
- Defined in client/tcpPool.ts:193

getPoolSize

getPoolSize(): number
Get pool size

Returns number
- Defined in client/tcpPool.ts:150

isClosed

isClosed(): boolean
Check if pool is closed

Returns boolean
- Defined in client/tcpPool.ts:188

isConnected

isConnected(): boolean
Check if any connection is ready

Returns boolean
- Defined in client/tcpPool.ts:140

onReconnect

onReconnect(cb: () => void): void
Invoke cb whenever a pooled connection (re)establishes. TcpClient emits 'connected' on every successful connect, including reconnects. Used by Worker to re-register after a reconnect (the server drops registration when the registering connection closes and each reconnect gets a fresh clientId).
Parameters
- cb: () => void
Returns void
- Defined in client/tcpPool.ts:133

release

release(): void
Decrement reference count and close if zero

Returns void
- Defined in client/tcpPool.ts:160

send

send(command: Record<string, unknown>): Promise<Record<string, unknown>>
Send command using next available connection
Parameters
- command: Record<string, unknown>
Returns Promise<Record<string, unknown>>
- Defined in client/tcpPool.ts:103

sendParallel

sendParallel(
commands: Record<string, unknown>[],
): Promise<Record<string, unknown>[]>
Send multiple commands in parallel across pool
Parameters
- commands: Record<string, unknown>[]
Returns Promise<Record<string, unknown>[]>
- Defined in client/tcpPool.ts:111

setPoolKey

setPoolKey(key: string): void
Set pool key for shared pool cleanup
Parameters
- key: string
Returns void
- Defined in client/tcpPool.ts:168