Struct ConfigurationBus 

pub struct ConfigurationBus { /* private fields */ }

Shared configuration bus for cross-module configuration

Provides a thread-safe, async-friendly way for modules to share configuration without direct dependencies.

Implementations

impl ConfigurationBus

pub fn new() -> Self

Create a new configuration bus

pub async fn set(&self, key: impl Into<String>, value: impl Into<ConfigValue>)

Set a configuration value

Notifies all subscribers of the change.

pub async fn set_many(&self, values: HashMap<String, ConfigValue>)

Set multiple configuration values at once

pub async fn get(&self, key: &str) -> Option<ConfigValue>

Get a configuration value

pub async fn get_string(&self, key: &str) -> Option<String>

Get a string configuration value

pub async fn get_integer(&self, key: &str) -> Option<i64>

Get an integer configuration value

pub async fn get_float(&self, key: &str) -> Option<f64>

Get a float configuration value

pub async fn get_boolean(&self, key: &str) -> Option<bool>

Get a boolean configuration value

pub async fn get_or_default( &self, key: &str, default: ConfigValue, ) -> ConfigValue

Get a configuration value with default

pub async fn delete(&self, key: &str) -> Option<ConfigValue>

Delete a configuration value

Returns the deleted value if it existed.

pub async fn contains(&self, key: &str) -> bool

Check if a configuration key exists

pub async fn keys(&self) -> Vec<String>

List all configuration keys

pub async fn keys_with_prefix(&self, prefix: &str) -> Vec<String>

List configuration keys matching a prefix

For example, keys_with_prefix("sapiens.") returns all sapiens configuration.

pub async fn get_with_prefix( &self, prefix: &str, ) -> HashMap<String, ConfigValue>

Get all configuration values matching a prefix

pub fn subscribe(&self) -> Receiver<ConfigChangeEvent>

Subscribe to configuration changes

Returns a broadcast receiver that receives all configuration changes.

pub async fn len(&self) -> usize

Get the total number of configuration entries

pub async fn is_empty(&self) -> bool

Check if the configuration store is empty

pub async fn clear(&self)

Clear all configuration values

pub async fn dump(&self) -> HashMap<String, ConfigValue>

Dump all configuration as a HashMap

pub async fn load(&self, values: HashMap<String, ConfigValue>)

Load configuration from a HashMap

Merges with existing configuration (overwrites duplicates).

Trait Implementations

impl Clone for ConfigurationBus

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for ConfigurationBus

fn default() -> Self

Returns the “default value” for a type.