Struct kube::runtime::Informer

pub struct Informer<K> where
    K: Clone + DeserializeOwned + Meta,  { /* fields omitted */ }

An event informer for a Resource

This watches a Resource<K>, by:

• seeding the intial resourceVersion with a list call (optional)
• keeping track of resourceVersions during every poll
• recovering when resourceVersions get desynced

Methods

impl<K> Informer<K> where
    K: Clone + DeserializeOwned + Meta, 

pub fn new(client: APIClient, lp: ListParams, r: Resource) -> Self

Create a reflector with a kube client on a kube resource

pub fn init_from(self, v: String) -> Self

Initialize from a prior version

pub async fn poll<'_>(
    &'_ self
) -> Result<impl Stream<Item = Result<WatchEvent<K>>>>

Start a single watch stream

Opens a long polling GET and returns the complete WatchEvents as a Stream. You should always poll. When this call ends, call it again. Do not call it from more than one context.

This function will handle error handling up to a point:

• if we go out of history (410 Gone), we reset to latest
• if we failed an initial poll, we will retry All real errors are bubbled up, as are WachEvent::Error instances. In the retry/reset cases we wait 10s between each attempt.

If you need to track the resourceVersion you can use Informer::version().

pub async fn reset<'_>(&'_ self)

Reset the resourceVersion to 0

Note: This will cause duplicate Added events for all existing resources

pub fn version(&self) -> String

Return the current version

Trait Implementations

impl<K: Clone> Clone for Informer<K> where
    K: Clone + DeserializeOwned + Meta, 

fn clone(&self) -> Informer<K>

Returns a copy of the value.

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

Performs copy-assignment from source.