- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for GetRoute (0.29 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)