Referencia de @spire/bus generada de su TSDoc.
node_modules/@spire/bus/package.jsonPágina generada desde
el TSDoc de @spire/bus. No se edita a mano:bun run docs:genla regenera ybun run docs:checkfalla si difiere.
Anti-replay compartido entre réplicas (nats): SET key id NX PX ttl
atómico; si ya existía se compara el id guardado.
Sin cuota por fuente: la memoria la acota el TTL en Valkey (la ventana), no un tope local; el allowlist y el rate del router van delante. Una cuota compartida entre réplicas (contador por fuente y ventana) es follow-up.
new ValkeyReplayStore(
client,prefix?,opts?):ValkeyReplayStore
string = 'spire:replay:'
IReplayOptions = {}
ValkeyReplayStore
check(
source,idHex,nonceHex,tsMs,nowMs):Promise<ReplayResult>
string
string
string
bigint
bigint
Promise<ReplayResult>
reserveAll():
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.
void