Struct MultiStore 

pub struct MultiStore<K>
where
    K: Resource + Clone + 'static,
    K::DynamicType: Hash + Eq + Clone + Debug + Default,
{ /* private fields */ }

A reflector view over one or more namespace-scoped watches.

When the operator runs cluster-wide (NamespaceScope::All) this holds exactly one shard built from Api::all, and every operation is a direct pass-through — the cluster-wide deployment behaves exactly as it did before namespace scoping existed.

When the operator is scoped to a namespace set it holds one shard per namespace. That sharding is load-bearing, not an implementation detail: a single reflector Store cannot be fed by several namespace watches merged with select_all, because watcher::Event::InitDone makes the store replace its entire contents with the buffer of whichever watch just finished listing (kube_runtime::reflector::store does mem::swap(&mut *store, &mut self.buffer)). Merging N watches into one writer would leave the store holding only the last namespace to sync — silently, and again on every watch reconnect. Sharding keeps each watch’s Init/InitDone cycle confined to its own store.

Implementations

impl<K> MultiStore<K>

where K: Resource + Clone + 'static, K::DynamicType: Hash + Eq + Clone + Debug + Default,

pub fn new(shards: Vec<Store<K>>) -> Self

Build a view over the given shards.

Panics

Panics if shards is empty. An empty view would make every lookup return nothing while the operator reported itself healthy — a far worse failure than a loud one at startup.

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

All objects across every shard.

Shards are disjoint by construction (one namespace each, or a single cluster-wide shard), so no de-duplication is needed.

pub fn shard_count(&self) -> usize

Number of shards backing this view (1 when cluster-wide).

Trait Implementations

impl<K> Clone for MultiStore<K>

where K: Resource + Clone + 'static + Clone, K::DynamicType: Hash + Eq + Clone + Debug + Default,

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

Returns a duplicate of the value.

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

Performs copy-assignment from source.