tower-http-cache-plus 0.0.2

HTTP response caching middleware with integrated compression
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
27
28
29
30
31
32
33
34
35
36

use super::super::super::{cache::*, key::*, response::*};

use std::{ops::*, sync::*};

//
// MokaCacheImplementation
//

/// Moka cache implementation.
///
/// Note that it is based on the `sync` version of Moka cache rather than its `future` version.
///
/// The reason is that our `get` is not `async`, and unfortunately the `future` version of Moka
/// does not have a non-`async` version of its `get`.
pub type MokaCacheImplementation<CacheKeyT = CommonCacheKey> = Arc<moka::future::Cache<CacheKeyT, CachedResponseRef>>;

impl<CacheKeyT> Cache<CacheKeyT> for MokaCacheImplementation<CacheKeyT>
where
    CacheKeyT: CacheKey,
{
    async fn get(&self, key: &CacheKeyT) -> Option<CachedResponseRef> {
        self.deref().get(key).await
    }

    async fn put(&self, key: CacheKeyT, cached_response: CachedResponseRef) {
        self.deref().insert(key, cached_response).await
    }

    async fn invalidate(&self, key: &CacheKeyT) {
        self.deref().invalidate(key).await
    }

    async fn invalidate_all(&self) {
        self.deref().invalidate_all()
    }
}