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>>>,
Handles events from a [kube::runtime::watcher()] to delay the application of Deletion events.
kube::runtime::watcher()