@@ -158,6 +158,7 @@ pub fn trigger_owners<KOwner, S>(
158
158
stream : S ,
159
159
owner_type : KOwner :: DynamicType ,
160
160
child_type : <S :: Ok as Resource >:: DynamicType ,
161
+ namespaced_owners : bool ,
161
162
) -> impl Stream < Item = Result < ReconcileRequest < KOwner > , S :: Error > >
162
163
where
163
164
S : TryStream ,
@@ -168,7 +169,10 @@ where
168
169
{
169
170
let mapper = move |obj : S :: Ok | {
170
171
let meta = obj. meta ( ) . clone ( ) ;
171
- let ns = meta. namespace ;
172
+ let ns = match namespaced_owners {
173
+ true => meta. namespace ,
174
+ false => None ,
175
+ } ;
172
176
let owner_type = owner_type. clone ( ) ;
173
177
meta. owner_references
174
178
. into_iter ( )
@@ -762,6 +766,7 @@ where
762
766
metadata_watcher ( api, wc) . touched_objects ( ) ,
763
767
self . dyntype . clone ( ) ,
764
768
dyntype,
769
+ false ,
765
770
) ;
766
771
self . trigger_selector . push ( child_watcher. boxed ( ) ) ;
767
772
self
@@ -830,7 +835,7 @@ where
830
835
where
831
836
Child :: DynamicType : Debug + Eq + Hash + Clone ,
832
837
{
833
- let child_watcher = trigger_owners ( trigger, self . dyntype . clone ( ) , dyntype) ;
838
+ let child_watcher = trigger_owners ( trigger, self . dyntype . clone ( ) , dyntype, false ) ;
834
839
self . trigger_selector . push ( child_watcher. boxed ( ) ) ;
835
840
self
836
841
}
@@ -1155,7 +1160,7 @@ where
1155
1160
/// use kube::{Api, Client, ResourceExt};
1156
1161
/// use kube_runtime::{
1157
1162
/// controller::{Controller, Action},
1158
- /// watcher,
1163
+ /// watcher,
1159
1164
/// };
1160
1165
/// use std::{convert::Infallible, sync::Arc};
1161
1166
/// Controller::new(
0 commit comments