Struct skytable::aio::TlsConnection

source · [−]

pub struct TlsConnection { /* private fields */ }

This is supported on crate feature aio and (crate features aio-ssl or aio-sslv) only.

Expand description

An asynchronous database connection over Skyhash/TLS

Implementations

impl TlsConnection

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

Pass the host and port and the path to the CA certificate to use for TLS

impl TlsConnection

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

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_pipeline(
&mut self,
pipeline: Pipeline
) -> SkyResult<Vec<Element>>

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

Auto Trait Implementations

impl RefUnwindSafe for TlsConnection

impl Send for TlsConnection

impl Sync for TlsConnection

impl Unpin for TlsConnection

impl UnwindSafe for TlsConnection

Blanket Implementations

impl<T> Any for T where
T: 'static + ?Sized,

pub fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

impl<T> AsyncActions for T where
T: AsyncSocket,

fn dbsize<'s>(&'s mut self) -> AsyncResult<'_, SkyResult<u64>>

This is supported on crate feature aio only.

Get the number of keys present in the database

fn del<'s>(
&'s mut self,
key: impl IntoSkyhashAction + 's
) -> AsyncResult<'_, SkyResult<u64>>

This is supported on crate feature aio only.

Deletes a single or a number of keys Read more

fn exists<'s>(
&'s mut self,
key: impl IntoSkyhashAction + 's
) -> AsyncResult<'_, SkyResult<u64>>

This is supported on crate feature aio only.

Checks if a key (or keys) exist(s) Read more

fn flushdb<'s>(&'s mut self) -> AsyncResult<'_, SkyResult<()>>

This is supported on crate feature aio only.

Removes all the keys present in the database

fn get<'s, T: FromSkyhashBytes>(
&'s mut self,
key: impl IntoSkyhashBytes + 's
) -> AsyncResult<'_, SkyResult<T>>

This is supported on crate feature aio only.

Get the value of a key Read more

fn keylen<'s>(
&'s mut self,
key: impl IntoSkyhashBytes + 's
) -> AsyncResult<'_, SkyResult<u64>>

This is supported on crate feature aio only.

Get the length of a key Read more

fn lskeys<'s, T: FromSkyhashBytes>(
&'s mut self,
count: u64
) -> AsyncResult<'_, SkyResult<T>>

This is supported on crate feature aio only.

Returns a vector of keys Read more

fn mget<'s, T: FromSkyhashBytes>(
&'s mut self,
keys: impl IntoSkyhashAction + 's
) -> AsyncResult<'_, SkyResult<T>>

This is supported on crate feature aio only.

Get multiple keys Read more

fn mksnap<'s>(&'s mut self) -> AsyncResult<'_, SkyResult<SnapshotResult>>

This is supported on crate feature aio only.

Creates a snapshot Read more

fn mset<'s, T: IntoSkyhashBytes + 's, U: IntoSkyhashBytes + 's>(
    &'s mut self,
    keys: impl GetIterator<T> + 's,
    values: impl GetIterator<U> + 's
) -> AsyncResult<'_, SkyResult<u64>>

This is supported on crate feature aio only.

Sets the value of multiple keys and values and returns the number of keys that were set Read more

fn mupdate<'s, T: IntoSkyhashBytes + 's, U: IntoSkyhashBytes + 's>(
    &'s mut self,
    keys: impl GetIterator<T> + 's,
    values: impl GetIterator<U> + 's
) -> AsyncResult<'_, SkyResult<u64>>

This is supported on crate feature aio only.

Updates the value of multiple keys and values and returns the number of keys that were updated Read more

fn pop<'s, T: FromSkyhashBytes>(
&'s mut self,
keys: impl IntoSkyhashBytes + 's
) -> AsyncResult<'_, SkyResult<T>>

This is supported on crate feature aio only.

Consumes a key if it exists Read more

fn mpop<'s, T: FromSkyhashBytes>(
&'s mut self,
keys: impl IntoSkyhashAction + 's
) -> AsyncResult<'_, SkyResult<T>>

This is supported on crate feature aio only.

Consumes the provided keys if they exist Read more

