Expand description
Helpers for manipulating built-in streams
Re-exports§
pub use EventDecode as EventFlatten;
Modules§
- predicates
- Predicate functions for
WatchStreamExt::predicate_filter
Structs§
- Cancelable
Join Handle - A
JoinHandle
that cancels theFuture
when dropped, rather than detaching it - Event
Decode - Stream returned by the
applied_objects
andtouched_objects
method. - Event
Modify - Stream returned by the
modify
method. Modifies theEvent
item returned by the inner stream by callingmodify
on it. - Predicate
Filter - Stream returned by the
predicate_filter
method. - Reflect
- Stream returned by the
reflect
method - Reset
Timer Backoff - A
Backoff
wrapper that resets after a fixed duration has elapsed. - Stream
Backoff - Applies a
Backoff
policy to aStream
Traits§
- Backoff
- Predicate
- A predicate is a hasher of Kubernetes objects stream filtering
- Watch
Stream Ext - Extension trait for streams returned by
watcher
orreflector