Classes · @purista/core
InFlightExecutionTracker
Tracks active event bridge handler promises for drain and health reporting.
Signature
class InFlightExecutionTrackerConstructors
1 entry
constructor
Constructor
new constructor()Accessors
1 entry
size
Member
sizeMethods
3 entries
getCounts
Method
getCounts(): EventBridgeInFlightExecutionCountsReturn active execution counts grouped by kind.
run
Method
run<T>(fn: () => Promise<T>, kind: InFlightExecutionKind): Promise<T>Run and track one asynchronous execution.
waitForIdle
Method
waitForIdle(timeoutMs: number): Promise<boolean>Wait until all tracked work settles or the timeout elapses.