Module kube_runtime::scheduler
source · Expand description
Delays and deduplicates [Stream
] items
Structs
- See
Scheduler::hold
- A request to re-emit
message
at a givenInstant
(run_at
).
Functions
- Stream transformer that delays and deduplicates [
Stream
] items. - Stream transformer that delays and deduplicates [
Stream
] items.