Struct kube_runtime::reflector::store::Writer

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

A writable Store handle

This is exclusive since it’s not safe to share a single Store between multiple reflectors. In particular, Restarted events will clobber the state of other connected reflectors.

Implementations

impl<K: 'static + Lookup + Clone> Writer<K>

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

pub fn new(dyntype: K::DynamicType) -> Self

Creates a new Writer with the specified dynamic type.

If the dynamic type is default-able (for example when writer is used with k8s_openapi types) you can use Default instead.

pub fn new_shared(buf_size: usize, dyntype: K::DynamicType) -> Self

Creates a new Writer with the specified dynamic type and buffer size.

When the Writer is created through new_shared, it will be able to be subscribed. Stored objects will be propagated to all subscribers. The buffer size is used for the underlying channel. An object is cleared from the buffer only when all subscribers have seen it.

If the dynamic type is default-able (for example when writer is used with k8s_openapi types) you can use Default instead.

pub fn as_reader(&self) -> Store<K>

Return a read handle to the store

Multiple read handles may be obtained, by either calling as_reader multiple times, or by calling Store::clone() afterwards.

pub fn subscribe(&self) -> Option<ReflectHandle<K>>

Return a handle to a subscriber

Multiple subscribe handles may be obtained, by either calling subscribe multiple times, or by calling clone()

This function returns a Some when the Writer is constructed through Writer::new_shared or store_shared, and a None otherwise.

pub fn apply_watcher_event(&mut self, event: &Event<K>)

Applies a single watcher event to the store

Trait Implementations

impl<K: Debug + 'static + Lookup + Clone> Debug for Writer<K>

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

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

Formats the value using the given formatter.

impl<K> Default for Writer<K>

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

fn default() -> Self

Returns the “default value” for a type.