fix: configure multiple paths for same backend (#217)

Signed-off-by: Lin Yang <reaver@flomesh.io>

pkg/cache/ingress.go

@@ -135,10 +135,16 @@ func (info BaseIngressInfo) TrustedCA() *route.CertificateSpec {
 	return info.trustedCA
 }
 
-type IngressMap map[ServicePortName]Route
+type IngressMap map[RouteKey]Route
 
-type BackendInfo struct {
-	ServicePortName ServicePortName
+type RouteKey struct {
+	ServicePortName
+	Host string
+	Path string
+}
+
+func (irk *RouteKey) String() string {
+	return fmt.Sprintf("%s#%s#%s", irk.Host, irk.Path, irk.ServicePortName.String())
 }
 
 type ingressChange struct {
@@ -285,19 +291,26 @@ func (ict *IngressChangeTracker) ingressToIngressMap(ing *networkingv1.Ingress,
 			}
 			klog.V(5).Infof("ServicePortName %q", svcPortName.String())
 
-			// already exists, first one wins
-			if _, ok := ingressMap[*svcPortName]; ok {
+			baseIngInfo := ict.newBaseIngressInfo(rule, path, *svcPortName)
+			if baseIngInfo == nil {
 				continue
 			}
 
-			baseIngInfo := ict.newBaseIngressInfo(rule, path, *svcPortName)
-			if baseIngInfo == nil {
+			routeKey := RouteKey{
+				ServicePortName: *svcPortName,
+				Host:            baseIngInfo.Host(),
+				Path:            baseIngInfo.Path(),
+			}
+
+			// already exists, first one wins
+			if _, ok := ingressMap[routeKey]; ok {
+				klog.Warningf("Duplicate route for tuple: %q", routeKey.String())
 				continue
 			}
 
-			ingressMap[*svcPortName] = ict.enrichIngressInfo(&rule, ing, baseIngInfo)
+			ingressMap[routeKey] = ict.enrichIngressInfo(&rule, ing, baseIngInfo)
 
-			klog.V(5).Infof("ServicePort %q is linked to rule %#v", svcPortName.String(), ingressMap[*svcPortName])
+			klog.V(5).Infof("Route %q is linked to rule %#v", routeKey.String(), ingressMap[routeKey])
 		}
 	}
 

pkg/cache/local_cache.go

@@ -281,7 +281,9 @@ func (c *LocalCache) buildIngressConfig() routepkg.IngressData {
 		Routes: []routepkg.IngressRouteSpec{},
 	}
 
-	for svcName, route := range c.ingressMap {
+	for _, route := range c.ingressMap {
+		svcName := route.Backend()
+
 		ir := routepkg.IngressRouteSpec{
 			RouterSpec: routepkg.RouterSpec{
 				Host:    route.Host(),