Struct Store 

pub struct Store<K: 'static + Lookup>
where
    K::DynamicType: Hash + Eq,
{ /* private fields */ }

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 + Lookup> Store<K>

where K::DynamicType: Eq + Hash + Clone,

pub async fn wait_until_ready(&self) -> Result<(), WriterDropped>

Wait for the store to be populated by Kubernetes.

Note that polling this will not await the source of the stream that populates the Writer. The reflector stream must be awaited separately.

Errors

Returns an error if the Writer was dropped before any value was written.

pub fn get(&self, key: &ObjectRef<K>) -> Option<Arc<K>>

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

key.namespace is ignored for cluster-scoped resources.

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<Arc<K>>

Return a full snapshot of the current values

pub fn find<P>(&self, predicate: P) -> Option<Arc<K>>

where P: Fn(&K) -> bool,

Retrieve a clone() of the entry found by the given predicate

pub fn state_filter<P>(&self, predicate: P) -> Vec<Arc<K>>

where P: Fn(&K) -> bool,

Return a filtered snapshot of the current values, retaining only objects matching predicate

Note: the store read lock is held for the entire duration of predicate evaluation. Avoid blocking or expensive operations inside the predicate.

pub fn state_filter_selector(&self, selector: &Selector) -> Vec<Arc<K>>

where K: ResourceExt,

Return a filtered snapshot of the current values, retaining only objects whose labels match selector

Example

let selector: Selector = Expression::Equal("app".into(), "nginx".into()).into();
let result = reader.state_filter_selector(&selector);

pub fn len(&self) -> usize

Return the number of elements in the store

pub fn is_empty(&self) -> bool

Return whether the store is empty

Trait Implementations

impl<K: 'static + Lookup> Clone for Store<K>

where K::DynamicType: Hash + Eq, Arc<RwLock<AHashMap<ObjectRef<K>, Arc<K>>>>: Clone, Arc<DelayedInit<()>>: Clone,

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<K> Debug for Store<K>

where K::DynamicType: Hash + Eq + Debug, K: Debug + 'static + Lookup,

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

Formats the value using the given formatter.