Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for GetRoute (0.19 sec)

  1. pkg/config/analysis/analyzers/virtualservice/util.go

    	for i, r := range vs.GetTcp() {
    		for j, rd := range r.GetRoute() {
    			destinations = append(destinations, &AnnotatedDestination{
    				RouteRule:        "tcp",
    				ServiceIndex:     i,
    				DestinationIndex: j,
    				Destination:      rd.GetDestination(),
    			})
    		}
    	}
    	for i, r := range vs.GetTls() {
    		for j, rd := range r.GetRoute() {
    			destinations = append(destinations, &AnnotatedDestination{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Aug 07 15:18:05 UTC 2023
    - 2.4K bytes
    - Viewed (0)
  2. pilot/pkg/networking/core/route/route_test.go

    		g.Expect(len(routes)).To(Equal(1))
    		// Validate that when timeout is not specified, we disable it based on default value of flag.
    		g.Expect(routes[0].GetRoute().Timeout.Seconds).To(Equal(int64(0)))
    		// nolint: staticcheck
    		g.Expect(routes[0].GetRoute().MaxGrpcTimeout.Seconds).To(Equal(int64(0)))
    	})
    
    	t.Run("for virtual service with HTTP/3 discovery enabled", func(t *testing.T) {
    		g := NewWithT(t)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 14 14:12:39 UTC 2024
    - 88.1K bytes
    - Viewed (0)
  3. pilot/pkg/networking/core/route/route.go

    func BuildDefaultHTTPInboundRoute(clusterName string, operation string) *route.Route {
    	out := buildDefaultHTTPRoute(clusterName, operation)
    	// For inbound, configure with notimeout.
    	out.GetRoute().Timeout = Notimeout
    	out.GetRoute().MaxStreamDuration = &route.RouteAction_MaxStreamDuration{
    		MaxStreamDuration: Notimeout,
    		// If not configured at all, the grpc-timeout header is not used and
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 14 14:12:39 UTC 2024
    - 56.1K bytes
    - Viewed (0)
  4. pilot/pkg/xds/xds_test.go

    	routes := s.Routes(proxy)
    	for _, rc := range routes {
    		for _, vh := range rc.GetVirtualHosts() {
    			if vh.GetName() == "allow_any" {
    				for _, r := range vh.GetRoutes() {
    					if expectedEgressCluster == r.GetRoute().GetCluster() {
    						found = true
    						break
    					}
    				}
    				break
    			}
    		}
    	}
    	if !found {
    		t.Fatalf("failed to find expected fallthrough route")
    	}
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Mar 27 16:59:05 UTC 2024
    - 13.8K bytes
    - Viewed (0)
  5. pilot/test/xdstest/extract.go

    func ExtractVirtualHosts(rc *route.RouteConfiguration) map[string][]string {
    	res := map[string][]string{}
    	for _, vh := range rc.GetVirtualHosts() {
    		var dests []string
    		for _, r := range vh.Routes {
    			if dc := r.GetRoute().GetCluster(); dc != "" {
    				dests = append(dests, dc)
    			}
    		}
    		sort.Strings(dests)
    		for _, d := range vh.Domains {
    			res[d] = dests
    		}
    	}
    	return res
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Dec 19 22:42:42 UTC 2023
    - 13.9K bytes
    - Viewed (0)
  6. pkg/adsc/adsc.go

    			for _, rt := range h.Routes {
    				rcount++
    				// Example: match:<prefix:"/" > route:<cluster:"outbound|9154||load-se-154.local" ...
    				adscLog.Debugf("Handle route %v, path %v, cluster %v", h.Name, rt.Match.PathSpecifier, rt.GetRoute().GetCluster())
    			}
    		}
    		rds[r.Name] = r
    		size += proto.Size(r)
    	}
    	if a.initialLoad == 0 {
    		a.initialLoad = time.Since(a.watchTime)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Feb 05 22:18:49 UTC 2024
    - 35K bytes
    - Viewed (0)
  7. pilot/pkg/networking/core/httproute_test.go

    			got := map[string][]string{}
    			clusters := map[string]string{}
    			for _, vh := range routeCfg.VirtualHosts {
    				got[vh.Name] = vh.Domains
    				clusters[vh.Name] = vh.GetRoutes()[0].GetRoute().GetCluster()
    			}
    
    			if !reflect.DeepEqual(tt.expectedHosts, got) {
    				t.Fatalf("unexpected virtual hosts\n%v, wanted\n%v", got, tt.expectedHosts)
    			}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Mar 28 17:09:02 UTC 2024
    - 51.4K bytes
    - Viewed (0)
  8. istioctl/pkg/describe/describe.go

    		ss := re.FindStringSubmatch(domain)
    		if ss != nil {
    			if ss[1] == svc.ObjectMeta.Name && ss[2] == svc.ObjectMeta.Namespace {
    				return true
    			}
    		}
    	}
    
    	clusterName := ""
    	switch cs := vhRoute.GetRoute().GetClusterSpecifier().(type) {
    	case *route.RouteAction_Cluster:
    		clusterName = cs.Cluster
    	case *route.RouteAction_WeightedClusters:
    		clusterName = cs.WeightedClusters.Clusters[0].GetName()
    	}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sat Apr 13 05:23:38 UTC 2024
    - 50.4K bytes
    - Viewed (0)
  9. pilot/pkg/networking/core/gateway.go

    		}
    
    		for _, mirror := range httpRoute.GetMirrors() {
    			if mirror.GetDestination() != nil {
    				addService(host.Name(mirror.GetDestination().GetHost()))
    			}
    		}
    
    		for _, route := range httpRoute.GetRoute() {
    			if route.GetDestination() != nil {
    				addService(host.Name(route.GetDestination().GetHost()))
    			}
    		}
    	}
    
    	return nameToServiceMap
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon May 06 04:44:06 UTC 2024
    - 46.4K bytes
    - Viewed (0)
  10. ci/devinfra/docker_windows/Dockerfile

        $gateway = (Get-NetRoute | Where { $_.DestinationPrefix -eq \"0.0.0.0/0\" } | Sort-Object RouteMetric \
            | Select NextHop).NextHop; \
        $ifIndex = (Get-NetAdapter -InterfaceDescription \"Hyper-V Virtual Ethernet*\" | Sort-Object \
            | Select ifIndex).ifIndex; \
        New-NetRoute -DestinationPrefix 169.254.169.254/32 -InterfaceIndex $ifIndex -NextHop $gateway
    
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Fri Aug 18 17:24:20 UTC 2023
    - 13.6K bytes
    - Viewed (0)
Back to top