[−][src]Enum kube_runtime::watcher::State
The internal FSM driving the Watcher
NOTE: This isn't intended to be used externally or part of the external API, but it's published to document the internal workings.
Variants
The Watcher is empty, and the next poll() will start the initial LIST to get all existing objects
The initial LIST was successful, so we should move on to starting the actual watch.
Fields of InitListed
resource_version: String
The watch is in progress, from this point we just return events from the server.
If the connection is disrupted then we propagate the error but try to restart the watch stream by
returning to the InitListed
state.
If we fall out of the K8s watch window then we propagate the error and fall back doing a re-list
with Empty
.
Fields of Watching
resource_version: String
stream: BoxStream<'static, Result<WatchEvent<K>>>
Trait Implementations
Auto Trait Implementations
impl<K> !RefUnwindSafe for State<K>
impl<K> Send for State<K>
impl<K> !Sync for State<K>
impl<K> Unpin for State<K>
impl<K> !UnwindSafe for State<K>
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> From<T> for T
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,