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).
Extends
Section titled “Extends”Properties
Section titled “Properties”circuitBreaker?
Section titled “circuitBreaker?”
readonlyoptionalcircuitBreaker?: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.
failureThreshold
Section titled “failureThreshold”
readonlyfailureThreshold:number
resetMs
Section titled “resetMs”
readonlyresetMs:number
Inherited from
Section titled “Inherited from”BrokerCommonSettings.circuitBreaker
credentials?
Section titled “credentials?”
readonlyoptionalcredentials?:GrpcCredentials
Defined in: src/io/broker/GrpcClientActor.ts:34
deadlineMs?
Section titled “deadlineMs?”
readonlyoptionaldeadlineMs?:number
Defined in: src/io/broker/GrpcClientActor.ts:36
Per-call deadline in ms. Default 30_000.
endpoint?
Section titled “endpoint?”
readonlyoptionalendpoint?:string
Defined in: src/io/broker/GrpcClientActor.ts:33
Server endpoint ('host:port').
outboundBuffer?
Section titled “outboundBuffer?”
readonlyoptionaloutboundBuffer?: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).
Inherited from
Section titled “Inherited from”BrokerCommonSettings.outboundBuffer
packageName?
Section titled “packageName?”
readonlyoptionalpackageName?:string
Defined in: src/io/broker/GrpcClientActor.ts:29
gRPC package name ('sensor.v1').
protoPath?
Section titled “protoPath?”
readonlyoptionalprotoPath?:string| readonlystring[]
Defined in: src/io/broker/GrpcClientActor.ts:27
Path to the .proto file (or array of paths).
reconnect?
Section titled “reconnect?”
readonlyoptionalreconnect?: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).
Union Members
Section titled “Union Members”false
Type Literal
Section titled “Type Literal”{ factor?: number; initialDelayMs?: number; maxAttempts?: number; maxDelayMs?: number; }
factor?
Section titled “factor?”
readonlyoptionalfactor?:number
initialDelayMs?
Section titled “initialDelayMs?”
readonlyoptionalinitialDelayMs?:number
maxAttempts?
Section titled “maxAttempts?”
readonlyoptionalmaxAttempts?:number
Cap on retry attempts. Default: Infinity (retry forever).
maxDelayMs?
Section titled “maxDelayMs?”
readonlyoptionalmaxDelayMs?:number
Inherited from
Section titled “Inherited from”BrokerCommonSettings.reconnect
serviceName?
Section titled “serviceName?”
readonlyoptionalserviceName?:string
Defined in: src/io/broker/GrpcClientActor.ts:31
Service name ('SensorService').