Skip to content

Commit a138416

Browse files
committed
considering NodePort,ClusterIP svc
1 parent eab2ea0 commit a138416

File tree

1 file changed

+9
-6
lines changed

1 file changed

+9
-6
lines changed

controllers/ingress/reconcile.go

+9-6
Original file line numberDiff line numberDiff line change
@@ -149,8 +149,9 @@ func (r *ingressController) updateIngressStatus(ctx context.Context, ingress *ne
149149
}
150150

151151
func svcStatusToIngress(svc *corev1.Service) []networkingv1.IngressLoadBalancerIngress {
152-
if svc.Spec.Type == corev1.ServiceTypeLoadBalancer {
153-
var src = svc.Status.LoadBalancer.Ingress
152+
switch svc.Spec.Type {
153+
case corev1.ServiceTypeLoadBalancer:
154+
src = svc.Status.LoadBalancer.Ingress
154155
dst := make([]networkingv1.IngressLoadBalancerIngress, len(src))
155156
for i := range src {
156157
dst[i] = networkingv1.IngressLoadBalancerIngress{
@@ -160,11 +161,13 @@ func svcStatusToIngress(svc *corev1.Service) []networkingv1.IngressLoadBalancerI
160161
}
161162
}
162163
return dst
164+
case corev1.ServiceTypeNodePort, corev1.ServiceTypeClusterIP:
165+
return []networkingv1.IngressLoadBalancerIngress{{
166+
IP: svc.Spec.ClusterIP,
167+
}}
168+
default:
169+
return nil
163170
}
164-
// Assign ClusterIP for NodePort service
165-
return []networkingv1.IngressLoadBalancerIngress{{
166-
IP: svc.Spec.ClusterIP,
167-
}}
168171
}
169172

170173
func svcPortToIngress(src []corev1.PortStatus) []networkingv1.IngressPortStatus {

0 commit comments

Comments
 (0)