Package app.ductape.sdk.cloud

Class VpcConnectorTunnelClient

java.lang.Object

app.ductape.sdk.cloud.VpcConnectorTunnelClient

public final class VpcConnectorTunnelClient
extends Object

Opens a TCP-over-WebSocket tunnel to a private VPC host via the Ductape VPC connector relay, then exposes it as a loopback-only local TCP proxy so any plain JDBC driver (which has no custom-stream hook, unlike pg's Pool on the TS side) can connect to it as if it were an ordinary local socket.

Speaks the exact JSON handshake/framing protocol used by sdk/ts/src/cloud/vpc-connector-tunnel.client.ts so the existing backend relay (shared, language-agnostic) needs no changes: stream_open → stream_opened/ stream_error, then stream_data/stream_close with base64-encoded payloads correlated by stream_id.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	VpcConnectorTunnelClient.VpcConnectorTunnelHandle	Live tunnel handle: a stream_id-correlated WebSocket session plus the local loopback TCP proxy that relays bytes to/from it.
static final record	VpcConnectorTunnelClient.VpcConnectorTunnelTarget	Target VPC-private TCP endpoint to relay to, plus the cloud connection tag authorizing it.

Method Summary

Modifier and Type	Method	Description
static VpcConnectorTunnelClient.VpcConnectorTunnelHandle	open(VpcConnectorTunnelClient.VpcConnectorTunnelTarget target, EnvType environment, RequestContext auth)	Opens the relay WebSocket and performs the stream_open → stream_opened handshake.
static VpcConnectorTunnelClient.VpcConnectorTunnelHandle	open(VpcConnectorTunnelClient.VpcConnectorTunnelTarget target, EnvType environment, RequestContext auth, Duration timeout)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

open

public static VpcConnectorTunnelClient.VpcConnectorTunnelHandle open(VpcConnectorTunnelClient.VpcConnectorTunnelTarget target,
 EnvType environment,
 RequestContext auth)

Opens the relay WebSocket and performs the stream_open → stream_opened handshake. Mirrors TS openVpcConnectorTunnelStream.

open

public static VpcConnectorTunnelClient.VpcConnectorTunnelHandle open(VpcConnectorTunnelClient.VpcConnectorTunnelTarget target,
 EnvType environment,
 RequestContext auth,
 Duration timeout)