Skip to main content

Interface: EventSinkMonitor

Defined in: packages/workflow-engine/src/kernel/helpers/host-support.ts:711

Tracks event-sink health across flushes for a long-lived host.

Logs only on a state transition (healthy → degraded and back), so a sink that is down for an hour produces two lines rather than one per tick, and unconditionally whenever events were dead-lettered — that is the point at which delivery genuinely cannot proceed on its own and needs a human or a plugin.replayDLQ.

Methods​

observe()​

observe(flush): void

Defined in: packages/workflow-engine/src/kernel/helpers/host-support.ts:712

Parameters​

flush​

EventSinkObservation

Returns​

void


observeError()​

observeError(error): void

Defined in: packages/workflow-engine/src/kernel/helpers/host-support.ts:714

Record that a flush attempt threw outright.

Parameters​

error​

unknown

Returns​

void


report()​

report(): EventSinkHealth

Defined in: packages/workflow-engine/src/kernel/helpers/host-support.ts:715

Returns​

EventSinkHealth