Struct skytable::aio::TcpConnection

pub struct TcpConnection<C: AsyncWriteExt + AsyncReadExt + Unpin> { /* private fields */ }

The underlying socket type

Implementations

impl<C: AsyncWriteExt + AsyncReadExt + Unpin> TcpConnection<C>

pub async fn execute_pipeline( &mut self, pipeline: &Pipeline ) -> ClientResult<Vec<Response>>

Execute a pipeline. The server returns the queries in the order they were sent (unless otherwise set).

pub async fn query(&mut self, q: &Query) -> ClientResult<Response>

Run a query and return a raw Response

pub async fn query_parse<T: FromResponse>( &mut self, q: &Query ) -> ClientResult<T>

Run and parse a query into the indicated type. The type must implement FromResponse

pub fn reset_buffer(&mut self)

Call this if the internally allocated buffer is growing too large and impacting your performance. However, normally you will not need to call this

Trait Implementations

impl<C: Debug + AsyncWriteExt + AsyncReadExt + Unpin> Debug for TcpConnection<C>

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

Formats the value using the given formatter.