Module kube_runtime::scheduler

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.