Graphorin API reference v0.1.0

---

Graphorin API reference / @graphorin/server / / ReplayBuffer

Interface: ReplayBuffer

Defined in: packages/server/src/ws/replay-buffer.ts:45

Per-subject replay buffer. Stores up to maxEvents per subject with a TTL; thread-safe under the single-writer Node event loop model.

Stable

Methods

forget()

forget(subject): void;

Defined in: packages/server/src/ws/replay-buffer.ts:49

Parameters

Parameter	Type
subject	string

Returns

void

---

prune()

prune(): void;

Defined in: packages/server/src/ws/replay-buffer.ts:50

Returns

void

---

push()

push(subject, event): void;

Defined in: packages/server/src/ws/replay-buffer.ts:46

Parameters

Parameter	Type
subject	string
event	{ eventId: string; kind: "event"; payload?: unknown; subject: string; subscriptionId: string; type: string; v: "1"; }
event.eventId	string
event.kind	"event"
event.payload?	unknown
event.subject	string
event.subscriptionId	string
event.type	string
event.v	"1"

Returns

void

---

replay()

replay(subject, sinceEventId): ReplayBufferSlice;

Defined in: packages/server/src/ws/replay-buffer.ts:47

Parameters

Parameter	Type
subject	string
sinceEventId	string | undefined

Returns

ReplayBufferSlice

---

size()

size(subject): number;

Defined in: packages/server/src/ws/replay-buffer.ts:48

Parameters

Parameter	Type
subject	string

Returns

number