Struct Client 

pub struct Client { /* private fields */ }

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

Implementations

impl Client

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

new connect 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

async fn authenticate<R>(&self, req: R) -> Result<AuthenticateResponse>

where R: Into<AuthenticateRequest>,

async fn auth_status(&self) -> Result<AuthStatusResponse>

async fn auth_enable(&self) -> Result<AuthEnableResponse>

async fn auth_disable(&self) -> Result<AuthDisableResponse>

async fn role_add<R>(&self, req: R) -> Result<AuthRoleAddResponse>

where R: Into<AuthRoleAddRequest>,

async fn role_delete<R>(&self, req: R) -> Result<AuthRoleDeleteResponse>

where R: Into<AuthRoleDeleteRequest>,

async fn role_list(&self) -> Result<AuthRoleListResponse>

impl Clone for Client

fn clone(&self) -> Client

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl ClusterOp for Client

async fn member_add<R>(&self, req: R) -> Result<MemberAddResponse>

where R: Into<MemberAddRequest>,

async fn member_remove<R>(&self, req: R) -> Result<MemberRemoveResponse>

where R: Into<MemberRemoveRequest>,

async fn member_update<R>(&self, req: R) -> Result<MemberUpdateResponse>

where R: Into<MemberUpdateRequest>,

async fn member_list(&self) -> Result<MemberListResponse>

impl KeyValueOp for Client

async fn put<R>(&self, req: R) -> Result<PutResponse>

where R: Into<PutRequest>,

async fn get<R>(&self, req: R) -> Result<RangeResponse>

where R: Into<RangeRequest>,

async fn get_all(&self) -> Result<RangeResponse>

async fn get_by_prefix<K>(&self, p: K) -> Result<RangeResponse>

where K: Into<Vec<u8>>,

async fn get_range<F, E>(&self, from: F, end: E) -> Result<RangeResponse>

where F: Into<Vec<u8>>, E: Into<Vec<u8>>,

async fn delete<R>(&self, req: R) -> Result<DeleteResponse>

where R: Into<DeleteRequest>,

async fn delete_all(&self) -> Result<DeleteResponse>

async fn delete_by_prefix<K>(&self, p: K) -> Result<DeleteResponse>

where K: Into<Vec<u8>>,

async fn delete_range<F, E>(&self, from: F, end: E) -> Result<DeleteResponse>

where F: Into<Vec<u8>>, E: Into<Vec<u8>>,

async fn txn<R>(&self, req: R) -> Result<TxnResponse>

where R: Into<TxnRequest>,

async fn compact<R>(&self, req: R) -> Result<CompactResponse>

where R: Into<CompactRequest>,

impl LeaseOp for Client

async fn grant_lease<R>(&self, req: R) -> Result<LeaseGrantResponse>

where R: Into<LeaseGrantRequest>,

async fn revoke<R>(&self, req: R) -> Result<LeaseRevokeResponse>

where R: Into<LeaseRevokeRequest>,

async fn keep_alive_for(&self, lease_id: LeaseId) -> Result<LeaseKeepAlive>

async fn time_to_live<R>(&self, req: R) -> Result<LeaseTimeToLiveResponse>

where R: Into<LeaseTimeToLiveRequest>,

impl WatchOp for Client

async fn watch<R>(&self, req: R) -> Result<(WatchStream, WatchCanceler)>

where R: Into<WatchCreateRequest>,