Skip to content

GrpcClientActorSettings

Defined in: src/io/broker/GrpcClientActor.ts:25

Common settings every broker actor accepts on top of its protocol- specific options. Subclasses extend this interface with their own required fields (e.g. brokerUrl, topics).

readonly optional circuitBreaker?: object

Defined in: src/io/broker/BrokerSettings.ts:28

Optional circuit-breaker around connectImpl. After failureThreshold consecutive failed connect attempts the breaker opens for resetMs and rejects new attempts immediately.

readonly failureThreshold: number

readonly resetMs: number

BrokerCommonSettings.circuitBreaker


readonly optional credentials?: GrpcCredentials

Defined in: src/io/broker/GrpcClientActor.ts:34


readonly optional deadlineMs?: number

Defined in: src/io/broker/GrpcClientActor.ts:36

Per-call deadline in ms. Default 30_000.


readonly optional endpoint?: string

Defined in: src/io/broker/GrpcClientActor.ts:33

Server endpoint ('host:port').


readonly optional outboundBuffer?: number

Defined in: src/io/broker/BrokerSettings.ts:41

Maximum number of outbound messages buffered while the connection is connecting or disconnected. When the buffer is full the oldest message is dropped (FIFO eviction) and a BrokerBufferOverflow event is published. Default: 1000. Set to 0 to fail-fast (publish a BrokerNotConnected event and drop the message).

BrokerCommonSettings.outboundBuffer


readonly optional packageName?: string

Defined in: src/io/broker/GrpcClientActor.ts:29

gRPC package name ('sensor.v1').


readonly optional protoPath?: string | readonly string[]

Defined in: src/io/broker/GrpcClientActor.ts:27

Path to the .proto file (or array of paths).


readonly optional reconnect?: false | { factor?: number; initialDelayMs?: number; maxAttempts?: number; maxDelayMs?: number; }

Defined in: src/io/broker/BrokerSettings.ts:15

Reconnect strategy applied when the underlying connection drops or connectImpl throws. Default: exponential backoff starting at 200ms, doubling, capped at 30s, infinite attempts. Set to false to disable auto-reconnect (one-shot connections).

false


{ factor?: number; initialDelayMs?: number; maxAttempts?: number; maxDelayMs?: number; }

readonly optional factor?: number

readonly optional initialDelayMs?: number

readonly optional maxAttempts?: number

Cap on retry attempts. Default: Infinity (retry forever).

readonly optional maxDelayMs?: number

BrokerCommonSettings.reconnect


readonly optional serviceName?: string

Defined in: src/io/broker/GrpcClientActor.ts:31

Service name ('SensorService').