Skip to main content

RunEventLog

@forge/monorepo

@forge/monorepo / backend/src / RunEventLog

Interface: RunEventLog

Defined in: backend/src/core/events.ts:241

Durable, append-only per-run event log — the catch-up half of reconnect. Every event the worker publishes is also appended here; a reconnecting client reads everything after its cursor. Ordering is by the monotonic sequence, so replay is deterministic and gap-free. Adapters: Postgres, Redis list (Twenty's pattern), in-memory for tests.

Methods​

append()​

append(input): Promise<void>

Defined in: backend/src/core/events.ts:242

Parameters​

input​
event​

RunEvent

tenantId​

TenantId

Returns​

Promise<void>

latestSequence()​

latestSequence(input): Promise<number>

Defined in: backend/src/core/events.ts:250

Parameters​

input​
runId​

RunId

tenantId​

TenantId

Returns​

Promise<number>

listAfter()​

listAfter(input): Promise<readonly RunEvent[]>

Defined in: backend/src/core/events.ts:244

Events with sequence > after, ascending. after: 0 returns the whole run.

Parameters​

input​
after​

number

limit?​

number

runId​

RunId

tenantId​

TenantId

Returns​

Promise<readonly RunEvent[]>