Module kube_runtime::scheduler[−][src]

Expand description

Delays and deduplicates [Stream] items

Structs

HoldUnless

See Scheduler::hold_unless

ScheduleRequest

A request to re-emit message at a given Instant (run_at).

Scheduler

Enums

Error

Functions

scheduler

Stream transformer that delays and deduplicates [Stream] items.

Type Definitions

Result