kube::runtime::controller

Function trigger_with

Source 
pub fn trigger_with<T, K, I, S>(
    stream: S,
    mapper: impl Fn(T) -> I,
) -> impl Stream<Item = Result<ReconcileRequest<K>, <S as TryStream>::Error>>
where
    S: TryStream<Ok = T>,
    I: IntoIterator,
    <I as IntoIterator>::Item: Into<ReconcileRequest<K>>,
    K: Resource,
Expand description

Helper for building custom trigger filters, see the implementations of trigger_self and trigger_owners for some examples.