Module kube_runtime::scheduler

Delays and deduplicates [Stream] items

Structs

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

Functions

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