Struct ScopedConfigStore 

pub struct ScopedConfigStore { /* private fields */ }

Implementations

impl ScopedConfigStore

pub fn new(inner: Arc<dyn ConfigStore>, scope_id: ScopeId) -> ScopedConfigStore

pub fn scope_id(&self) -> &ScopeId

pub fn inner(&self) -> &dyn ConfigStore

Trait Implementations

impl Clone for ScopedConfigStore

fn clone(&self) -> ScopedConfigStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl ConfigStore for ScopedConfigStore

fn get<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, namespace: &'life1 str, id: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<Option<Value>, StorageError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, ScopedConfigStore: 'async_trait,

Get a single entry by namespace and ID.

fn list<'life0, 'life1, 'async_trait>( &'life0 self, namespace: &'life1 str, offset: usize, limit: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<(String, Value)>, StorageError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, ScopedConfigStore: 'async_trait,

List entries in a namespace ordered by ID.

fn put<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, namespace: &'life1 str, id: &'life2 str, value: &'life3 Value, ) -> Pin<Box<dyn Future<Output = Result<(), StorageError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, ScopedConfigStore: 'async_trait,

Create or overwrite an entry.

fn delete<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, namespace: &'life1 str, id: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<(), StorageError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, ScopedConfigStore: 'async_trait,

Delete an entry. Missing entries are not an error.

fn put_if_absent<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, namespace: &'life1 str, id: &'life2 str, value: &'life3 Value, ) -> Pin<Box<dyn Future<Output = Result<(), StorageError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, ScopedConfigStore: 'async_trait,

Create an entry only when it does not already exist.

fn exists<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, namespace: &'life1 str, id: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<bool, StorageError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, ScopedConfigStore: 'async_trait,

Check whether an entry exists.

fn put_if_revision<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, namespace: &'life1 str, id: &'life2 str, value: &'life3 Value, expected_revision: u64, ) -> Pin<Box<dyn Future<Output = Result<(), StorageError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, ScopedConfigStore: 'async_trait,

Atomic compare-and-set on the record’s meta.revision.

fn delete_if_revision<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, namespace: &'life1 str, id: &'life2 str, expected_revision: u64, ) -> Pin<Box<dyn Future<Output = Result<(), StorageError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, ScopedConfigStore: 'async_trait,

Delete only when the current record’s meta.revision matches expected_revision.