rhedge 0.1.0

A hedged request library that sends redundant HTTP requests to reduce tail latency
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26

use bytes::Bytes;
use http::{HeaderMap, Method};
use reqwest::Client;
use rhedge::{HedgedClient, HedgedRequest};
use std::time::Duration;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let client = Client::new();

    let hedged = HedgedClient::new(client, 2, Duration::from_millis(10), 0.95, 0.8);

    for _ in 0..10 {
        let req = HedgedRequest::new(
            Method::GET,
            "http://127.0.0.1:9999/hello".parse()?,
            HeaderMap::new(),
            Bytes::new(),
        );

        let resp = hedged.send(req).await?;
        println!("Status: {}", resp.status());
    }

    Ok(())
}