Lib.rs

毒proxy - Rust客户端

Rust客户端，用于Toxiproxy。

用法

填充代理

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(),
  )
])?;

测试不可用连接

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

使用毒药（有关可用毒药的完整文档，请参阅原始文档）

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

或没有安全的lambda（负责重置代理）

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();

支持的毒药

• 延迟
• 关闭
• 带宽
• 缓慢关闭
• 超时
• 切片器
• 限制数据

为Toxiproxy服务器使用自定义地址

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

开发

测试

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