Struct SourceSpec 

pub struct SourceSpec { /* private fields */ }

The enabled indexes a source must build, each paired with its schema.

Everything here is treated as live — disabled indexes are dropped by the composition root when it translates the config into this spec, so the source never has to re-check an enabled flag.

Implementations

impl SourceSpec

pub fn new(indexes: BTreeMap<IndexName, IndexSchema>) -> Self

Build a spec from an explicit set of (index, schema) pairs. Every entry is treated as live; the caller (the composition root) is responsible for having filtered out disabled indexes when translating from a config.

pub fn indexes(&self) -> impl Iterator<Item = (&IndexName, &IndexSchema)>

Iterate the indexes and their schemas, in index-name order.

pub fn schema(&self, index: &IndexName) -> Option<&IndexSchema>

pub fn index_mappings(&self) -> Vec<IndexMapping>

Project every index into its fully-typed IndexMapping, using only the declared schema — the database-free counterpart the engine creates indexes from up front.

pub fn all_tables(&self) -> BTreeSet<QualifiedTable>

Every table any enabled index reads — each index’s root table plus every table a join or aggregate (and any through junction) pulls from.

Relations carry no schema of their own; the resolver qualifies a related table with the index’s db_schema (see the Postgres resolve module), so this does the same. This is the set a source must be able to stream — what CaptureProvisioning checks coverage against.

Trait Implementations

impl Clone for SourceSpec

fn clone(&self) -> SourceSpec

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SourceSpec

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for SourceSpec

fn default() -> SourceSpec

Returns the “default value” for a type.