@@ -94,12 +94,14 @@ func (db *db) ListClusters(_ context.Context) (*appv1.ClusterList, error) {
9494
9595// CreateCluster creates a cluster
9696func (db * db ) CreateCluster (ctx context.Context , c * appv1.Cluster ) (* appv1.Cluster , error ) {
97- settings , err := db .settingsMgr .GetSettings ()
98- if err != nil {
99- return nil , err
100- }
101- if c .Server == appv1 .KubernetesInternalAPIServerAddr && ! settings .InClusterEnabled {
102- return nil , status .Errorf (codes .InvalidArgument , "cannot register cluster: in-cluster has been disabled" )
97+ if c .Server == appv1 .KubernetesInternalAPIServerAddr {
98+ settings , err := db .settingsMgr .GetSettings ()
99+ if err != nil {
100+ return nil , err
101+ }
102+ if ! settings .InClusterEnabled {
103+ return nil , status .Errorf (codes .InvalidArgument , "cannot register cluster: in-cluster has been disabled" )
104+ }
103105 }
104106 secName , err := URIToSecretName ("cluster" , c .Server )
105107 if err != nil {
@@ -225,12 +227,14 @@ func (db *db) getClusterSecret(server string) (*corev1.Secret, error) {
225227
226228// GetCluster returns a cluster from a query
227229func (db * db ) GetCluster (_ context.Context , server string ) (* appv1.Cluster , error ) {
228- argoSettings , err := db .settingsMgr .GetSettings ()
229- if err != nil {
230- return nil , err
231- }
232- if server == appv1 .KubernetesInternalAPIServerAddr && ! argoSettings .InClusterEnabled {
233- return nil , status .Errorf (codes .NotFound , "cluster %q is disabled" , server )
230+ if server == appv1 .KubernetesInternalAPIServerAddr {
231+ argoSettings , err := db .settingsMgr .GetSettings ()
232+ if err != nil {
233+ return nil , err
234+ }
235+ if ! argoSettings .InClusterEnabled {
236+ return nil , status .Errorf (codes .NotFound , "cluster %q is disabled" , server )
237+ }
234238 }
235239
236240 informer , err := db .settingsMgr .GetSecretsInformer ()
0 commit comments