Struct AsyncRuntimeConfig 

pub struct AsyncRuntimeConfig { /* private fields */ }

Async runtime configuration cache.

This type uses tokio::sync::RwLock and is intended for async-first services that want to load and query runtime configuration through async boundaries. Services with synchronous hot read paths should use SyncRuntimeConfig instead.

Implementations

impl AsyncRuntimeConfig

pub fn new() -> Self

Creates an empty async runtime cache.

pub async fn reload<S>(&self, store: &S) -> Result<Vec<RuntimeConfigChange>>

where S: AsyncConfigStore + ?Sized,

Reloads all values from store and returns the diff.

Restart-only rows keep their in-process record when the key already exists (value and flags stay until restart), mirroring Self::apply; the diff does not report those keys as changed. Removals are applied immediately, matching Self::remove.

pub async fn snapshot(&self) -> AsyncConfigSnapshot

Returns a cloned snapshot for lock-free derived-state processing.

pub async fn get_model(&self, key: &str) -> Option<StoredConfig>

Returns the stored model for key.

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

Returns the storage string for key.

pub async fn apply(&self, config: StoredConfig) -> Option<RuntimeConfigChange>

Applies one row to the snapshot.

If the incoming row requires restart and the key already exists, the update is ignored to preserve the in-process value until restart.

pub async fn remove(&self, key: &str) -> Option<RuntimeConfigChange>

Removes one key from the snapshot.

Trait Implementations

impl Debug for AsyncRuntimeConfig

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

Formats the value using the given formatter.

impl Default for AsyncRuntimeConfig

fn default() -> AsyncRuntimeConfig

Returns the “default value” for a type.