Struct Client

pub struct Client { /* private fields */ }

Client is an abstraction for grouping etcd operations and managing underlying network communications.

Implementations

impl Client

pub fn with_channel(channel: Channel, token: Option<String>) -> Self

Build clients from tonic Channel directly.

For advanced users, it provides the ability to control more details about the connection.

pub async fn connect_with_token( cfg: &ClientConfig, token: Option<String>, ) -> Result<Self>

pub async fn connect(cfg: ClientConfig) -> Result<Self>

Connects to etcd cluster and returns a client.

Errors

Will returns Err if failed to contact with given endpoints or authentication failed.

Trait Implementations

impl AuthOp for Client

fn authenticate<'life0, 'async_trait, R>( &'life0 self, req: R, ) -> Pin<Box<dyn Future<Output = Result<AuthenticateResponse>> + Send + 'async_trait>>

where R: Into<AuthenticateRequest> + Send + 'async_trait, Self: 'async_trait, 'life0: 'async_trait,

impl Clone for Client

fn clone(&self) -> Client

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl ClusterOp for Client

fn member_add<'life0, 'async_trait, R>( &'life0 self, req: R, ) -> Pin<Box<dyn Future<Output = Result<MemberAddResponse>> + Send + 'async_trait>>

where R: Into<MemberAddRequest> + Send + 'async_trait, Self: 'async_trait, 'life0: 'async_trait,

fn member_remove<'life0, 'async_trait, R>( &'life0 self, req: R, ) -> Pin<Box<dyn Future<Output = Result<MemberRemoveResponse>> + Send + 'async_trait>>

where R: Into<MemberRemoveRequest> + Send + 'async_trait, Self: 'async_trait, 'life0: 'async_trait,

fn member_update<'life0, 'async_trait, R>( &'life0 self, req: R, ) -> Pin<Box<dyn Future<Output = Result<MemberUpdateResponse>> + Send + 'async_trait>>

where R: Into<MemberUpdateRequest> + Send + 'async_trait, Self: 'async_trait, 'life0: 'async_trait,

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

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

impl KeyValueOp for Client

fn put<'life0, 'async_trait, R>( &'life0 self, req: R, ) -> Pin<Box<dyn Future<Output = Result<PutResponse>> + Send + 'async_trait>>

where R: Into<PutRequest> + Send + 'async_trait, Self: 'async_trait, 'life0: 'async_trait,

fn get<'life0, 'async_trait, R>( &'life0 self, req: R, ) -> Pin<Box<dyn Future<Output = Result<RangeResponse>> + Send + 'async_trait>>

where R: Into<RangeRequest> + Send + 'async_trait, Self: 'async_trait, 'life0: 'async_trait,

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

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

fn get_by_prefix<'life0, 'async_trait, K>( &'life0 self, p: K, ) -> Pin<Box<dyn Future<Output = Result<RangeResponse>> + Send + 'async_trait>>

where K: Into<Vec<u8>> + Send + 'async_trait, Self: 'async_trait, 'life0: 'async_trait,

fn get_range<'life0, 'async_trait, F, E>( &'life0 self, from: F, end: E, ) -> Pin<Box<dyn Future<Output = Result<RangeResponse>> + Send + 'async_trait>>

where F: Into<Vec<u8>> + Send + 'async_trait, E: Into<Vec<u8>> + Send + 'async_trait, Self: 'async_trait, 'life0: 'async_trait,

fn delete<'life0, 'async_trait, R>( &'life0 self, req: R, ) -> Pin<Box<dyn Future<Output = Result<DeleteResponse>> + Send + 'async_trait>>

where R: Into<DeleteRequest> + Send + 'async_trait, Self: 'async_trait, 'life0: 'async_trait,

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

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

fn delete_by_prefix<'life0, 'async_trait, K>( &'life0 self, p: K, ) -> Pin<Box<dyn Future<Output = Result<DeleteResponse>> + Send + 'async_trait>>

where K: Into<Vec<u8>> + Send + 'async_trait, Self: 'async_trait, 'life0: 'async_trait,

fn delete_range<'life0, 'async_trait, F, E>( &'life0 self, from: F, end: E, ) -> Pin<Box<dyn Future<Output = Result<DeleteResponse>> + Send + 'async_trait>>

where F: Into<Vec<u8>> + Send + 'async_trait, E: Into<Vec<u8>> + Send + 'async_trait, Self: 'async_trait, 'life0: 'async_trait,

fn txn<'life0, 'async_trait, R>( &'life0 self, req: R, ) -> Pin<Box<dyn Future<Output = Result<TxnResponse>> + Send + 'async_trait>>

where R: Into<TxnRequest> + Send + 'async_trait, Self: 'async_trait, 'life0: 'async_trait,

fn compact<'life0, 'async_trait, R>( &'life0 self, req: R, ) -> Pin<Box<dyn Future<Output = Result<CompactResponse>> + Send + 'async_trait>>

where R: Into<CompactRequest> + Send + 'async_trait, Self: 'async_trait, 'life0: 'async_trait,

impl LeaseOp for Client

fn grant_lease<'life0, 'async_trait, R>( &'life0 self, req: R, ) -> Pin<Box<dyn Future<Output = Result<LeaseGrantResponse>> + Send + 'async_trait>>

where R: Into<LeaseGrantRequest> + Send + 'async_trait, Self: 'async_trait, 'life0: 'async_trait,

fn revoke<'life0, 'async_trait, R>( &'life0 self, req: R, ) -> Pin<Box<dyn Future<Output = Result<LeaseRevokeResponse>> + Send + 'async_trait>>

where R: Into<LeaseRevokeRequest> + Send + 'async_trait, Self: 'async_trait, 'life0: 'async_trait,

fn keep_alive_for<'life0, 'async_trait>( &'life0 self, lease_id: LeaseId, ) -> Pin<Box<dyn Future<Output = Result<LeaseKeepAlive>> + Send + 'async_trait>>

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

fn time_to_live<'life0, 'async_trait, R>( &'life0 self, req: R, ) -> Pin<Box<dyn Future<Output = Result<LeaseTimeToLiveResponse>> + Send + 'async_trait>>

where R: Into<LeaseTimeToLiveRequest> + Send + 'async_trait, Self: 'async_trait, 'life0: 'async_trait,

impl WatchOp for Client

fn watch<'life0, 'async_trait, R>( &'life0 self, req: R, ) -> Pin<Box<dyn Future<Output = Result<(WatchStream, WatchCanceler)>> + Send + 'async_trait>>

where R: Into<WatchCreateRequest> + Send + 'async_trait, Self: 'async_trait, 'life0: 'async_trait,