Remove duplicate endpoint, apply protocol

Signed-off-by: Daishan Peng <[email protected]>

pkg/controller/appstatus/endpoints.go

@@ -53,11 +53,15 @@ func serviceEndpoints(ctx context.Context, c kclient.Client, app *v1.AppInstance
 					portNum := port.Port
 					if len(ingress.Ports) > 0 {
 						for _, ingressPort := range ingress.Ports {
+							portProtocol := port.Protocol
+							if ingressPort.Protocol != "" {
+								portProtocol = ingressPort.Protocol
+							}
 							endpoints = append(endpoints, v1.Endpoint{
 								Target:     containerName,
 								TargetPort: port.TargetPort.IntVal,
 								Address:    fmt.Sprintf("%s:%d", ingress.Hostname, ingressPort.Port),
-								Protocol:   protocol,
+								Protocol:   v1.Protocol(portProtocol),
 							})
 						}
 					} else {
@@ -90,7 +94,17 @@ func serviceEndpoints(ctx context.Context, c kclient.Client, app *v1.AppInstance
 		}
 	}
 
-	return
+	set := map[string]v1.Endpoint{}
+	for _, ep := range endpoints {
+		set[fmt.Sprintf("%v://%v", ep.Protocol, ep.Address)] = ep
+	}
+
+	var result []v1.Endpoint
+	for _, ep := range set {
+		result = append(result, ep)
+	}
+
+	return result, nil
 }
 
 func ingressEndpoints(ctx context.Context, c kclient.Client, app *v1.AppInstance) (endpoints []v1.Endpoint, _ error) {