Classes · @purista/core

InFlightExecutionTracker

Tracks active event bridge handler promises for drain and health reporting.

@purista/core Source

Signature

InFlightExecutionTracker.ts typescript 
class InFlightExecutionTracker

Constructors

1 entry

constructor

Constructor

constructor.ts typescript 
new constructor()

Accessors

1 entry

size

Member

Source
size.ts typescript 
size

Methods

3 entries

getCounts

Method

Source
getCounts.ts typescript 
getCounts(): EventBridgeInFlightExecutionCounts

Return active execution counts grouped by kind.

run

Method

Source
run.ts typescript 
run<T>(fn: () => Promise<T>, kind: InFlightExecutionKind): Promise<T>

Run and track one asynchronous execution.

waitForIdle

Method

Source
waitForIdle.ts typescript 
waitForIdle(timeoutMs: number): Promise<boolean>

Wait until all tracked work settles or the timeout elapses.