Struct ValuesStore 

pub struct ValuesStore { /* private fields */ }

Implementations

impl ValuesStore

pub fn new( registry: Arc<SchemaRegistry>, values_dir: &Path, ) -> ValidationResult<Self>

Build a store and perform the initial values load synchronously.

pub fn with_propagation_callback( registry: Arc<SchemaRegistry>, values_dir: &Path, callback: PropagationCallback, ) -> ValidationResult<Self>

Build a store with a callback that fires whenever new values are detected. The callback receives (namespace, delay_secs) on each value change.

pub fn registry(&self) -> &Arc<SchemaRegistry>

The registry the store was constructed with.

pub fn load(&self) -> Guard<Arc<ValuesByNamespace>>

Returns a guard onto the current values snapshot, refreshing first if the cached snapshot is older than refresh_threshold + jitter.