Module kube::runtime::utils

Available on crate feature runtime only.

Helpers for manipulating built-in streams

Modules

• predicates
  Predicate functions for WatchStreamExt::predicate_filter
• stream_subscribe

Structs

• CancelableJoinHandle
  A [JoinHandle] that cancels the Future when dropped, rather than detaching it
• EventFlatten
  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.
• ResetTimerBackoff
  A [Backoff] wrapper that resets after a fixed duration has elapsed.
• StreamBackoff
  Applies a [Backoff] policy to a [Stream]
• StreamSubscribe
  Exposes the StreamSubscribe::subscribe() method which allows additional consumers of events from a stream without consuming the stream itself.

Traits

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