kube_runtime::scheduler

Function debounced_scheduler

source
pub fn debounced_scheduler<T: Eq + Hash + Clone, S: Stream<Item = ScheduleRequest<T>>>(
    requests: S,
    debounce: Duration,
) -> Scheduler<T, S>
Expand description

Stream transformer that delays and deduplicates Stream items.

The debounce period lets the scheduler deduplicate requests that ask to be emitted instantly, by making sure we wait for the configured period of time to receive an uninterrupted request before actually emitting it.

For more info, see scheduler().