StreamPosition

@rotorsoft/act-root

---

@rotorsoft/act-root / act/src / StreamPosition

Type Alias: StreamPosition

StreamPosition = object

Defined in: libs/act/src/types/ports.ts:143

Subscription position for a registered stream.

Streamed by Store.query_streams to power operational dashboards (projection lag, blocked subscriptions, in-flight leases). The shape mirrors what every adapter already tracks on its streams table.

Properties

at

readonly at: number

Defined in: libs/act/src/types/ports.ts:146

Last processed event id watermark (-1 for fresh streams)

---

blocked

readonly blocked: boolean

Defined in: libs/act/src/types/ports.ts:148

True when the stream is blocked by a poison message

---

deferred_at?

readonly optional deferred_at?: number

Defined in: libs/act/src/types/ports.ts:154

Persisted next-visit time (ms since epoch) when the stream is held out of claim by a defer outcome; omitted when the stream carries no active defer schedule. Read at cold start to re-seed the in-process defer timer so an idle deferred stream re-arms its drain across a restart (#1221) — the schedule outlives the process memory it was derived from.

---

error

readonly error: string

Defined in: libs/act/src/types/ports.ts:149

Last error message (empty string when none)

---

lane?

readonly optional lane?: string

Defined in: libs/act/src/types/ports.ts:153

Drain lane bound to the stream (ACT-1103)

---

leased_by?

readonly optional leased_by?: string

Defined in: libs/act/src/types/ports.ts:151

Current lease holder UUID (when leased)

---

leased_until?

readonly optional leased_until?: Date

Defined in: libs/act/src/types/ports.ts:152

Lease expiration timestamp (when leased)

---

priority

readonly priority: number

Defined in: libs/act/src/types/ports.ts:150

Scheduling priority (default 0). Biases the lagging-frontier claim() ordering — see Store.prioritize.

---

retry

readonly retry: number

Defined in: libs/act/src/types/ports.ts:147

Current retry counter

---

source?

readonly optional source?: string

Defined in: libs/act/src/types/ports.ts:145

Optional source (literal name or regex pattern) the reaction consumes from

---

stream

readonly stream: string

Defined in: libs/act/src/types/ports.ts:144

The subscription target (projection or reaction stream)