Module utils

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

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