Просмотр исходного кода

Merge pull request #2051 from porter-dev/master

Ingress class name casing -> staging
abelanger5 4 лет назад
Родитель
Сommit
976bcdeeec
1 измененных файлов с 20 добавлено и 14 удалено
  1. 20 14
      internal/kubernetes/prometheus/metrics.go

+ 20 - 14
internal/kubernetes/prometheus/metrics.go

@@ -65,26 +65,32 @@ func GetIngressesWithNGINXAnnotation(clientset kubernetes.Interface) ([]SimpleIn
 
 
 	if v1beta1Err == nil && len(v1beta1IngressList.Items) > 0 {
 	if v1beta1Err == nil && len(v1beta1IngressList.Items) > 0 {
 		for _, ingress := range v1beta1IngressList.Items {
 		for _, ingress := range v1beta1IngressList.Items {
-			if ingressAnn, found := ingress.ObjectMeta.Annotations["kubernetes.io/ingress.class"]; found {
-				if ingressAnn == "nginx" {
-					res = append(res, SimpleIngress{
-						Name:      ingress.ObjectMeta.Name,
-						Namespace: ingress.ObjectMeta.Namespace,
-					})
-				}
+			if ingressAnn, found := ingress.ObjectMeta.Annotations["kubernetes.io/ingress.class"]; found && ingressAnn == "nginx" {
+				res = append(res, SimpleIngress{
+					Name:      ingress.ObjectMeta.Name,
+					Namespace: ingress.ObjectMeta.Namespace,
+				})
+			} else if *ingress.Spec.IngressClassName == "nginx" {
+				res = append(res, SimpleIngress{
+					Name:      ingress.ObjectMeta.Name,
+					Namespace: ingress.ObjectMeta.Namespace,
+				})
 			}
 			}
 		}
 		}
 	}
 	}
 
 
 	if v1Err == nil && len(v1IngressList.Items) > 0 {
 	if v1Err == nil && len(v1IngressList.Items) > 0 {
 		for _, ingress := range v1IngressList.Items {
 		for _, ingress := range v1IngressList.Items {
-			if ingressAnn, found := ingress.ObjectMeta.Annotations["kubernetes.io/ingress.class"]; found {
-				if ingressAnn == "nginx" {
-					res = append(res, SimpleIngress{
-						Name:      ingress.ObjectMeta.Name,
-						Namespace: ingress.ObjectMeta.Namespace,
-					})
-				}
+			if ingressAnn, found := ingress.ObjectMeta.Annotations["kubernetes.io/ingress.class"]; found && (ingressAnn == "nginx") {
+				res = append(res, SimpleIngress{
+					Name:      ingress.ObjectMeta.Name,
+					Namespace: ingress.ObjectMeta.Namespace,
+				})
+			} else if *ingress.Spec.IngressClassName == "nginx" {
+				res = append(res, SimpleIngress{
+					Name:      ingress.ObjectMeta.Name,
+					Namespace: ingress.ObjectMeta.Namespace,
+				})
 			}
 			}
 		}
 		}
 	}
 	}