@@ -131,37 +131,33 @@ func getClusterType(ctx context.Context, clientset *kubernetes.Clientset, cluste
131
131
// The discovery package is used to discover APIs supported by a Kubernetes API server.
132
132
logger := ctrl .LoggerFrom (ctx )
133
133
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 {
162
135
logger .Info ("Cannot retrieve config, assuming we're on Vanilla Kubernetes" )
163
136
return false , fmt .Sprintf ("ray-dashboard-%s-%s.%s" , cluster .Name , cluster .Namespace , ingressDomain )
164
137
}
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 )
165
161
}
166
162
167
163
func (r * RayClusterReconciler ) isRayDashboardOAuthEnabled () bool {
0 commit comments