kube_runtime::reflector::store

Function store_shared

Source
pub fn store_shared<K>(buf_size: usize) -> (Store<K>, Writer<K>)
where K: Lookup + Clone + 'static, K::DynamicType: Eq + Hash + Clone + Default,
Expand description

Create a (Reader, Writer) for a Store<K> for a typed resource K

The resulting Writer can be subscribed on in order to fan out events from a watcher. The Writer should be passed to a reflector, and the Store is a read-only handle.

A buffer size is used for the underlying message channel. When the buffer is full, backpressure will be applied by waiting for capacity.