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 items.