Streams

Manage real-time data streams and windows.

Stream Management

Manage stream processing tasks via solidb.streams.

solidb.streams.list() -> array

List all active streams. Returns an array of tables with name and created_at.

local streams = solidb.streams.list()
for _, s in ipairs(streams) do
  solidb.log("Active stream: " .. s.name)
end

solidb.streams.stop(name) -> bool
Stop a running stream task by name. Returns true if stopped, false if not found.
```
solidb.streams.stop("high_value_orders")
```