Skip to content

InMemorySchemaRegistry

Defined in: src/persistence/migration/SchemaRegistry.ts:121

In-memory SchemaRegistry impl. All state lives in one process.

new InMemorySchemaRegistry(): InMemorySchemaRegistry

InMemorySchemaRegistry

eventAdapter<E>(manifest): EventAdapter<E, unknown>

Defined in: src/persistence/migration/SchemaRegistry.ts:199

Build an EventAdapter that writes at the latest registered version of manifest and reads any registered version by chaining upcasters forward.

E

string

EventAdapter<E, unknown>

SchemaRegistry.eventAdapter


get(manifest, version): SchemaDescriptor | undefined

Defined in: src/persistence/migration/SchemaRegistry.ts:179

Look up the registration for (manifest, version), if any.

string

number

SchemaDescriptor | undefined

SchemaRegistry.get


latestVersion(manifest): number | undefined

Defined in: src/persistence/migration/SchemaRegistry.ts:183

Highest registered version for manifest, or undefined if unknown.

string

number | undefined

SchemaRegistry.latestVersion


list(): readonly SchemaDescriptor[]

Defined in: src/persistence/migration/SchemaRegistry.ts:191

Snapshot of every registration — primarily for debugging / introspection.

readonly SchemaDescriptor[]

SchemaRegistry.list


register<Wire, Upcasted>(manifest, version, registration): void

Defined in: src/persistence/migration/SchemaRegistry.ts:124

Add or replace the registration for (manifest, version). Runs the configured compat check; throws on incompatibility. Re-registering the same (manifest, version) overwrites — the registry doesn’t enforce immutability, that’s an operator concern.

Wire = unknown

Upcasted = unknown

string

number

SchemaRegistration<Wire, Upcasted>

void

SchemaRegistry.register


snapshotAdapter<S>(manifest): SnapshotAdapter<S, unknown>

Defined in: src/persistence/migration/SchemaRegistry.ts:246

Same as eventAdapter but typed for snapshot/state actors.

S

string

SnapshotAdapter<S, unknown>

SchemaRegistry.snapshotAdapter