Struct RuntimeSwitchManager 

pub struct RuntimeSwitchManager {
    kv_backend: KvBackendRef,
    cache: Cache<Vec<u8>, Option<Vec<u8>>>,
}

The runtime switch manager.

Used to enable or disable runtime switches.

Fields

kv_backend: KvBackendRef

cache: Cache<Vec<u8>, Option<Vec<u8>>>

Implementations

impl RuntimeSwitchManager

pub fn new(kv_backend: KvBackendRef) -> Self

async fn put_key(&self, key: &str) -> Result<()>

async fn delete_keys(&self, keys: &[&str]) -> Result<()>

async fn exists(&self, key: &str) -> Result<bool>

Returns true if the key exists.

pub async fn set_maintenance_mode(&self) -> Result<()>

Enables maintenance mode.

pub async fn unset_maintenance_mode(&self) -> Result<()>

Unsets maintenance mode.

pub async fn maintenance_mode(&self) -> Result<bool>

Returns true if maintenance mode is enabled.

pub async fn pasue_procedure(&self) -> Result<()>

pub async fn resume_procedure(&self) -> Result<()>

Resumes processing of incoming procedure requests.

pub async fn is_procedure_paused(&self) -> Result<bool>

Returns true if the system is currently pausing incoming procedure requests.

pub async fn set_recovery_mode(&self) -> Result<()>

Enables recovery mode.

pub async fn unset_recovery_mode(&self) -> Result<()>

Unsets recovery mode.

pub async fn recovery_mode(&self) -> Result<bool>

Returns true if the system is currently in recovery mode.

Trait Implementations

impl Clone for RuntimeSwitchManager

fn clone(&self) -> RuntimeSwitchManager

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl PauseAware for RuntimeSwitchManager

fn is_paused<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<bool, BoxedError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Returns true if the procedure manager is paused.