backoff

指数退避和重试。

灵感来源于 Google 的 google-http-java-client 库及其 Golang 版本。

使用功能 wasm-bindgen 或 stdweb 编译以在 WASM 环境中使用。由于它使用 std::thread::sleep，因此尚不支持 retry_notify。

⚠️ 重大变更：在 重大变更 下查看迁移说明。

概述

backoff 是一个小型库，允许您根据退避策略重试操作。它提供

• 错误类型，将错误封装为短暂或永久类型，
• 包括指数在内的不同的退避算法，
• 支持同步和异步代码。

同步示例

只需将您的可失败操作包装在闭包中，并将其传递给 retry

use backoff::{retry, ExponentialBackoff, Error};

let op = || {
    reqwest::blocking::get("http://example.com").map_err(Error::transient)
};

let _ = retry(&mut ExponentialBackoff::default(), op);

重试策略将根据 ExponentialBackoff 字段的 randomization_factor 字段使用抖动。请参阅文档以获取更多参数。

异步示例

futures 模块支持 futures

use backoff::ExponentialBackoff;
use backoff::future::retry;

async fn fetch_url(url: &str) -> Result<String, reqwest::Error> {
    retry(ExponentialBackoff::default(), || async {
        println!("Fetching {}", url);
        Ok(reqwest::get(url).await?.text().await?)
    })
    .await
}

重大变更

0.3.x -> 0.4.x

向 Error::Transient 添加新字段

Transient 错误获得了第二个字段。对于处理像 HTTP 429 响应这样的速率限制非常有用。

要修复损坏的代码，只需将 Error::Transient() 的调用替换为 Error::transient()。