Struct BinaryProto

pub struct BinaryProto<T: BufRead + Write + Send> { /* private fields */ }

Implementations

impl<T: BufRead + Write + Send> BinaryProto<T>

pub fn new(stream: T) -> BinaryProto<T>

Trait Implementations

impl<T: BufRead + Write + Send> AuthOperation for BinaryProto<T>

fn list_mechanisms(&mut self) -> MemCachedResult<Vec<String>>

fn auth_start( &mut self, mech: &str, init: &[u8], ) -> MemCachedResult<AuthResponse>

fn auth_continue( &mut self, mech: &str, data: &[u8], ) -> MemCachedResult<AuthResponse>

impl<T: BufRead + Write + Send> CasOperation for BinaryProto<T>

fn set_cas( &mut self, key: &[u8], value: &[u8], flags: u32, expiration: u32, cas: u64, ) -> MemCachedResult<u64>

fn add_cas( &mut self, key: &[u8], value: &[u8], flags: u32, expiration: u32, ) -> MemCachedResult<u64>

fn replace_cas( &mut self, key: &[u8], value: &[u8], flags: u32, expiration: u32, cas: u64, ) -> MemCachedResult<u64>

fn get_cas(&mut self, key: &[u8]) -> MemCachedResult<(Vec<u8>, u32, u64)>

fn getk_cas( &mut self, key: &[u8], ) -> MemCachedResult<(Vec<u8>, Vec<u8>, u32, u64)>

fn increment_cas( &mut self, key: &[u8], amount: u64, initial: u64, expiration: u32, cas: u64, ) -> MemCachedResult<(u64, u64)>

fn decrement_cas( &mut self, key: &[u8], amount: u64, initial: u64, expiration: u32, cas: u64, ) -> MemCachedResult<(u64, u64)>

fn append_cas( &mut self, key: &[u8], value: &[u8], cas: u64, ) -> MemCachedResult<u64>

fn prepend_cas( &mut self, key: &[u8], value: &[u8], cas: u64, ) -> MemCachedResult<u64>

fn touch_cas( &mut self, key: &[u8], expiration: u32, cas: u64, ) -> MemCachedResult<u64>

impl<T: BufRead + Write + Send> MultiOperation for BinaryProto<T>

fn set_multi( &mut self, kv: BTreeMap<&[u8], (&[u8], u32, u32)>, ) -> MemCachedResult<()>

fn delete_multi(&mut self, keys: &[&[u8]]) -> MemCachedResult<()>

fn increment_multi<'a>( &mut self, kv: HashMap<&'a [u8], (u64, u64, u32)>, ) -> MemCachedResult<HashMap<&'a [u8], u64>>

fn get_multi( &mut self, keys: &[&[u8]], ) -> MemCachedResult<HashMap<Vec<u8>, (Vec<u8>, u32)>>

impl<T: BufRead + Write + Send> NoReplyOperation for BinaryProto<T>

fn set_noreply( &mut self, key: &[u8], value: &[u8], flags: u32, expiration: u32, ) -> MemCachedResult<()>

fn add_noreply( &mut self, key: &[u8], value: &[u8], flags: u32, expiration: u32, ) -> MemCachedResult<()>

fn delete_noreply(&mut self, key: &[u8]) -> MemCachedResult<()>

fn replace_noreply( &mut self, key: &[u8], value: &[u8], flags: u32, expiration: u32, ) -> MemCachedResult<()>

fn increment_noreply( &mut self, key: &[u8], amount: u64, initial: u64, expiration: u32, ) -> MemCachedResult<()>

fn decrement_noreply( &mut self, key: &[u8], amount: u64, initial: u64, expiration: u32, ) -> MemCachedResult<()>

fn append_noreply(&mut self, key: &[u8], value: &[u8]) -> MemCachedResult<()>

fn prepend_noreply(&mut self, key: &[u8], value: &[u8]) -> MemCachedResult<()>

impl<T: BufRead + Write + Send> Operation for BinaryProto<T>

fn set( &mut self, key: &[u8], value: &[u8], flags: u32, expiration: u32, ) -> MemCachedResult<()>

fn add( &mut self, key: &[u8], value: &[u8], flags: u32, expiration: u32, ) -> MemCachedResult<()>

fn delete(&mut self, key: &[u8]) -> MemCachedResult<()>

fn replace( &mut self, key: &[u8], value: &[u8], flags: u32, expiration: u32, ) -> MemCachedResult<()>

fn get(&mut self, key: &[u8]) -> MemCachedResult<(Vec<u8>, u32)>

fn getk(&mut self, key: &[u8]) -> MemCachedResult<(Vec<u8>, Vec<u8>, u32)>

fn increment( &mut self, key: &[u8], amount: u64, initial: u64, expiration: u32, ) -> MemCachedResult<u64>

fn decrement( &mut self, key: &[u8], amount: u64, initial: u64, expiration: u32, ) -> MemCachedResult<u64>

fn append(&mut self, key: &[u8], value: &[u8]) -> MemCachedResult<()>

fn prepend(&mut self, key: &[u8], value: &[u8]) -> MemCachedResult<()>

fn touch(&mut self, key: &[u8], expiration: u32) -> MemCachedResult<()>

impl<T: BufRead + Write + Send> ServerOperation for BinaryProto<T>

fn quit(&mut self) -> MemCachedResult<()>

fn flush(&mut self, expiration: u32) -> MemCachedResult<()>

fn noop(&mut self) -> MemCachedResult<()>

fn version(&mut self) -> MemCachedResult<Version>

fn stat(&mut self) -> MemCachedResult<BTreeMap<String, String>>