Retry Future
The main purpose of the crate is to retry Futures which may contain complex scenarios such as
not only handling errors but anything that should be retried. This may include
retrying 500's errors from http requests or retrying something like "pseudo" successes from
grpc requests.
For examples, please check examples/ dir, but here is one:
// imports...
use retry_future::{
RetryFuture, RetryPolicy, ExponentialRetryStrategy, Error
};
#[tokio::main]
async fn main() -> anyhow::Result<()> {
let resp = RetryFuture::new(
|| async {
let resp = reqwest::get("http://localhost:8080").await?;
match resp.status() {
StatusCode::OK => Ok(resp),
StatusCode::BAD_REQUEST | StatusCode::FORBIDDEN => Err(RetryPolicy::Fail(
String::from("Cannot recover from these kind of errors ._."),
)),
StatusCode::INTERNAL_SERVER_ERROR => Err(RetryPolicy::Retry(None)),
StatusCode::UNAUTHORIZED => {
// What if authorization server lies us?! Retry it to be convinced
let maybe_response_text = resp.text().await.ok().map(Error::msg); // debug info
Err(RetryPolicy::Retry(maybe_response_text))
}
_ => Err(RetryPolicy::Fail(format!("Some unusual response here: {resp:?}"))),
}
},
ExponentialRetryStrategy::new()
.max_attempts(5)
.initial_delay(Duration::from_millis(100))
.retry_early_returned_errors(true),
)
.await?;
eprintln!("resp = {:#?}", resp);
Ok(())
}License
Licensed under either of
- Apache License, Version 2.0 (LICENSE-APACHE or http://www.apache.org/licenses/LICENSE-2.0)
- MIT license (LICENSE-MIT or http://opensource.org/licenses/MIT)
at your option.
Contribution
Unless you explicitly state otherwise, any contribution intentionally submitted for inclusion in the work by you, as defined in the Apache-2.0 license, shall be dual licensed as above, without any additional terms or conditions.
