events.iterate.com

Stream processor

core

Maintains the stream's own reduced state.

Owned event types

events.iterate.com/stream/child-stream-createdRecords the immediate child stream segment under this stream.payload: { childPath }emitted by 1 · consumed by 2events.iterate.com/stream/configuredConfigures core stream runtime policy.payload: { config }consumed by 1events.iterate.com/stream/connection-closedObserves that a live connection from this stream to a processEventBatch callback closed. Abrupt Durable Object teardown can end an in-memory connection without leaving this best-effort close fact; runtime connection state is authoritative for what is open now. Ephemeral, like connection-opened.payload: { connectionKey, reason, error? }emitted by 1 · consumed by 2events.iterate.com/stream/connection-openedA live connection from this stream to a processEventBatch callback opened. Appended by the stream itself once per actual open; reconnecting after a transient break is a new connection. Ephemeral: runtime connection state is authoritative for presence, and a reconnect storm against a crash-looping host must not grow the durable journal (the 2026-08-11 revival death spiral journaled ~1500 durable open/close facts per revival cycle, making every replay heavier than the last).payload: { connectionKey, kind, openedBy? }emitted by 1 · consumed by 2events.iterate.com/stream/createdInitializes the core reduced state for a stream.payload: { projectId, path, streamId }consumed by 3events.iterate.com/stream/error-occurredRecords a structured stream or processor runner error.payload: { message, error? }emitted by 1 · consumed by 2events.iterate.com/stream/pausedRecords that the stream is paused and should reject ordinary appends.payload: { reason? }consumed by 1events.iterate.com/stream/processor-revivedA recovery-wired stream processor was revived after its incarnation died owing background work (in-flight obligations lost to an eviction). Appended by the platform's recovery keepalive, never emitted by a processor; the payload's processorSlug names which processor was revived (the type string is shared by every recovery-wired processor). Consumption is optional and only needed when the processor reacts to the fact itself; an unconsumed tail still receives the runner's eventless at-head turn so open obligations are not stranded.payload: { processorSlug, revivals, version }consumed by 1events.iterate.com/stream/resumedRecords that the stream has resumed accepting ordinary appends.payload: { reason? }consumed by 1events.iterate.com/stream/subscription-configuredConfigures or replaces one durable subscription for sending this stream's events to a receiver. This is the sole event that enables delivery.payload: { name?, description?, filter?, receiver }emitted by 3 · consumed by 1events.iterate.com/stream/subscription-cursor-setChanges the next source offset read by one copy, ITX-call, or webhook subscription (exclusive afterOffset semantics). It rejects offsets beyond the current stream head. A receiver call already in progress may still finish, but cannot advance this new position. Hosted processors reject this event because the processor stores its own checkpoint.payload: { name, afterOffset }consumed by 1events.iterate.com/stream/subscription-delivery-haltedOne subscription stopped after delivering matching source events exhausted the bounded retry count. A halt is not forever: the first send check under a LATER deploy version appends one automatic subscription-delivery-resumed (the antidote-deploy retry), so a receiver fixed by a deploy recovers without an operator.payload: { name, reason, afterOffset, attempts, error?, workerVersion? }emitted by 1 · consumed by 1events.iterate.com/stream/subscription-delivery-resumedResumes one halted subscription at its existing cursor.payload: { name }consumed by 1events.iterate.com/stream/subscription-removedRemoves one durable subscription.payload: { name, reason }emitted by 1 · consumed by 1events.iterate.com/stream/wokenRecords that a Durable Object incarnation has started running this stream.payload: { incarnationId }consumed by 1

Consumes

Consumes * — every event on the stream reaches this processor's reducer, with these types named explicitly:

events.iterate.com/stream/createdInitializes the core reduced state for a stream.events.iterate.com/stream/wokenRecords that a Durable Object incarnation has started running this stream.events.iterate.com/stream/configuredConfigures core stream runtime policy.events.iterate.com/stream/child-stream-createdRecords the immediate child stream segment under this stream.events.iterate.com/stream/subscription-configuredConfigures or replaces one durable subscription for sending this stream's events to a receiver. This is the sole event that enables delivery.events.iterate.com/stream/subscription-removedRemoves one durable subscription.events.iterate.com/stream/subscription-delivery-haltedOne subscription stopped after delivering matching source events exhausted the bounded retry count. A halt is not forever: the first send check under a LATER deploy version appends one automatic subscription-delivery-resumed (the antidote-deploy retry), so a receiver fixed by a deploy recovers without an operator.events.iterate.com/stream/subscription-delivery-resumedResumes one halted subscription at its existing cursor.events.iterate.com/stream/subscription-cursor-setChanges the next source offset read by one copy, ITX-call, or webhook subscription (exclusive afterOffset semantics). It rejects offsets beyond the current stream head. A receiver call already in progress may still finish, but cannot advance this new position. Hosted processors reject this event because the processor stores its own checkpoint.events.iterate.com/stream/connection-openedA live connection from this stream to a processEventBatch callback opened. Appended by the stream itself once per actual open; reconnecting after a transient break is a new connection. Ephemeral: runtime connection state is authoritative for presence, and a reconnect storm against a crash-looping host must not grow the durable journal (the 2026-08-11 revival death spiral journaled ~1500 durable open/close facts per revival cycle, making every replay heavier than the last).events.iterate.com/stream/connection-closedObserves that a live connection from this stream to a processEventBatch callback closed. Abrupt Durable Object teardown can end an in-memory connection without leaving this best-effort close fact; runtime connection state is authoritative for what is open now. Ephemeral, like connection-opened.events.iterate.com/stream/error-occurredRecords a structured stream or processor runner error.events.iterate.com/stream/pausedRecords that the stream is paused and should reject ordinary appends.events.iterate.com/stream/resumedRecords that the stream has resumed accepting ordinary appends.

Emits