Class InMemoryJobStorage

Shared process-local state; reuse one instance to model multiple workers.

Implements

JobStorage

Index

Constructors

Methods

Constructors

constructor

new InMemoryJobStorage(clock?: () => number): InMemoryJobStorage
Inject a deterministic clock for conformance/recovery tests.
Parameters
- clock: () => number = Date.now
Returns InMemoryJobStorage
- Defined in libs/scheduler/src/memory.ts:18

Methods

atomic

atomic<T>(
action: (transaction: JobStorageTransaction) => Promise<T>,
): Promise<T>
Serialize transactions and restore snapshots on failure. Returned data is detached.
Type Parameters
- T
Parameters
- action: (transaction: JobStorageTransaction) => Promise<T>
Returns Promise<T>
Implementation of JobStorage.atomic
- Defined in libs/scheduler/src/memory.ts:21