StreamPosition

@rotorsoft/act-root

---

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

Type Alias: StreamPosition

StreamPosition = object

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

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:140

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

---

blocked

readonly blocked: boolean

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

True when the stream is blocked by a poison message

---

error

readonly error: string

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

Last error message (empty string when none)

---

lane?

readonly optional lane?: string

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

Drain lane bound to the stream (ACT-1103)

---

leased_by?

readonly optional leased_by?: string

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

Current lease holder UUID (when leased)

---

leased_until?

readonly optional leased_until?: Date

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

Lease expiration timestamp (when leased)

---

priority

readonly priority: number

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

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:141

Current retry counter

---

source?

readonly optional source?: string

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

Optional exact source stream name (for reactions)

---

stream

readonly stream: string

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

The subscription target (projection or reaction stream)