pub async fn ensure_stream(client: &Client) -> Result<Context>Expand description
Construct a JetStream context and ensure the canonical
CELLOS_EVENTS stream exists with the FC-74 retention floor.
Idempotent: if the stream already exists with any config we leave it alone (see module docs for the rationale).