Struct Client 

pub struct Client { /* private fields */ }

Client which is used to query picodata.

Implementations

impl Client

pub async fn new(config: Config) -> Result<Self, Error>

Creates a new instance of picodata client.

Errors

Returns Error if manager initialization fails.

pub async fn new_with_strategy<S>( config: Config, strategy: S, ) -> Result<Self, Error>

where S: Strategy,

Creates a new instance of picodata client with a custom strategy.

Errors

Returns Error if manager initialization fails.

pub fn query<'a>( &'a self, sql: &'a str, params: &'a [&'a (dyn ToSql + Sync)], ) -> Query<'a, Vec<Row>>

Query picodata cluster. Returns a builder that supports .on_master(bool), .bucket_id(u64) and .instance(&str) before .await.

pub fn execute<'a>( &'a self, sql: &'a str, params: &'a [&'a (dyn ToSql + Sync)], ) -> Query<'a, u64>

Execute on picodata cluster. Returns a builder that supports .on_master(bool), .bucket_id(u64) and .instance(&str) before .await.

pub async fn topology(&self) -> Result<Topology, Error>

Returns a snapshot of the cluster topology. Tier::bucket_map checks a tier’s buckets.

Errors

Returns Error::Closed if the client has been closed.

pub async fn ping(&self) -> Result<(), Error>

Ping each instance of picodata cluster.

Errors

Returns Error if any instance fails to respond.

pub async fn close(&self) -> Result<(), Error>

Closes pool manager.

Errors

Returns Error if the manager is already closed.

Trait Implementations

impl Clone for Client

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.