Skip to content
pgxsinkit

EventStreamFlushOptions

Defined in: packages/client/src/event-lane.ts:78

Per-Event-stream flush overrides (ADR-0053 consequences: cadence is client config, never registry).

Properties

Section titled “Properties”

backoff?

Section titled “backoff?”

optional backoff?: EventBackoffOptions

Defined in: packages/client/src/event-lane.ts:91

Backoff tuning for THIS stream’s deferred rows (e.g. a stream mid-rollout wanting a shorter retry).

batchSize?

Section titled “batchSize?”

optional batchSize?: number

Defined in: packages/client/src/event-lane.ts:89

Cap on how many events of THIS Event stream ride one batch. The lane assembles one mixed batch ordered by seq across every stream, so this is the knob that stops one chatty stream from filling every batch ahead of a quieter one. Absent → only the batch-wide EventLaneOptions.batchSize applies.

The cap is applied IN the selection query (each stream’s eligible rows are ranked by seq and the over-cap ones dropped BEFORE the global order/limit), so it genuinely yields the batch slots it frees to other streams rather than just shrinking the request. Must be an integer >= 1 — a 0/negative/NaN cap would hold every row of the stream back forever, so it is refused at construction.