picodata-driver 3.0.0

A native asyncronous cluster-aware Picodata client
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56

#![allow(clippy::mutable_key_type, clippy::inline_always)]

mod accessor;
pub(crate) mod bucket;
mod client;
mod config;
mod discovery;
mod error;
mod instance;
mod manager;
pub(crate) mod metadata;
mod pool;
mod strategy;
mod tls;
pub(crate) mod topology;

pub use client::*;
pub use config::*;
pub use error::*;
pub use strategy::*;
pub use topology::view::{BucketMap, Instance, Replicaset, Tier, Topology};

/// Creates a picodata `Client`
///
/// # Parameters
///
/// - `config`: A string with parameters.
///
/// # Errors
///
/// - Any [`Error`] than `Client` initializer may return.
///
/// # Returns
///
/// An instances of `Client` on success or an `Error` if init did fail.
pub async fn connect(config: &str) -> Result<Client, Error> {
    let cfg = Config::from(config.parse::<pg::Config>()?);
    Client::new(cfg).await
}

/// Creates a picodata `Client`
///
/// # Parameters
///
/// - `config`: A config.
///
/// # Errors
///
/// - Any [`Error`] than `Client` initializer may return.
///
/// # Returns
///
/// An instances of `Client` on success or an `Error` if init did fail.
pub async fn connect_cfg(cfg: Config) -> Result<Client, Error> {
    Client::new(cfg).await
}