SDK y paquetes@spire/busindexclasses

Class: MemoryReplayStore

Referencia de @spire/bus generada de su TSDoc.

ImplementadoSin versión del tren todavía· generada desde node_modules/@spire/bus/package.json

Página generada desde el TSDoc de @spire/bus. No se edita a mano: bun run docs:gen la regenera y bun run docs:check falla si difiere.

Class: MemoryReplayStore

Implements

Constructors

Constructor

new MemoryReplayStore(opts?): MemoryReplayStore

Parameters

opts?

IReplayOptions = {}

Returns

MemoryReplayStore

Accessors

size

Get Signature

get size(): number

Returns

number

Methods

check()

check(source, idHex, nonceHex, tsMs, nowMs): ReplayResult

Parameters

source

string

idHex

string

nonceHex

string

tsMs

bigint

nowMs

bigint

Returns

ReplayResult

Implementation of

IReplayStore.check


quotaOf()

quotaOf(source): number

Cuota reservada para source (0 si no tiene).

Parameters

source

string

Returns

number


reserve()

reserve(source, rate): void

Parameters

source

string

rate

IReplayRate

Returns

void


reserveAll()

reserveAll(sources, rate): void

Reserva para cada source lo que un rate perSec/burst admite en una ventana; se acumula (una fuente en varias rutas suma cada una). Todas o ninguna: si no caben lanza ReplayBudgetError sin reservar nada. El router la llama al registrar cada ruta con los emisores admitidos.

Parameters

sources

readonly string[]

rate

IReplayRate

Returns

void

Implementation of

IReplayStore.reserveAll