File tree Expand file tree Collapse file tree 2 files changed +11
-7
lines changed
operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing Expand file tree Collapse file tree 2 files changed +11
-7
lines changed Original file line number Diff line number Diff line change 1
1
package io .javaoperatorsdk .operator .processing ;
2
2
3
3
import java .util .Optional ;
4
+ import java .util .function .Predicate ;
5
+ import java .util .stream .Stream ;
4
6
5
7
import io .fabric8 .kubernetes .api .model .HasMetadata ;
6
8
import io .javaoperatorsdk .operator .processing .event .ResourceID ;
@@ -9,4 +11,9 @@ public interface ResourceCache<T extends HasMetadata> {
9
11
10
12
Optional <T > getCustomResource (ResourceID resourceID );
11
13
14
+ default Stream <T > getCachedCustomResources () {
15
+ return getCachedCustomResources (a -> true );
16
+ }
17
+
18
+ Stream <T > getCachedCustomResources (Predicate <T > predicate );
12
19
}
Original file line number Diff line number Diff line change 8
8
import java .util .function .Predicate ;
9
9
import java .util .stream .Stream ;
10
10
11
+ import org .slf4j .Logger ;
12
+ import org .slf4j .LoggerFactory ;
13
+
11
14
import io .fabric8 .kubernetes .api .model .HasMetadata ;
12
15
import io .fabric8 .kubernetes .api .model .KubernetesResourceList ;
13
16
import io .fabric8 .kubernetes .client .KubernetesClientException ;
23
26
import io .javaoperatorsdk .operator .processing .ResourceCache ;
24
27
import io .javaoperatorsdk .operator .processing .event .ResourceID ;
25
28
26
- import org .slf4j .Logger ;
27
- import org .slf4j .LoggerFactory ;
28
-
29
29
import static io .javaoperatorsdk .operator .processing .KubernetesResourceUtils .getName ;
30
30
import static io .javaoperatorsdk .operator .processing .KubernetesResourceUtils .getUID ;
31
31
import static io .javaoperatorsdk .operator .processing .KubernetesResourceUtils .getVersion ;
@@ -180,10 +180,7 @@ public Optional<T> getCustomResource(ResourceID resourceID) {
180
180
}
181
181
}
182
182
183
- public Stream <T > getCachedCustomResources () {
184
- return getCachedCustomResources (a -> true );
185
- }
186
-
183
+ @ Override
187
184
public Stream <T > getCachedCustomResources (Predicate <T > predicate ) {
188
185
return sharedIndexInformers .values ().stream ()
189
186
.flatMap (i -> i .getStore ().list ().stream ().filter (predicate ));
You can’t perform that action at this time.
0 commit comments