Struct skytable::sync::Connection

pub struct Connection { /* private fields */ }

Available on crate feature sync only.

A database connection over Skyhash/TCP

Implementations

impl Connection

pub 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 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 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) This function is a subroutine of run_query used to parse the response packet

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

👎Deprecated since 0.7.0: this will be removed in a future release. consider using <code>run_query_raw</code> instead

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

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

Trait Implementations

impl Debug for Connection

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

Formats the value using the given formatter.