rcache 0.1.1

A basic, featureless memory cache with a TCP frontend analogous to memcached.
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

use codec::CacheCodec;
use message::Message;
use tokio_io::codec::Framed;
use tokio_io::{AsyncRead, AsyncWrite};
use tokio_proto::multiplex::{ClientProto, ServerProto};
use std::io;

/// `CacheProto`
pub struct CacheProto;

impl<T: AsyncRead + AsyncWrite + 'static> ClientProto<T> for CacheProto {
    type Request = Message;
    type Response = Message;

    type Transport = Framed<T, CacheCodec>;
    type BindTransport = Result<Self::Transport, io::Error>;

    fn bind_transport(&self, io: T) -> Self::BindTransport {
        Ok(io.framed(CacheCodec))
    }
}

impl<T: AsyncRead + AsyncWrite + 'static> ServerProto<T> for CacheProto {
    type Request = Message;
    type Response = Message;

    type Transport = Framed<T, CacheCodec>;
    type BindTransport = Result<Self::Transport, io::Error>;

    fn bind_transport(&self, io: T) -> Self::BindTransport {
        Ok(io.framed(CacheCodec))
    }
}