Struct DbClient

pub struct DbClient { /* private fields */ }

DbClient handle

Implementations

impl DbClient

pub fn new(addr: String) -> Self

Trait Implementations

impl Client for DbClient

fn connect<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Starts a TCP connection with an rldb node

fn ping<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<PingResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Ping command interface

fn get<'life0, 'async_trait>( &'life0 mut self, key: Bytes, ) -> Pin<Box<dyn Future<Output = Result<GetResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get command interface

fn replication_get<'life0, 'async_trait>( &'life0 mut self, key: Bytes, ) -> Pin<Box<dyn Future<Output = Result<ReplicationGetResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

ReplicationGet command interface

fn put<'life0, 'async_trait>( &'life0 mut self, key: Bytes, value: Value, context: Option<String>, replication: bool, ) -> Pin<Box<dyn Future<Output = Result<PutResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Put command interface

fn heartbeat<'life0, 'async_trait>( &'life0 mut self, known_nodes: Vec<Node>, ) -> Pin<Box<dyn Future<Output = Result<HeartbeatResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Heartbeat command interface

fn join_cluster<'life0, 'async_trait>( &'life0 mut self, known_cluster_node_addr: String, ) -> Pin<Box<dyn Future<Output = Result<JoinClusterResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

JoinCluster command interface

fn cluster_state<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<ClusterStateResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

ClusterState command interface

impl Debug for DbClient

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

Formats the value using the given formatter.