QueryStreams
@rotorsoft/act-root / act/src / QueryStreams
Type Alias: QueryStreams
QueryStreams =
object
Defined in: libs/act/src/types/ports.ts:132
Filter options for Store.query_streams.
Mirrors the Query pattern used by Store.query — pass filters server-side to keep the cost low on large tables (e.g., dynamic reactions producing one subscription per aggregate).
What the store can filter: the columns it actually persists —
stream, source, blocked. Higher-level classification ("is this a
projection vs a reaction?", "is this a static or dynamic resolver?")
is an orchestrator concern; the streams table doesn't store kinds.
Layer that on top by joining results with Act's built-in registry.
Properties
after?
readonlyoptionalafter?:string
Defined in: libs/act/src/types/ports.ts:138
Keyset pagination cursor: returns only streams with
stream > after (lexicographic). Pass the last seen stream to fetch
the next page.
blocked?
readonlyoptionalblocked?:boolean
Defined in: libs/act/src/types/ports.ts:137
Restrict to blocked (true) or unblocked (false)
streams. Omit for all.
limit?
readonlyoptionallimit?:number
Defined in: libs/act/src/types/ports.ts:139
Max rows to return (default: 100).
source?
readonlyoptionalsource?:string
Defined in: libs/act/src/types/ports.ts:135
Source-stream filter (regex by default). Useful to
isolate dynamic-reaction subscriptions tied to a particular aggregate
stream. Pass source_exact: true for exact equality.
source_exact?
readonlyoptionalsource_exact?:boolean
Defined in: libs/act/src/types/ports.ts:136
Use exact match instead of pattern match for
source.
stream?
readonlyoptionalstream?:string
Defined in: libs/act/src/types/ports.ts:133
Stream-name filter. By default treated as a regex
(PG ~, SQLite/InMemory LIKE-translated). Pass stream_exact: true
for exact string equality.
stream_exact?
readonlyoptionalstream_exact?:boolean
Defined in: libs/act/src/types/ports.ts:134
Use exact match instead of pattern match for
stream.