Client

Struct Client 

Source
pub struct Client { /* private fields */ }

Implementations§

Source§

impl Client

Source

pub fn new( peers: impl IntoIterator<Item = impl AsRef<str>> + ExactSizeIterator, endpoint_config: ClientEndpointConfig, ) -> Self

Source

pub fn set_auth_token(&self, token: HeaderValue)

Updates the authentication token used by the client.

This token will be used for all future requests made by the client. This method can be used to do live token rotation, without having to create a new client.

Source

pub fn clear_auth_token(&self)

Clears the authentication token used by the client.

This will cause the client to make requests without an authentication token.

Source

pub fn watcher(&self) -> Arc<WatcherHandle>

Creates, or returns an existing [Watcher] that can be used to watch keys in etcd.

If there is already an existing watcher, this method will return a clone of it, otherwise it will create a new watcher. When all references to the watcher are dropped, the watcher will be dropped as well.

The watcher coalesces watch requests, so that multiple requests watching the same key will only result in a single watch request being made to etcd.

Source

pub async fn grant_lease(&self, ttl: Duration) -> Result<LeaseHandle, Status>

Acquires a lease with the given TTL, spawning a background worker to continue to keep-alive the lease as long as the returned lease::LeaseHandle is alive.

The lease handle provides methods for checking if the lease is still valid.

ttl must be above 10 seconds.

Auto Trait Implementations§

§

impl !Freeze for Client

§

impl !RefUnwindSafe for Client

§

impl Send for Client

§

impl Sync for Client

§

impl Unpin for Client

§

impl !UnwindSafe for Client

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> IntoRequest<T> for T

Source§

fn into_request(self) -> Request<T>

Wrap the input message T in a tonic::Request
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

Source§

fn vzip(self) -> V

Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more