Function vector::kubernetes::reflector::custom_reflector

source ยท 
pub async fn custom_reflector<K, W>(
    store: Writer<K>,
    meta_cache: MetaCache,
    stream: W,
    delay_deletion: Duration,
)
where
    K: Resource + Clone + Debug,
    K::DynamicType: Eq + Hash + Clone,
    W: Stream<Item = Result<Event<K>>>,
Expand description

Handles events from a [kube::runtime::watcher()] to delay the application of Deletion events.