Struct SchemaRegistry 

pub struct SchemaRegistry { /* private fields */ }

Registry of metric and event schema metadata linked into the current binary.

global lazily discovers every spectra_schema! and spectra_metric! registration submitted through inventory. Schema modules must be compiled into the binary (linked with mod); declaring macros alone in unlinked files does not register them.

Examples

use spectra_core::SchemaRegistry;

let registry = SchemaRegistry::global();
for name in registry.list_schemas() {
    let schema = registry.get_schema(name).expect("listed schema");
    println!("{} uses store {}", schema.table_name(), schema.store);
}

// "default" is always available even when this binary declares no schemas.
assert!(registry.distinct_store_names().iter().any(|name| name == "default"));

Implementations

impl SchemaRegistry

pub fn new() -> SchemaRegistry

Creates an empty registry.

pub fn auto_discover() -> SchemaRegistry

Populate from all inventory::submit!-ed SchemaMetadataInit items.

pub fn set_global(registry: SchemaRegistry)

Installs a custom registry as the process-global instance (call once).

pub fn global() -> &'static SchemaRegistry

Returns the process-global registry, auto-discovering on first access.

pub fn register(&mut self, metadata: &'static SchemaMetadata)

Registers a leaked schema metadata entry.

pub fn get_schema( &self, table_or_metric: &str, ) -> Option<&'static SchemaMetadata>

Looks up schema metadata by table or metric name.

pub fn list_schemas(&self) -> Vec<&str>

Lists all registered table and metric names.

pub fn has_schema(&self, table_or_metric: &str) -> bool

Returns whether a schema is registered.

pub fn distinct_store_names(&self) -> Vec<String>

Distinct store names from all registered schemas, always including "default".

Methods from Deref<Target = Registry<SchemaMetadata>>

pub fn get(&self, key: &str) -> Option<&'static T>

Look up an item by registry key.

pub fn list(&self) -> Vec<&str>

Returns all registered keys in arbitrary order.

pub fn len(&self) -> usize

Return the number of registered items.

pub fn is_empty(&self) -> bool

Return true when no items are registered.

pub fn iter(&self) -> impl Iterator<Item = &'static T>

Iterates over all registered descriptors in arbitrary order.

Trait Implementations

impl Debug for SchemaRegistry

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

Formats the value using the given formatter.

impl Default for SchemaRegistry

fn default() -> SchemaRegistry

Returns the “default value” for a type.

impl Deref for SchemaRegistry

type Target = Registry<SchemaMetadata>

The resulting type after dereferencing.

fn deref(&self) -> &<SchemaRegistry as Deref>::Target

Dereferences the value.