Module kube_runtime::scheduler

source · [−]
Expand description

Delays and deduplicates [Stream] items

Structs

HoldUnless
See Scheduler::hold_unless
ScheduleRequest
A request to re-emit message at a given Instant (run_at).
Scheduler

Functions

scheduler
Stream transformer that delays and deduplicates [Stream] items.