- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for ValidateClusters (0.21 sec)
-
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) -
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) -
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) -
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) -
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) -
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)