Module utils

Source
Expand description

Helpers for manipulating built-in streams

Re-exports§

pub use EventDecode as EventFlatten;

Modules§

predicates
Predicate functions for WatchStreamExt::predicate_filter

Structs§

CancelableJoinHandle
A JoinHandle that cancels the Future when dropped, rather than detaching it
EventDecode
Stream returned by the applied_objects and touched_objects method.
EventModify
Stream returned by the modify method. Modifies the Event item returned by the inner stream by calling modify on it.
PredicateFilter
Stream returned by the predicate_filter method.
Reflect
Stream returned by the reflect method
ResetTimerBackoff
A Backoff wrapper that resets after a fixed duration has elapsed.
StreamBackoff
Applies a Backoff policy to a Stream

Traits§

Backoff
Predicate
A predicate is a hasher of Kubernetes objects stream filtering
WatchStreamExt
Extension trait for streams returned by watcher or reflector