Struct etcd_client::ElectionClient
source · [−]#[repr(transparent)]pub struct ElectionClient { /* private fields */ }Expand description
Client for Elect operations.
Implementations
sourceimpl ElectionClient
impl ElectionClient
sourcepub async fn campaign(
&mut self,
name: impl Into<Vec<u8>>,
value: impl Into<Vec<u8>>,
lease: i64
) -> Result<CampaignResponse, Error>
pub async fn campaign(
&mut self,
name: impl Into<Vec<u8>>,
value: impl Into<Vec<u8>>,
lease: i64
) -> Result<CampaignResponse, Error>
Puts a value as eligible for the election on the prefix key. Multiple sessions can participate in the election for the same prefix, but only one can be the leader at a time.
sourcepub async fn proclaim(
&mut self,
value: impl Into<Vec<u8>>,
options: Option<ProclaimOptions>
) -> Result<ProclaimResponse, Error>
pub async fn proclaim(
&mut self,
value: impl Into<Vec<u8>>,
options: Option<ProclaimOptions>
) -> Result<ProclaimResponse, Error>
Lets the leader announce a new value without another election.
sourcepub async fn leader(
&mut self,
name: impl Into<Vec<u8>>
) -> Result<LeaderResponse, Error>
pub async fn leader(
&mut self,
name: impl Into<Vec<u8>>
) -> Result<LeaderResponse, Error>
Returns the leader value for the current election.
sourcepub async fn observe(
&mut self,
name: impl Into<Vec<u8>>
) -> Result<ObserveStream, Error>
pub async fn observe(
&mut self,
name: impl Into<Vec<u8>>
) -> Result<ObserveStream, Error>
Returns a channel that reliably observes ordered leader proposals as GetResponse values on every current elected leader key.
sourcepub async fn resign(
&mut self,
option: Option<ResignOptions>
) -> Result<ResignResponse, Error>
pub async fn resign(
&mut self,
option: Option<ResignOptions>
) -> Result<ResignResponse, Error>
Releases election leadership and then start a new election
Trait Implementations
sourceimpl Clone for ElectionClient
impl Clone for ElectionClient
sourcefn clone(&self) -> ElectionClient
fn clone(&self) -> ElectionClient
Returns a copy of the value. Read more
1.0.0 · sourcefn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from source. Read more
Auto Trait Implementations
impl !RefUnwindSafe for ElectionClient
impl Send for ElectionClient
impl Sync for ElectionClient
impl Unpin for ElectionClient
impl !UnwindSafe for ElectionClient
Blanket Implementations
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<T> Instrument for T
impl<T> Instrument for T
sourcefn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
sourcefn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
sourceimpl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
sourcefn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message T in a tonic::Request
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
fn vzip(self) -> V
sourceimpl<T> WithSubscriber for T
impl<T> WithSubscriber for T
sourcefn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
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
sourcefn with_current_subscriber(self) -> WithDispatch<Self>
fn with_current_subscriber(self) -> WithDispatch<Self>
Attaches the current default Subscriber to this type, returning a
WithDispatch wrapper. Read more