7 releases

0.1.6 Mar 20, 2021
0.1.5 Mar 17, 2021

#143 in #redis

Download history 271/week @ 2024-02-26 327/week @ 2024-03-04 393/week @ 2024-03-11 413/week @ 2024-03-18 608/week @ 2024-03-25 779/week @ 2024-04-01 447/week @ 2024-04-08 604/week @ 2024-04-15 615/week @ 2024-04-22 858/week @ 2024-04-29 526/week @ 2024-05-06 858/week @ 2024-05-13 679/week @ 2024-05-20 1021/week @ 2024-05-27 790/week @ 2024-06-03 1090/week @ 2024-06-10

3,590 downloads per month

MIT license

29KB
391 lines

Toxiproxy - Rust client

Build Status Crates.io

Rust client for Toxiproxy.

Usage

Populating proxies:

let proxies = TOXIPROXY.populate(vec![
  Proxy::new(
    "socket_service".into(),
    "localhost:2001".into(),
    "localhost:2000".into(),
  ),
  Proxy::new(
    "redis".into(),
    "localhost:6000".into(),
    "localhost:6379".into(),
  )
])?;

Testing with an unavailable connection:

TOXIPROXY.find_and_reset_proxy("redis")?.with_down(|| {
  // Calling the desired service...
})?;

Testing with toxics (for full documentation on available toxics see the original docs):

TOXIPROXY.find_and_reset_proxy("redis")?.with_latency("downstream".into(), 2000, 0, 1.0).apply(|| {
  // Calling the desired service...
})?;

Or without a safe lambda (that takes care of resetting a proxy):

TOXIPROXY.find_proxy("redis")?.with_latency("downstream".into(), 2000, 0, 1.0)
// Calling the desired service...

TOXIPROXY.find_proxy("redis")?.disable();
// Test unavailability.
TOXIPROXY.find_proxy("redis")?.enable();

Supported toxics:

Using a custom address for Toxiproxy server:

let toxiclient: Client = toxiproxy_rust::Client::new("1.2.3.4:5678");

Development

Tests:

$> cargo test -- --test-threads 1

Dependencies

~4–19MB
~246K SLoC