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.