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
).Functions
Stream transformer that delays and deduplicates [
Stream
] items.