Struct LatencyInjector 

pub struct LatencyInjector { /* private fields */ }

Latency and fault injector

Implementations

impl LatencyInjector

pub fn new(latency_profile: LatencyProfile, fault_config: FaultConfig) -> Self

Create a new latency injector

pub fn set_enabled(&mut self, enabled: bool)

Enable or disable injection

pub fn is_enabled(&self) -> bool

Check if injection is enabled

pub async fn inject_latency(&self, tags: &[String]) -> Result<()>

Inject latency for a request

pub fn should_inject_failure(&self) -> bool

Check if a failure should be injected

pub fn get_failure_response(&self) -> (u16, Option<Value>)

Get failure response details

pub async fn process_request( &self, tags: &[String], ) -> Result<Option<(u16, Option<Value>)>>

Process a request with latency and potential fault injection

pub fn update_profile(&mut self, profile: LatencyProfile)

Update latency profile at runtime

This allows changing the latency profile without recreating the injector. Useful for hot-reloading reality level configurations.

pub async fn update_profile_async( this: &Arc<RwLock<Self>>, profile: LatencyProfile, ) -> Result<()>

Update latency profile (async version for Arc)

Convenience method for updating a latency injector wrapped in Arc. This is the recommended way to update latency profiles at runtime.

Returns

Ok(()) on success, or an error if the update fails.

Trait Implementations

impl Clone for LatencyInjector

fn clone(&self) -> LatencyInjector

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for LatencyInjector

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

Formats the value using the given formatter.

impl Default for LatencyInjector

fn default() -> Self

Returns the “default value” for a type.