Function query 

pub(crate) async fn query(
    pool: &PgPool,
    reflector_filter: Option<&str>,
    since: DateTime<Utc>,
    limit: i64,
) -> Result<Vec<StreamRow>, Error>

Queries streams with optional filters on reflector, time window, and limit.

Used by the HTTP API to serve the stream listing endpoint. When reflector_filter is Some, only streams from that reflector are returned. Results are ordered by started_at DESC (most recent first).

Errors

Returns sqlx::Error on query failure.