File tree 2 files changed +14
-12
lines changed
operator-framework-core/src/main/java/io/javaoperatorsdk/operator/processing/event/source/informer
sample-operators/tomcat-operator/src/main/java/io/javaoperatorsdk/operator/sample
2 files changed +14
-12
lines changed Original file line number Diff line number Diff line change @@ -29,6 +29,18 @@ public static <T extends HasMetadata> PrimaryResourcesRetriever<T> fromLabel(
29
29
return fromMetadata (nameKey , namespaceKey , true );
30
30
}
31
31
32
+ public static <T extends HasMetadata > PrimaryResourcesRetriever <T > fromOwnerReference () {
33
+ return resource -> {
34
+ var ownerReferences = resource .getMetadata ().getOwnerReferences ();
35
+ if (!ownerReferences .isEmpty ()) {
36
+ return Set .of (new ResourceID (ownerReferences .get (0 ).getName (),
37
+ resource .getMetadata ().getNamespace ()));
38
+ } else {
39
+ return Collections .emptySet ();
40
+ }
41
+ };
42
+ }
43
+
32
44
private static <T extends HasMetadata > PrimaryResourcesRetriever <T > fromMetadata (
33
45
String nameKey , String namespaceKey , boolean isLabel ) {
34
46
return resource -> {
Original file line number Diff line number Diff line change 4
4
import java .io .InputStream ;
5
5
import java .util .List ;
6
6
import java .util .Objects ;
7
- import java .util .Set ;
8
7
9
8
import org .slf4j .Logger ;
10
9
import org .slf4j .LoggerFactory ;
22
21
import io .javaoperatorsdk .operator .api .reconciler .EventSourceInitializer ;
23
22
import io .javaoperatorsdk .operator .api .reconciler .Reconciler ;
24
23
import io .javaoperatorsdk .operator .api .reconciler .UpdateControl ;
25
- import io .javaoperatorsdk .operator .processing .event .ResourceID ;
26
24
import io .javaoperatorsdk .operator .processing .event .source .EventSource ;
27
25
import io .javaoperatorsdk .operator .processing .event .source .informer .InformerEventSource ;
26
+ import io .javaoperatorsdk .operator .processing .event .source .informer .Mappers ;
28
27
29
28
import static io .javaoperatorsdk .operator .api .reconciler .Constants .NO_FINALIZER ;
30
- import static java .util .Collections .EMPTY_SET ;
31
29
32
30
/**
33
31
* Runs a specified number of Tomcat app server Pods. It uses a Deployment to create the Pods. Also
@@ -52,15 +50,7 @@ public List<EventSource> prepareEventSources(EventSourceContext<Tomcat> context)
52
50
.runnableInformer (0 );
53
51
54
52
return List .of (new InformerEventSource <>(
55
- deploymentInformer , d -> {
56
- var ownerReferences = d .getMetadata ().getOwnerReferences ();
57
- if (!ownerReferences .isEmpty ()) {
58
- return Set .of (new ResourceID (ownerReferences .get (0 ).getName (),
59
- d .getMetadata ().getNamespace ()));
60
- } else {
61
- return EMPTY_SET ;
62
- }
63
- }));
53
+ deploymentInformer , Mappers .fromOwnerReference ()));
64
54
}
65
55
66
56
@ Override
You can’t perform that action at this time.
0 commit comments