Преглед на файлове

read ip address from svc status spec

Alexander Belanger преди 5 години
родител
ревизия
723eb5b041
променени са 1 файла, в които са добавени 5 реда и са изтрити 5 реда
  1. 5 5
      internal/kubernetes/domain/domain.go

+ 5 - 5
internal/kubernetes/domain/domain.go

@@ -43,7 +43,11 @@ func GetNGINXIngressServiceIP(clientset kubernetes.Interface) (string, bool, err
 		return "", false, nil
 	}
 
-	return nginxSvc.Spec.LoadBalancerIP, exists, nil
+	if ipArr := nginxSvc.Status.LoadBalancer.Ingress; len(ipArr) > 0 {
+		return ipArr[0].IP, true, nil
+	}
+
+	return "", false, nil
 }
 
 // DNSRecord wraps the gorm DNSRecord model
@@ -155,16 +159,12 @@ func (e *DNSRecord) createServiceWithEndpoint(clientset kubernetes.Interface) er
 
 	// case service spec on ipv4
 	if isIPv4 {
-		fmt.Println("TYPE IS IPV4", e.Endpoint)
 		svcSpec.ClusterIP = "None"
 	} else {
-		fmt.Println("TYPE IS EXTERNAL NAME", e.Endpoint)
 		svcSpec.Type = "ExternalName"
 		svcSpec.ExternalName = e.Endpoint
 	}
 
-	fmt.Println("SVC SPEC IS", svcSpec)
-
 	// create service
 	_, err := clientset.CoreV1().Services("default").Create(
 		context.TODO(),