29
29
public class InformerManager <T extends HasMetadata , C extends ResourceConfiguration <T >>
30
30
implements LifecycleAware , IndexerResourceCache <T >, UpdatableCache <T > {
31
31
32
- private static final String ALL_NAMESPACE_MAP_KEY = "allNamespace " ;
32
+ private static final String ALL_NAMESPACES_MAP_KEY = "allNamespaces " ;
33
33
private static final Logger log = LoggerFactory .getLogger (InformerManager .class );
34
34
35
35
private final Map <String , InformerWrapper <T >> sources = new ConcurrentHashMap <>();
@@ -58,7 +58,7 @@ void initSources(MixedOperation<T, KubernetesResourceList<T>, Resource<T>> clien
58
58
final var filteredBySelectorClient =
59
59
client .inAnyNamespace ().withLabelSelector (labelSelector );
60
60
final var source =
61
- createEventSource (filteredBySelectorClient , eventHandler , ALL_NAMESPACE_MAP_KEY );
61
+ createEventSource (filteredBySelectorClient , eventHandler , ALL_NAMESPACES_MAP_KEY );
62
62
log .debug ("Registered {} -> {} for any namespace" , this , source );
63
63
} else {
64
64
targetNamespaces .forEach (
@@ -130,7 +130,7 @@ public Stream<T> list(Predicate<T> predicate) {
130
130
@ Override
131
131
public Stream <T > list (String namespace , Predicate <T > predicate ) {
132
132
if (isWatchingAllNamespaces ()) {
133
- return getSource (ALL_NAMESPACE_MAP_KEY )
133
+ return getSource (ALL_NAMESPACES_MAP_KEY )
134
134
.map (source -> source .list (namespace , predicate ))
135
135
.orElse (Stream .empty ());
136
136
} else {
@@ -142,7 +142,7 @@ public Stream<T> list(String namespace, Predicate<T> predicate) {
142
142
143
143
@ Override
144
144
public Optional <T > get (ResourceID resourceID ) {
145
- return getSource (resourceID .getNamespace ().orElse (ALL_NAMESPACE_MAP_KEY ))
145
+ return getSource (resourceID .getNamespace ().orElse (ALL_NAMESPACES_MAP_KEY ))
146
146
.flatMap (source -> source .get (resourceID ))
147
147
.map (cloner ::clone );
148
148
}
@@ -153,24 +153,24 @@ public Stream<ResourceID> keys() {
153
153
}
154
154
155
155
private boolean isWatchingAllNamespaces () {
156
- return sources .containsKey (ALL_NAMESPACE_MAP_KEY );
156
+ return sources .containsKey (ALL_NAMESPACES_MAP_KEY );
157
157
}
158
158
159
159
private Optional <InformerWrapper <T >> getSource (String namespace ) {
160
- namespace = isWatchingAllNamespaces () || namespace == null ? ALL_NAMESPACE_MAP_KEY : namespace ;
160
+ namespace = isWatchingAllNamespaces () || namespace == null ? ALL_NAMESPACES_MAP_KEY : namespace ;
161
161
return Optional .ofNullable (sources .get (namespace ));
162
162
}
163
163
164
164
@ Override
165
165
public T remove (ResourceID key ) {
166
- return getSource (key .getNamespace ().orElse (ALL_NAMESPACE_MAP_KEY ))
166
+ return getSource (key .getNamespace ().orElse (ALL_NAMESPACES_MAP_KEY ))
167
167
.map (c -> c .remove (key ))
168
168
.orElse (null );
169
169
}
170
170
171
171
@ Override
172
172
public void put (ResourceID key , T resource ) {
173
- getSource (key .getNamespace ().orElse (ALL_NAMESPACE_MAP_KEY ))
173
+ getSource (key .getNamespace ().orElse (ALL_NAMESPACES_MAP_KEY ))
174
174
.ifPresentOrElse (c -> c .put (key , resource ),
175
175
() -> log .warn (
176
176
"Cannot put resource in the cache. No related cache found: {}. Resource: {}" ,
0 commit comments