Skip to main content

Module bootstrap

Module bootstrap 

Source
Expand description

Idempotent JetStream bootstrap (Sprint 6.x follow-up).

Lists every NATS JetStream resource the kanade fleet expects — streams, KV buckets, Object Stores — and asks the broker to create them. create_* is a no-op when the resource already exists, so this is safe to call from every backend startup and from the operator-side kanade jetstream setup CLI.

Centralising the list here means a future “we added a new bucket” change touches one place and both the operator CLI + the auto-bootstrap path pick it up.

Functions§

ensure_jetstream_resources
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.