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