StreamPosition

@rotorsoft/act-root

---

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

Type Alias: StreamPosition

StreamPosition = object

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

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

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

---

blocked

readonly blocked: boolean

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

True when the stream is blocked by a poison message

---

error

readonly error: string

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

Last error message (empty string when none)

---

lane?

readonly optional lane?: string

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

Drain lane bound to the stream (ACT-1103)

---

leased_by?

readonly optional leased_by?: string

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

Current lease holder UUID (when leased)

---

leased_until?

readonly optional leased_until?: Date

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

Lease expiration timestamp (when leased)

---

priority

readonly priority: number

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

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

Current retry counter

---

source?

readonly optional source?: string

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

Optional source stream filter (for reactions)

---

stream

readonly stream: string

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

The subscription target (projection or reaction stream)