StreamPosition

@rotorsoft/act-root

---

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

Type Alias: StreamPosition

StreamPosition = object

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

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

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

---

blocked

readonly blocked: boolean

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

True when the stream is blocked by a poison message

---

error

readonly error: string

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

Last error message (empty string when none)

---

leased_by?

readonly optional leased_by?: string

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

Current lease holder UUID (when leased)

---

leased_until?

readonly optional leased_until?: Date

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

Lease expiration timestamp (when leased)

---

retry

readonly retry: number

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

Current retry counter

---

source?

readonly optional source?: string

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

Optional source stream filter (for reactions)

---

stream

readonly stream: string

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

The subscription target (projection or reaction stream)