[−][src]Function kube_runtime::watcher::watcher
pub fn watcher<K: Meta + Clone + DeserializeOwned + Send + 'static>(
api: Api<K>,
list_params: ListParams
) -> impl Stream<Item = Result<Event<K>>> + Send
Watches a Kubernetes Resource for changes
Errors are propagated to the client as Err
. Tries to recover (by reconnecting and resyncing as required)
if polled again after an error.
Migration from kube::runtime
This is similar to the legacy kube::runtime::Informer
, or the watching half of client-go's Reflector
.
Renamed to avoid confusion with client-go's Informer
(which watches a Reflector
for updates, rather
the Kubernetes API).