EventsRegistry
Defined in: pkgs/core/src/events/registry.ts:79
Methods
Section titled “Methods”close()
Section titled “close()”close():
Promise<void>
Defined in: pkgs/core/src/events/registry.ts:103
Returns
Section titled “Returns”Promise<void>
emit()
Section titled “emit()”emit(
batch,input):EmitHandle
Defined in: pkgs/core/src/events/registry.ts:81
Parameters
Section titled “Parameters”Returns
Section titled “Returns”getCursor()
Section titled “getCursor()”getCursor(
subscriberName,originHostId):Promise<Readonly<{originHostId:string;sequence:bigint; }> |null>
Defined in: pkgs/core/src/events/registry.ts:82
Parameters
Section titled “Parameters”subscriberName
Section titled “subscriberName”string
originHostId
Section titled “originHostId”string
Returns
Section titled “Returns”Promise<Readonly<{ originHostId: string; sequence: bigint; }> | null>
listDeadLetter()
Section titled “listDeadLetter()”listDeadLetter(
subscriberName,opts?):Promise<readonlyReadonly<{envelope:EventEnvelope;payloadRaw:Uint8Array; }>[]>
Defined in: pkgs/core/src/events/registry.ts:83
Parameters
Section titled “Parameters”subscriberName
Section titled “subscriberName”string
afterSequence?
Section titled “afterSequence?”bigint
limit?
Section titled “limit?”number
Returns
Section titled “Returns”Promise<readonly Readonly<{ envelope: EventEnvelope; payloadRaw: Uint8Array; }>[]>
listHalted()
Section titled “listHalted()”listHalted(
name?):Promise<readonlyReadonly<{attemptCount:number;eventId:string;haltedAt:Date;haltedAtSequence:bigint;lastReason:string;materializerName:string;originHostId:string; }>[]>
Defined in: pkgs/core/src/events/registry.ts:94
Parameters
Section titled “Parameters”string
Returns
Section titled “Returns”Promise<readonly Readonly<{ attemptCount: number; eventId: string; haltedAt: Date; haltedAtSequence: bigint; lastReason: string; materializerName: string; originHostId: string; }>[]>
redeliverDeadLetter()
Section titled “redeliverDeadLetter()”redeliverDeadLetter(
name,selector):Promise<{redelivered:number;stillFailing:number; }>
Defined in: pkgs/core/src/events/registry.ts:87
Parameters
Section titled “Parameters”string
selector
Section titled “selector”{ eventIds: readonly string[]; } | { all: true; } | { olderThan: Date; }
Returns
Section titled “Returns”Promise<{ redelivered: number; stillFailing: number; }>
registerEvents()
Section titled “registerEvents()”registerEvents<
Tx>(module):void
Defined in: pkgs/core/src/events/registry.ts:80
Type Parameters
Section titled “Type Parameters”Tx
Parameters
Section titled “Parameters”module
Section titled “module”EventsModule<Tx>
Returns
Section titled “Returns”void
resumeHaltedMaterializer()
Section titled “resumeHaltedMaterializer()”resumeHaltedMaterializer(
name,originHostId):Promise<void>
Defined in: pkgs/core/src/events/registry.ts:101
Parameters
Section titled “Parameters”string
originHostId
Section titled “originHostId”string
Returns
Section titled “Returns”Promise<void>
rewindMaterializer()
Section titled “rewindMaterializer()”rewindMaterializer(
name,originHostId,toSequence):Promise<void>
Defined in: pkgs/core/src/events/registry.ts:102
Parameters
Section titled “Parameters”string
originHostId
Section titled “originHostId”string
toSequence
Section titled “toSequence”bigint
Returns
Section titled “Returns”Promise<void>
skipHaltedEvent()
Section titled “skipHaltedEvent()”skipHaltedEvent(
name,originHostId,eventId,attestation):Promise<void>
Defined in: pkgs/core/src/events/registry.ts:95
Parameters
Section titled “Parameters”string
originHostId
Section titled “originHostId”string
eventId
Section titled “eventId”string
attestation
Section titled “attestation”Returns
Section titled “Returns”Promise<void>