Struct LatencyInjector 

pub struct LatencyInjector { /* private fields */ }

Computes per-attempt delays from a LatencyProfile.

LatencyInjector is intentionally side-effect-free: it returns the delay it would sleep, leaving the actual thread::sleep (or tokio::time::sleep) up to the caller. This keeps the type usable in both sync and async contexts.

Example

use dev_chaos::latency::{LatencyInjector, LatencyProfile};
use std::time::Duration;

let inj = LatencyInjector::new(LatencyProfile::Constant(Duration::from_millis(5)));
assert_eq!(inj.delay_for(1), Duration::from_millis(5));
assert_eq!(inj.delay_for(100), Duration::from_millis(5));

Implementations

impl LatencyInjector

pub fn new(profile: LatencyProfile) -> Self

Build an injector from a profile.

pub fn delay_for(&self, attempt: usize) -> Duration

Compute the delay that would be applied at attempt (1-indexed).

pub fn apply_blocking(&self, attempt: usize)

Apply the delay synchronously by sleeping the calling thread.

Equivalent to std::thread::sleep(self.delay_for(attempt)).