Struct etcd_client::WatchResponse [−][src]
#[repr(transparent)]pub struct WatchResponse(_);
Response for Watch
operation.
Implementations
impl WatchResponse
[src]
impl WatchResponse
[src]pub fn header(&self) -> Option<&ResponseHeader>
[src]
Watch response header.
pub fn take_header(&mut self) -> Option<ResponseHeader>
[src]
Takes the header out of the response, leaving a None
in its place.
pub const fn watch_id(&self) -> i64
[src]
The ID of the watcher that corresponds to the response.
pub const fn canceled(&self) -> bool
[src]
canceled
is set to true if the response is for a cancel watch request.
No further events will be sent to the canceled watcher.
pub const fn compact_revision(&self) -> i64
[src]
compact_revision
is set to the minimum index if a watcher tries to watch
at a compacted index.
This happens when creating a watcher at a compacted revision or the watcher cannot catch up with the progress of the key-value store.
The client should treat the watcher as canceled and should not try to create any watcher with the same start_revision again.
pub fn cancel_reason(&self) -> &str
[src]
Indicates the reason for canceling the watcher.
pub fn events(&self) -> &[Event]
[src]
Events happened on the watched keys.
Trait Implementations
impl Clone for WatchResponse
[src]
impl Clone for WatchResponse
[src]fn clone(&self) -> WatchResponse
[src]
pub fn clone_from(&mut self, source: &Self)
1.0.0[src]
Auto Trait Implementations
impl RefUnwindSafe for WatchResponse
impl RefUnwindSafe for WatchResponse
impl Send for WatchResponse
impl Send for WatchResponse
impl Sync for WatchResponse
impl Sync for WatchResponse
impl Unpin for WatchResponse
impl Unpin for WatchResponse
impl UnwindSafe for WatchResponse
impl UnwindSafe for WatchResponse
Blanket Implementations
impl<T> Instrument for T
[src]
impl<T> Instrument for T
[src]pub fn instrument(self, span: Span) -> Instrumented<Self>
[src]
pub fn in_current_span(self) -> Instrumented<Self>
[src]
impl<T> Instrument for T
[src]
impl<T> Instrument for T
[src]pub fn instrument(self, span: Span) -> Instrumented<Self>
[src]
pub fn in_current_span(self) -> Instrumented<Self>
[src]
impl<T> IntoRequest<T> for T
[src]
impl<T> IntoRequest<T> for T
[src]pub fn into_request(self) -> Request<T>
[src]
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
pub fn vzip(self) -> V
impl<T> WithSubscriber for T
[src]
impl<T> WithSubscriber for T
[src]pub fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
[src]
S: Into<Dispatch>,