@@ -585,29 +585,32 @@ func main() {
585
585
flags .FatalIfFailed (flags .NewInvalidFlagError ("k8s-mode" , "must be one of: in-cluster, off-cluster" ))
586
586
}
587
587
588
- controllerManagerMetricsOptions := ctrlmetrics.Options {
589
- BindAddress : * fControllerManagerMetricsAddr ,
590
- }
591
- mgr , err := ctrl .NewManager (srv .InternalProxiedK8SClientConfig , ctrl.Options {
592
- Scheme : kruntime .NewScheme (),
593
- Metrics : controllerManagerMetricsOptions ,
594
- })
595
- if err != nil {
596
- klog .Errorf ("problem creating controller manager: %v" , err )
597
- }
598
-
599
- catalogService := olm .NewDummyCatalogService ()
600
- if err = controllers .NewClusterCatalogReconciler (mgr , catalogService ).SetupWithManager (mgr ); err != nil {
601
- klog .Errorf ("failed to start ClusterCatalog reconciler: %v" , err )
602
- }
588
+ // Controllers are behind Tech Preview flag
589
+ if * fTechPreview {
590
+ controllerManagerMetricsOptions := ctrlmetrics.Options {
591
+ BindAddress : * fControllerManagerMetricsAddr ,
592
+ }
593
+ mgr , err := ctrl .NewManager (srv .InternalProxiedK8SClientConfig , ctrl.Options {
594
+ Scheme : kruntime .NewScheme (),
595
+ Metrics : controllerManagerMetricsOptions ,
596
+ })
597
+ if err != nil {
598
+ klog .Errorf ("problem creating controller manager: %v" , err )
599
+ }
603
600
604
- klog .Info ("starting manager" )
605
- mgrContext := ctrl .SetupSignalHandler ()
606
- go func () {
607
- if err := mgr .Start (mgrContext ); err != nil {
608
- klog .Errorf ("problem running manager: %v" , err )
601
+ catalogService := olm .NewDummyCatalogService ()
602
+ if err = controllers .NewClusterCatalogReconciler (mgr , catalogService ).SetupWithManager (mgr ); err != nil {
603
+ klog .Errorf ("failed to start ClusterCatalog reconciler: %v" , err )
609
604
}
610
- }()
605
+
606
+ klog .Info ("starting manager" )
607
+ mgrContext := ctrl .SetupSignalHandler ()
608
+ go func () {
609
+ if err := mgr .Start (mgrContext ); err != nil {
610
+ klog .Errorf ("problem running manager: %v" , err )
611
+ }
612
+ }()
613
+ }
611
614
612
615
apiServerEndpoint := * fK8sPublicEndpoint
613
616
if apiServerEndpoint == "" {
0 commit comments