Struct mz_persist::unreliable::UnreliableHandle

pub struct UnreliableHandle {
    core: Arc<Mutex<UnreliableCore>>,
}

A handle for controlling the behavior of an unreliable delegate.

Fields

core: Arc<Mutex<UnreliableCore>>

Implementations

impl UnreliableHandle

pub fn new(seed: u64, should_happen: f64, should_timeout: f64) -> Self

Returns a new UnreliableHandle.

pub fn partially_available(&self, should_happen: f64, should_timeout: f64)

Cause all later calls to sometimes return an error.

pub fn totally_unavailable(&self)

Cause all later calls to return an error.

pub fn totally_available(&self)

Cause all later calls to succeed.

fn should_happen(&self) -> bool

fn should_timeout(&self) -> bool

async fn run_op<R, F, WorkFn>( &self, name: &str, work_fn: WorkFn, ) -> Result<R, ExternalError>

where F: Future<Output = Result<R, ExternalError>>, WorkFn: FnOnce() -> F,

Trait Implementations

impl Clone for UnreliableHandle

fn clone(&self) -> UnreliableHandle

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for UnreliableHandle

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

Formats the value using the given formatter.

impl Default for UnreliableHandle

fn default() -> Self

Returns the “default value” for a type.