Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for ValidateClusters (0.21 sec)

  1. pilot/pkg/networking/core/cluster_test.go

    			Metadata:     c.meta,
    			IstioVersion: c.istioVersion,
    		}
    	default:
    		panic(fmt.Sprintf("unsupported node type: %v", c.nodeType))
    	}
    	clusters := cg.Clusters(cg.SetupProxy(proxy))
    	xdstest.ValidateClusters(c.t, clusters)
    	if len(cg.PushContext().ProxyStatus[model.DuplicatedClusters.Name()]) > 0 {
    		c.t.Fatalf("duplicate clusters detected %#v", cg.PushContext().ProxyStatus[model.DuplicatedClusters.Name()])
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 108.8K bytes
    - Viewed (0)
  2. pilot/pkg/networking/core/httproute.go

    				hit++
    			} else {
    				miss++
    			}
    			if rc == nil {
    				emptyRoute := &route.RouteConfiguration{
    					Name:             routeName,
    					VirtualHosts:     []*route.VirtualHost{},
    					ValidateClusters: proto.BoolFalse,
    				}
    				rc = &discovery.Resource{
    					Name:     routeName,
    					Resource: protoconv.MessageToAny(emptyRoute),
    				}
    			}
    			routeConfigurations = append(routeConfigurations, rc)
    		}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Mar 28 17:09:02 UTC 2024
    - 32.7K bytes
    - Viewed (0)
  3. pilot/test/xdstest/validate.go

    		if m.TransportProtocol == "" && len(m.ApplicationProtocols) > 0 {
    			t.Errorf("application protocol set, but missing tls inspector: %v", Dump(t, l))
    		}
    	}
    }
    
    func ValidateClusters(t testing.TB, ls []*cluster.Cluster) {
    	found := sets.New[string]()
    	for _, l := range ls {
    		if found.Contains(l.Name) {
    			t.Errorf("duplicate cluster name %v", l.Name)
    		}
    		found.Insert(l.Name)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Mar 28 17:09:02 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  4. pilot/pkg/networking/core/gateway.go

    		log.Warnf("buildGatewayRoutes: no gateways for router %v", node.ID)
    		return &route.RouteConfiguration{
    			Name:             routeName,
    			VirtualHosts:     []*route.VirtualHost{},
    			ValidateClusters: proto.BoolFalse,
    		}
    	}
    
    	ph := GetProxyHeaders(node, push, istionetworking.ListenerClassGateway)
    	merged := node.MergedGateway
    	log.Debugf("buildGatewayRoutes: gateways after merging: %v", merged)
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon May 06 04:44:06 UTC 2024
    - 46.4K bytes
    - Viewed (0)
  5. pilot/pkg/networking/core/listener_waypoint.go

    		Domains: []string{"*"},
    		Routes:  routes,
    	}
    
    	return &route.RouteConfiguration{
    		Name:             cc.clusterName,
    		VirtualHosts:     []*route.VirtualHost{inboundVHost},
    		ValidateClusters: proto.BoolFalse,
    	}
    }
    
    func (lb *ListenerBuilder) waypointInboundRoute(virtualService config.Config, listenPort int) ([]*route.Route, error) {
    	vs, ok := virtualService.Spec.(*networking.VirtualService)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:37 UTC 2024
    - 27.6K bytes
    - Viewed (0)
  6. pilot/pkg/networking/core/gateway_simulation_test.go

    			t.Log(xdstest.DumpList(t, sim.Routes))
    			t.Log(tt.config)
    			t.Log(tt.kubeConfig)
    		}
    		t.Run("validate configs", func(t *testing.T) {
    			if tt.skipValidation {
    				t.Skip()
    			}
    			xdstest.ValidateClusters(t, sim.Clusters)
    			xdstest.ValidateListeners(t, sim.Listeners)
    			xdstest.ValidateRouteConfigurations(t, sim.Routes)
    		})
    	}
    	if tt.name != "" {
    		t.Run(tt.name, runTest)
    	} else {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 10 18:27:40 UTC 2024
    - 46.5K bytes
    - Viewed (0)
Back to top