Struct ConfigurationServiceImpl 

pub struct ConfigurationServiceImpl {
    name: String,
    config: Arc<RwLock<HashMap<String, ConfigurationValue>>>,
    config_paths: Arc<RwLock<HashMap<ConfigurationScope, PathBuf>>>,
    running: Arc<RwLock<bool>>,
    watchers: Arc<RwLock<HashMap<String, Vec<Arc<RwLock<dyn Fn(String, Value) -> Result<()> + Send + Sync>>>>>>,
}

Configuration service

Fields

name: String

Service name

config: Arc<RwLock<HashMap<String, ConfigurationValue>>>

Configuration data

config_paths: Arc<RwLock<HashMap<ConfigurationScope, PathBuf>>>

Configuration paths

running: Arc<RwLock<bool>>

Running flag

watchers: Arc<RwLock<HashMap<String, Vec<Arc<RwLock<dyn Fn(String, Value) -> Result<()> + Send + Sync>>>>>>

Watchers

Implementations

impl ConfigurationServiceImpl

pub fn new(config_path: Option<PathBuf>) -> Self

Create a new configuration service

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

Get a configuration value

pub async fn get_with_default(&self, key: &str, default: Value) -> Value

Get a configuration value with a default

pub async fn set( &self, key: String, value: Value, scope: ConfigurationScope, ) -> Result<()>

Set a configuration value

pub async fn remove(&self, key: String) -> Result<bool>

Remove a configuration value

pub async fn get_all(&self) -> HashMap<String, Value>

Get all configuration values

pub async fn get_all_in_scope( &self, scope: ConfigurationScope, ) -> HashMap<String, Value>

Get all configuration values in a scope

pub async fn load_from_file( &self, path: &Path, scope: ConfigurationScope, ) -> Result<()>

Load configuration from a file

pub async fn load_from_value( &self, value: Value, scope: ConfigurationScope, ) -> Result<()>

Load configuration from a value

pub async fn save_to_file( &self, path: &Path, scope: ConfigurationScope, ) -> Result<()>

Save configuration to a file

pub async fn register_watcher<F>(&self, key: String, callback: F)

where F: Fn(String, Value) -> Result<()> + Send + Sync + 'static,

Register a configuration watcher

pub async fn unregister_watcher(&self, key: String) -> Result<bool>

Unregister a configuration watcher

async fn notify_watchers(&self, key: String, value: Value)

Notify watchers of configuration changes

pub async fn get_config_paths(&self) -> HashMap<ConfigurationScope, PathBuf>

Get configuration paths

Trait Implementations

impl Service for ConfigurationServiceImpl

fn name(&self) -> &str

Get service name

async fn start(&self) -> Result<()>

Start the service

async fn stop(&self) -> Result<()>

Stop the service

async fn is_running(&self) -> bool

Check if service is running