Struct FaultProxy 

pub struct FaultProxy { /* private fields */ }

A TCP proxy that forwards bytes between test clients and an upstream Redis node while injecting configurable network faults.

Construct with FaultProxy::spawn. Fault controls can be changed at any time via the returned handle; delay, close-after, and chunk-size take effect on data already in flight (checked on every read), while FaultProxy::set_drop_all is snapshotted once per accepted connection. The proxy stops accepting new connections when the handle is dropped; already-established connections run to completion.

Implementations

impl FaultProxy

pub async fn spawn(upstream_addr: impl ToSocketAddrs) -> Result<FaultProxy>

Bind an ephemeral local TCP listener that proxies to upstream_addr and return a handle to it. The proxy starts in clean-passthrough mode.

pub fn addr(&self) -> SocketAddr

The local address clients should connect to.

pub fn set_delay(&self, direction: Direction, delay: Delay)

Set (or replace) the delay applied before forwarding data in direction.

pub fn clear_delay(&self, direction: Direction)

Remove any delay configured for direction.

pub fn close_after(&self, direction: Direction, bytes: u64)

Close the connection once bytes total have been forwarded in direction, cutting mid-buffer if the triggering read straddles the threshold. Applies independently to every connection accepted while this setting is active.

pub fn clear_close_after(&self, direction: Direction)

Remove the close-after threshold configured for direction.

pub fn set_chunk_size(&self, size: usize)

Split forwarded writes into pieces of at most size bytes, in both directions. Use size == 1 to exercise incremental decoders.

pub fn clear_chunk_size(&self)

Stop chunking writes; forward reads in whatever size they arrive.

pub fn set_drop_all(&self, drop_all: bool)

Enable or disable black-hole mode. While enabled, newly accepted connections are held open (no upstream connection is made, nothing is ever forwarded or written back) until the client disconnects or the proxy is dropped. Existing connections are unaffected.

pub fn reset(&self)

Clear every fault control, returning the proxy to clean passthrough for new connections.

Trait Implementations

impl Drop for FaultProxy

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.