Struct ChaosMiddleware 

pub struct ChaosMiddleware { /* private fields */ }

Chaos middleware state

This middleware reads configuration from a shared Arc<RwLock<ChaosConfig>> to support hot-reload of chaos settings at runtime.

Implementations

impl ChaosMiddleware

pub fn new( config: Arc<RwLock<ChaosConfig>>, latency_tracker: Arc<LatencyMetricsTracker>, ) -> Self

Create new chaos middleware from shared config

Arguments

• config - Shared chaos configuration (Arc<RwLock>)
• latency_tracker - Latency metrics tracker for recording injected latencies

The middleware will read from the shared config on each request, allowing hot-reload of chaos settings without restarting the server.

pub async fn init_from_config(&self)

Initialize middleware from config (async version)

This should be called after creation to sync injectors with the actual config. This is a convenience method that calls update_from_config().

pub async fn update_from_config(&self)

Update injectors from current config

This method should be called when the config is updated to refresh the cached injectors. For hot-reload support, this is called automatically when processing requests if the config has changed.

pub fn latency_injector(&self) -> Arc<RwLock<LatencyInjector>>

Get latency injector (read-only access)

pub fn fault_injector(&self) -> Arc<RwLock<FaultInjector>>

Get fault injector (read-only access) Note: FaultInjector doesn’t support hot-reload, so we read from config directly

pub fn rate_limiter(&self) -> Arc<RwLock<RateLimiter>>

Get rate limiter (read-only access)

pub fn traffic_shaper(&self) -> Arc<RwLock<TrafficShaper>>

Get traffic shaper (read-only access)

pub fn circuit_breaker(&self) -> Arc<RwLock<CircuitBreaker>>

Get circuit breaker (read-only access)

pub fn bulkhead(&self) -> Arc<RwLock<Bulkhead>>

Get bulkhead (read-only access)

pub fn config(&self) -> Arc<RwLock<ChaosConfig>>

Get shared config (for direct access if needed)

pub fn latency_tracker(&self) -> &Arc<LatencyMetricsTracker>

Get latency tracker

Trait Implementations

impl Clone for ChaosMiddleware

fn clone(&self) -> ChaosMiddleware

Returns a duplicate of the value.

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

Performs copy-assignment from source.