@@ -131,37 +131,33 @@ func getClusterType(ctx context.Context, clientset *kubernetes.Clientset, cluste
131131 // The discovery package is used to discover APIs supported by a Kubernetes API server.
132132 logger := ctrl .LoggerFrom (ctx )
133133 config , err := ctrl .GetConfig ()
134- if err == nil && config != nil {
135- dclient , err := getDiscoveryClient (config )
136- if err == nil && dclient != nil {
137- apiGroupList , err := dclient .ServerGroups ()
138- if err != nil {
139- logger .Info ("Error while querying ServerGroups, assuming we're on Vanilla Kubernetes" )
140- return false , ""
141- } else {
142- for i := 0 ; i < len (apiGroupList .Groups ); i ++ {
143- if strings .HasSuffix (apiGroupList .Groups [i ].Name , ".openshift.io" ) {
144- logger .Info ("We detected being on OpenShift!" )
145- return true , ""
146- }
147- }
148- onKind , _ := isOnKindCluster (clientset )
149- if onKind && ingressDomain == "" {
150- logger .Info ("We detected being on a KinD cluster!" )
151- return false , "kind"
152- } else {
153- logger .Info ("We detected being on Vanilla Kubernetes!" )
154- return false , fmt .Sprintf ("ray-dashboard-%s-%s.%s" , cluster .Name , cluster .Namespace , ingressDomain )
155- }
156- }
157- } else {
158- logger .Info ("Cannot retrieve a DiscoveryClient, assuming we're on Vanilla Kubernetes" )
159- return false , fmt .Sprintf ("ray-dashboard-%s-%s.%s" , cluster .Name , cluster .Namespace , ingressDomain )
160- }
161- } else {
134+ if err != nil && config == nil {
162135 logger .Info ("Cannot retrieve config, assuming we're on Vanilla Kubernetes" )
163136 return false , fmt .Sprintf ("ray-dashboard-%s-%s.%s" , cluster .Name , cluster .Namespace , ingressDomain )
164137 }
138+ dclient , err := getDiscoveryClient (config )
139+ if err != nil && dclient == nil {
140+ logger .Info ("Cannot retrieve a DiscoveryClient, assuming we're on Vanilla Kubernetes" )
141+ return false , fmt .Sprintf ("ray-dashboard-%s-%s.%s" , cluster .Name , cluster .Namespace , ingressDomain )
142+ }
143+ apiGroupList , err := dclient .ServerGroups ()
144+ if err != nil {
145+ logger .Info ("Error while querying ServerGroups, assuming we're on Vanilla Kubernetes" )
146+ return false , ""
147+ }
148+ for i := 0 ; i < len (apiGroupList .Groups ); i ++ {
149+ if strings .HasSuffix (apiGroupList .Groups [i ].Name , ".openshift.io" ) {
150+ logger .Info ("We detected being on OpenShift!" )
151+ return true , ""
152+ }
153+ }
154+ onKind , _ := isOnKindCluster (clientset )
155+ if onKind && ingressDomain == "" {
156+ logger .Info ("We detected being on a KinD cluster!" )
157+ return false , "kind"
158+ }
159+ logger .Info ("We detected being on Vanilla Kubernetes!" )
160+ return false , fmt .Sprintf ("ray-dashboard-%s-%s.%s" , cluster .Name , cluster .Namespace , ingressDomain )
165161}
166162
167163func (r * RayClusterReconciler ) isRayDashboardOAuthEnabled () bool {
0 commit comments