File tree Expand file tree Collapse file tree 1 file changed +15
-1
lines changed
operator-framework-core/src/main/java/io/javaoperatorsdk/operator Expand file tree Collapse file tree 1 file changed +15
-1
lines changed Original file line number Diff line number Diff line change @@ -67,9 +67,23 @@ public <R extends CustomResource> void register(
6767 new EventDispatcher (
6868 controller , finalizer , new EventDispatcher .CustomResourceFacade (client ));
6969
70+ // check that the custom resource is known by the cluster
71+ final var crdName = configuration .getCRDName ();
72+ final var crd =
73+ k8sClient .apiextensions ().v1 ().customResourceDefinitions ().withName (crdName ).get ();
74+ final var controllerName = configuration .getName ();
75+ if (crd == null ) {
76+ log .warn (
77+ "'{}' CRD was not found on the {} cluster, skipping '{}' controller registration" ,
78+ crdName ,
79+ configurationService .getClientConfiguration ().getMasterUrl (),
80+ controllerName );
81+ return ;
82+ }
83+
7084 CustomResourceCache customResourceCache = new CustomResourceCache ();
7185 DefaultEventHandler defaultEventHandler =
72- new DefaultEventHandler (customResourceCache , dispatcher , configuration . getName () , retry );
86+ new DefaultEventHandler (customResourceCache , dispatcher , controllerName , retry );
7387 DefaultEventSourceManager eventSourceManager =
7488 new DefaultEventSourceManager (defaultEventHandler , retry != null );
7589 defaultEventHandler .setEventSourceManager (eventSourceManager );
You can’t perform that action at this time.
0 commit comments