Rust client for Toxiproxy.
Populating proxies:
rust
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:
rust
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):
rust
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):
```rust TOXIPROXY.findproxy("redis")?.withlatency("downstream".into(), 2000, 0, 1.0) // Calling the desired service...
TOXIPROXY.findproxy("redis")?.disable(); // Test unavailability. TOXIPROXY.findproxy("redis")?.enable(); ```
Supported toxics: - latency - down - bandwith - slow close - timeout - slicer - limit data
Using a custom address for Toxiproxy server:
rust
let toxiclient: Client = toxiproxy_rust::Client::new("1.2.3.4:5678");
Tests:
bash
$> cargo test -- --test-threads 1