Struct skytable::aio::Connection

pub struct Connection { /* private fields */ }

Available on crate feature aio only.

An asynchronous database connection over Skyhash/TCP

Implementations

impl Connection

pub async fn new(host: &str, port: u16) -> SkyResult<Self>

Create a new connection to a Skytable instance hosted on host and running on port

impl Connection

pub async fn run_query<T: FromSkyhashBytes, Q: AsRef<Query>>(
    &mut self,
    query: Q
) -> SkyResult<T>

Runs a query using Self::run_query_raw and attempts to return a type provided by the user

pub async fn run_query_raw<Q: AsRef<Query>>(
    &mut self,
    query: Q
) -> SkyResult<Element>

This function will write a Query to the stream and read the response from the server. It will then determine if the returned response is complete or incomplete or invalid and return an appropriate variant of Error wrapped in [IoResult] for any I/O errors that may occur

Panics

This method will panic if the Query supplied is empty (i.e has no arguments)

pub async fn run_simple_query(&mut self, query: &Query) -> SkyQueryResult

👎 Deprecated since 0.7.0:

this will be removed in a future release. consider using run_query_raw instead

pub async fn run_pipeline(
    &mut self,
    pipeline: Pipeline
) -> SkyResult<Vec<Element>>

Runs a pipelined query. See the Pipeline documentation for a guide on usage