Skip to main content

ensure_jetstream_resources

Function ensure_jetstream_resources 

Source
pub async fn ensure_jetstream_resources(js: &Context) -> Result<()>
Expand description

Idempotently create every NATS JetStream resource the kanade fleet relies on. Calling repeatedly is safe — create_* returns the existing resource if it’s already configured.

Returns once every resource is in place. The function is async so backends can await it as part of their startup sequence (one round-trip per resource — ~10 RTTs total).