Struct kube_runtime::reflector::store::Store

pub struct Store<K: 'static + Resource> { /* fields omitted */ }

A readable cache of Kubernetes objects of kind K

Cloning will produce a new reference to the same backing store.

Cannot be constructed directly since one writer handle is required, use Writer::as_reader() instead.

Implementations

impl<K: 'static + Clone + Resource> Store<K>

#[must_use]pub fn get(&self, key: &ObjectRef<K>) -> Option<K>

Retrieve a clone() of the entry referred to by key, if it is in the cache.

Note that this is a cache and may be stale. Deleted objects may still exist in the cache despite having been deleted in the cluster, and new objects may not yet exist in the cache. If any of these are a problem for you then you should abort your reconciler and retry later. If you use kube_rt::controller then you can do this by returning an error and specifying a reasonable error_policy.

pub fn state(&self) -> Vec<K>

Return a full snapshot of the current values

pub fn iter(&self) -> Iter<ObjectRef<K>, K>

Return a guarded dashmap iterator of our state

This creates an iterator over all entries in the map. This does not take a snapshot of the map and thus changes during the lifetime of the iterator may or may not become visible in the iterator.

Trait Implementations

impl<K: 'static + Resource> Clone for Store<K> where
    K: Clone, 

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<K: Debug + 'static + Resource> Debug for Store<K>

fn fmt(&self, f: &mut Formatter) -> Result

Formats the value using the given formatter.