Class InMemoryGovernanceReplayStore

Process-local replay store for development and single-process services. Multi-replica production services must supply an atomic shared store.

Implements

GovernanceReplayStore

Index

Constructors

Methods

preload consume

Constructors

constructor

new InMemoryGovernanceReplayStore(
options?: InMemoryGovernanceReplayStoreOptions,
): InMemoryGovernanceReplayStore
Parameters
- options: InMemoryGovernanceReplayStoreOptions = {}
Returns InMemoryGovernanceReplayStore
- Defined in src/lib/governance/authorization.ts:139

Methods

preload

preload(issuer: string, audience: string, jti: string, expiresAt: number): void
Deterministic conformance-test preload.
Parameters
- issuer: string
- audience: string
- jti: string
- expiresAt: number
Returns void
- Defined in src/lib/governance/authorization.ts:148

consume

consume(
    issuer: string,
    audience: string,
    jti: string,
    expiresAt: number,
    now: number,
    binding?: GovernanceReplayBinding,
): Promise<"ok" | "replayed" | "rate_abuse" | "conflict">
Atomically consume one (issuer, audience, jti) tuple. Only one caller may receive ok; concurrent or later consumers receive replayed.
Parameters
- issuer: string
- audience: string
- jti: string
- expiresAt: number
- now: number
- Optionalbinding: GovernanceReplayBinding
Returns Promise<"ok" | "replayed" | "rate_abuse" | "conflict">
Implementation of GovernanceReplayStore.consume
- Defined in src/lib/governance/authorization.ts:153