Skip to main content

InMemoryIdempotencyStore

@rotorsoft/act-root

@rotorsoft/act-root / act-ops/src/idempotency / InMemoryIdempotencyStore

Class: InMemoryIdempotencyStore

Defined in: libs/act-ops/src/idempotency/in-memory.ts:49

Bounded LRU + TTL implementation of IdempotencyStore for single-process receivers (the wolfdesk demo, integration tests, dev loops). Multi-process receivers should swap for a durable adapter (Postgres unique index, Redis SET NX) — the IdempotencyStore contract stays the same so the call site doesn't change.

Map iteration is insertion-ordered, so:

  • The oldest entry sits at keys().next().value (cheapest to evict).
  • GC walks until the first non-expired entry and stops.

claim is sync; durable adapters return a Promise<boolean> — both satisfy the union return type in the port.

Implements​

Constructors​

Constructor​

new InMemoryIdempotencyStore(options?): InMemoryIdempotencyStore

Defined in: libs/act-ops/src/idempotency/in-memory.ts:54

Parameters​

options?​

InMemoryIdempotencyStoreOptions

Returns​

InMemoryIdempotencyStore

Methods​

claim()​

claim(key, now?): boolean

Defined in: libs/act-ops/src/idempotency/in-memory.ts:63

Atomically claim key for this caller. Returns true if the caller won the claim (the key was fresh and is now recorded), false if another caller already claimed it — the request should be treated as a duplicate.

now is exposed for tests; production callers should leave it undefined so wall-clock is used.

Parameters​

key​

string

now?​

number = ...

Returns​

boolean

Implementation of​

IdempotencyStore.claim

clear()​

clear(): void

Defined in: libs/act-ops/src/idempotency/in-memory.ts:83

Drop every entry — test hook.

Returns​

void

size()​

size(now?): number

Defined in: libs/act-ops/src/idempotency/in-memory.ts:77

Number of entries currently tracked (post-GC at call time).

Parameters​

now?​

number = ...

Returns​

number