futures-cache

Futures-aware 缓存抽象。

为使用 sled 在文件系统中持久化数据异步操作提供缓存。异步缓存通过接受一个 future 来工作，但如果答案已经在缓存中，则会取消已接受的 future。

它需要唯一的可序列化缓存键，可以使用 Cache::namespaced 方法区分不同的缓存子组件。

状态

库的状态是

• API 仅限于 wrap，它包括超时 (#1)。
• 当前在 wrap 方法中请求正在竞态，因此当它们应该排队时，可能会发生多个不必要的请求 (#2)。
• 条目仅在库加载时过期 (#3)。
• 仅支持 sled 存储后端 (#4)。

使用方法

此库需要用户添加以下依赖项才能使用

futures-cache = "0.10.2"
serde = {version = "1.0", features = ["derive"]}

示例

简单示例展示了获取 GitHub 存储库信息的过程。

这也可以作为一个可以运行的示例，您可以使用

cargo run --example github -- --user udoprog --repo futures-cache

use futures_cache::{Cache, Duration};
use serde::Serialize;

type Error = Box<dyn std::error::Error>;

#[derive(Debug, Serialize)]
enum GithubKey<'a> {
    Repo { user: &'a str, repo: &'a str },
}

async fn github_repo(user: &str, repo: &str) -> Result<String, Error> {
    use reqwest::header;
    use reqwest::{Client, Url};

    let client = Client::new();

    let url = Url::parse(&format!("https://api.github.com/repos/{}/{}", user, repo))?;

    let req = client
        .get(url)
        .header(header::USER_AGENT, "Reqwest/0.10")
        .build()?;

    let body = client.execute(req).await?.text().await?;
    Ok(body)
}

#[tokio::main]
async fn main() -> Result<(), Error> {
    let db = sled::open("cache")?;
    let cache = Cache::load(db.open_tree("cache")?)?;

    let user = "udoprog";
    let repo = "futures-cache";

    let text = cache
        .wrap(
            GithubKey::Repo {
                user: user,
                repo: repo,
            },
            Duration::seconds(60),
            github_repo(user, repo),
        )
        .await?;

    println!("{}", text);
    Ok(())
}