Interface: StarterClientOptions
Options for createStarterClient.
The starter applies opinionated defaults on top of ClientOptions,
so every override here is optional except host + port. The
starter-specific addition is handleSignals (mirrors createStarterServer).
Example
const opts: StarterClientOptions = {
host: 'localhost',
port: 2575,
onMessage: (payload) => logger.info({ bytes: payload.length }),
handleSignals: true,
};
Properties
ackTimeoutMs?
readonlyoptionalackTimeoutMs?:number
Override default 30_000.
autoReconnect?
readonlyoptionalautoReconnect?:boolean
Override default true (auto-reconnect on transient errors).
correlateByControlId?
readonlyoptionalcorrelateByControlId?:boolean
Override default false (FIFO mode).
deadPeerTimeoutMs?
readonlyoptionaldeadPeerTimeoutMs?:number
Application-idle dead-peer timeout ms.
drainTimeoutMs?
readonlyoptionaldrainTimeoutMs?:number
Drain timeout for close() (default 30_000).
framing?
readonlyoptionalframing?:Omit<FrameReaderOptions,"onFrame"|"onWarning">
FrameReader options (passthrough).
handleSignals?
readonlyoptionalhandleSignals?:boolean
Register process SIGTERM/SIGINT handlers that close the client. Default
false. When true, SIGTERM/SIGINT both call client.close()
and exit the process. Handlers self-deregister on 'close'.
highWaterMark?
readonlyoptionalhighWaterMark?:HighWaterMark
Override default 64.
host
readonlyhost:string
Host to connect to.
keepaliveIntervalMs?
readonlyoptionalkeepaliveIntervalMs?:number
TCP keepalive interval ms.
onBackpressure?
readonlyoptionalonBackpressure?:"reject"|"wait"
Override default 'reject'.
onMessage?
readonlyoptionalonMessage?: (payload) =>void
Inbound-message callback (any framed payload from the peer, including
non-ACK messages on bidirectional channels). Mirrors the server-side
onMessage ergonomics.
Parameters
payload
Buffer
Returns
void
pipeline?
readonlyoptionalpipeline?:boolean
Override default true (parallel up to highWaterMark).
port
readonlyport:number
TCP port.
retryStrategy?
readonlyoptionalretryStrategy?:RetryStrategy
Custom reconnect-backoff hook.
tls?
readonlyoptionaltls?:true|TlsOptions
Enable TLS (MLLPS) for this connection. Passthrough to ClientOptions.tls.