Struct rsmc_tokio::TokioConnection

pub struct TokioConnection { /* fields omitted */ }

A TokioConnection uses the tokio runtime to form TCP connections to memcached.

Trait Implementations

impl Clone for TokioConnection

fn clone(&self) -> TokioConnection

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Connection for TokioConnection

fn connect<'async_trait>(
    url: String
) -> Pin<Box<dyn Future<Output = Result<Self, Error>> + Send + 'async_trait>> where
    Self: 'async_trait, 

Connect to a memcached server over TCP.

fn read<'life0, 'life1, 'async_trait>(
    &'life0 mut self,
    buf: &'life1 mut Vec<u8>
) -> Pin<Box<dyn Future<Output = Result<usize, Error>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

Read to fill the incoming buffer.

fn write<'life0, 'life1, 'async_trait>(
    &'life0 mut self,
    data: &'life1 [u8]
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    'life1: 'async_trait,
    Self: 'async_trait, 

Write an entire buffer to the TCP stream.

fn read_packet<'life0, 'async_trait, P>(
    &'life0 mut self,
    compressor: P
) -> Pin<Box<dyn Future<Output = Result<Packet, Error>> + Send + 'async_trait, Global>> where
    'life0: 'async_trait,
    P: Compressor + 'async_trait,
    Self: 'async_trait, 

Read a packet response, possibly decompressing it. It is most likely unnecessary to implement this yourself.

fn write_packet<'life0, 'async_trait, P>(
    &'life0 mut self,
    compressor: P,
    packet: Packet
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait, Global>> where
    'life0: 'async_trait,
    P: Compressor + 'async_trait,
    Self: 'async_trait, 

Write a packet request, possibly compressing it. It is most likely unnecessary to implement this yourself.

impl Debug for TokioConnection

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.