fn sdel<'s>(
&'s mut self,
keys: impl IntoSkyhashAction + 's
) -> AsyncResult<'_, SkyResult<bool>>

This is supported on crate feature aio only.

Deletes all the provided keys if they exist or doesn’t do anything at all. This method will return true if all the provided keys were deleted, else it will return false Read more

fn set<'s>(
    &'s mut self,
    key: impl IntoSkyhashBytes + 's,
    value: impl IntoSkyhashBytes + 's
) -> AsyncResult<'_, SkyResult<bool>>

This is supported on crate feature aio only.

Set the value of a key Read more

fn sset<'s, T: IntoSkyhashBytes + 's, U: IntoSkyhashBytes + 's>(
    &'s mut self,
    keys: impl GetIterator<T> + 's,
    values: impl GetIterator<U> + 's
) -> AsyncResult<'_, SkyResult<bool>>

This is supported on crate feature aio only.

Sets the value of all the provided keys or does nothing. This method will return true if all the keys were set or will return false if none were set Read more

fn supdate<'s, T: IntoSkyhashBytes + 's, U: IntoSkyhashBytes + 's>(
    &'s mut self,
    keys: impl GetIterator<T> + 's,
    values: impl GetIterator<U> + 's
) -> AsyncResult<'_, SkyResult<bool>>

This is supported on crate feature aio only.

Updates the value of all the provided keys or does nothing. This method will return true if all the keys were updated or will return false if none were updated. Read more

fn update<'s>(
    &'s mut self,
    key: impl IntoSkyhashBytes + 's,
    value: impl IntoSkyhashBytes + 's
) -> AsyncResult<'_, SkyResult<()>>

This is supported on crate feature aio only.

Update the value of a key Read more

fn uset<'s, T: IntoSkyhashBytes + 's, U: IntoSkyhashBytes + 's>(
    &'s mut self,
    keys: impl GetIterator<T> + 's,
    values: impl GetIterator<U> + 's
) -> AsyncResult<'_, SkyResult<u64>>

This is supported on crate feature aio only.

Updates or sets all the provided keys and returns the number of keys that were set Read more

impl<T> AsyncDdl for T where
T: AsyncSocket,

fn switch<'s, T: IntoSkyhashBytes + 's>(
&'s mut self,
entity: T
) -> AsyncResult<'_, SkyResult<()>>

This is supported on crate feature aio only.

This function switches to the provided entity. Read more

fn create_keyspace<'s>(
&'s mut self,
ks: impl IntoSkyhashBytes + 's
) -> AsyncResult<'_, SkyResult<bool>>

This is supported on crate feature aio only.

Create the provided keyspace Read more

fn create_table<'s>(
&'s mut self,
table: impl CreateTableIntoQuery + 's
) -> AsyncResult<'_, SkyResult<()>>

This is supported on crate feature aio only.

Create a table from the provided configuration

fn drop_table<'s>(
&'s mut self,
table: impl IntoSkyhashBytes + 's
) -> AsyncResult<'_, SkyResult<bool>>

This is supported on crate feature aio only.

Drop the provided table Read more

fn drop_keyspace<'s>(
    &'s mut self,
    keyspace: impl IntoSkyhashBytes + 's,
    force: bool
) -> AsyncResult<'_, SkyResult<()>>

This is supported on crate feature aio only.

Drop the provided keyspace Read more

fn whereami<'s>(&'s mut self) -> AsyncResult<'_, SkyResult<WhereAmI>>

This is supported on crate feature aio only.

Check what keyspace this connection is currently connected to

impl<T> Borrow<T> for T where
T: ?Sized,

const: unstable · source

pub fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

impl<T> BorrowMut<T> for T where
T: ?Sized,

const: unstable · source

pub fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more

impl<T> From<T> for T

const: unstable · source

pub fn from(t: T) -> T

Performs the conversion.

impl<T, U> Into<U> for T where
U: From<T>,

const: unstable · source

pub fn into(self) -> U

Performs the conversion.

impl<T, U> TryFrom<U> for T where
U: Into<T>,

type Error = Infallible

The type returned in the event of a conversion error.

const: unstable · source

pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.

impl<T, U> TryInto<U> for T where
U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

const: unstable · source

pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.