groupcache 0.3.0

groupcache is a distributed caching and cache-filling library, intended as a replacement for a pool of memcached nodes in many cases. It shards by key to select which peer is responsible for that key.
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
37
38
39
40

//! gRPC [groupcache_pb::GroupcacheServer] implementation

use crate::groupcache::ValueBounds;
use crate::metrics::METRIC_GET_SERVER_REQUESTS_TOTAL;
use crate::GroupcacheInner;
use async_trait::async_trait;
use groupcache_pb::{GetRequest, GetResponse, Groupcache, RemoveRequest, RemoveResponse};
use metrics::counter;
use tonic::{Request, Response, Status};

#[async_trait]
impl<Value: ValueBounds> Groupcache for GroupcacheInner<Value> {
    async fn get(&self, request: Request<GetRequest>) -> Result<Response<GetResponse>, Status> {
        counter!(METRIC_GET_SERVER_REQUESTS_TOTAL).increment(1);

        let payload = request.into_inner();
        match self.get(&payload.key).await {
            Ok(value) => {
                let result = rmp_serde::to_vec(&value);
                match result {
                    Ok(bytes) => Ok(Response::new(GetResponse { value: Some(bytes) })),
                    Err(err) => Err(Status::internal(err.to_string())),
                }
            }
            Err(err) => Err(Status::internal(err.to_string())),
        }
    }

    async fn remove(
        &self,
        request: Request<RemoveRequest>,
    ) -> Result<Response<RemoveResponse>, Status> {
        let payload = request.into_inner();

        match self.remove(&payload.key).await {
            Ok(_) => Ok(Response::new(RemoveResponse {})),
            Err(err) => Err(Status::internal(err.to_string())),
        }
    }
}