Struct SuperSTACEngine 

pub struct SuperSTACEngine { /* private fields */ }

Runtime entry point. Wraps a storage backend, runs background health checks and /collections introspection, and exposes the federated search

• discovery API.

Construct, call start(), then use search() / list_collections() / describe_collection(). start() is idempotent — search() will call it for you if needed.

Implementations

impl SuperSTACEngine

pub fn new(storage: Box<dyn StorageBackend + Send + Sync>) -> Self

Build an engine over the given storage. Construct the storage via superstac_config::init_from_yaml or directly via superstac_core::models::storage::Storage::init.

pub async fn start(&self) -> Result<(), SuperSTACError>

Run health checks against all catalogs, then introspect /collections on the healthy ones. Idempotent — safe to call multiple times.

pub async fn shutdown(&self)

Cancel background health-monitor tasks. Doesn’t drop the storage.

pub async fn ensure_started(&self) -> Result<(), SuperSTACError>

start() if we haven’t already. Called automatically by search() and the discovery methods.

pub async fn search( &self, query: SearchQuery, ) -> Result<SearchResponse, SuperSTACError>

Federated search. Applies source selection (filter catalogs that can’t possibly serve the requested collections), then fans out.

pub async fn list_collections( &self, ) -> Result<Vec<CollectionAvailability>, SuperSTACError>

Aggregated view: every collection ID known across healthy catalogs, with the catalogs that serve each.

pub async fn catalogs_supporting( &self, collection_id: &str, ) -> Result<Vec<String>, SuperSTACError>

IDs of every catalog whose introspected /collections includes collection_id. Catalogs not yet introspected are excluded.

pub async fn collections_by_catalog( &self, ) -> Result<HashMap<String, Vec<String>>, SuperSTACError>

Per-catalog inventory: catalog ID -> sorted canonical collection IDs. Catalogs without introspection data are omitted.

pub async fn describe_collection( &self, catalog_id: &str, collection_id: &str, ) -> Result<Option<Collection>, SuperSTACError>

Fetch full collection metadata from a specific catalog. The collection_id is interpreted as canonical and resolved to the catalog’s local name via collection_aliases. Returns None if the catalog returns 404 for the collection.