- Sort Score
- Result 10 results
- Languages All
Results 11 - 17 of 17 for MatchAll (0.17 sec)
-
pilot/pkg/xds/eds_test.go
mustReadFile(t, "tests/testdata/config/static-weighted-se.yaml"), }) ads := s.Connect(nil, nil, watchAll) t.Run("Full Push", func(t *testing.T) { s.Discovery.Push(&model.PushRequest{Full: true}) if _, err := ads.Wait(time.Second*5, watchAll...); err != nil { t.Fatal(err) } }) t.Run("Incremental Push with updated services", func(t *testing.T) { ads.WaitClear()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 02 20:58:47 UTC 2024 - 39.6K bytes - Viewed (0) -
pilot/pkg/networking/core/route/route_internal_test.go
}, }, }, }, want: false, }, } for _, tt := range cases { t.Run(tt.name, func(t *testing.T) { catchall := IsCatchAllRoute(tt.route) if catchall != tt.want { t.Errorf("Unexpected catchAllMatch want %v, got %v", tt.want, catchall) } }) } } func TestTranslateCORSPolicyForwardNotMatchingPreflights(t *testing.T) { node := &model.Proxy{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat May 11 02:47:57 UTC 2024 - 18.2K bytes - Viewed (0) -
pilot/pkg/networking/core/listener_waypoint.go
} out := make([]*route.Route, 0, len(vs.Http)) catchall := false for _, http := range vs.Http { if len(http.Match) == 0 { if r := lb.translateRoute(virtualService, http, nil, listenPort); r != nil { out = append(out, r) } // This is a catchall route, so we can stop processing the rest of the routes. break } for _, match := range http.Match {
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/listener_builder_test.go
} listenertest.VerifyListener(t, l, listenertest.ListenerTest{ FilterChains: []listenertest.FilterChainTest{ {Name: "virtualInbound-blackhole"}, {Name: "virtualInbound-catchall-http", Type: listenertest.MTLSHTTP}, {Name: "virtualInbound-catchall-http", Type: listenertest.PlainHTTP}, {Name: "virtualInbound", Type: listenertest.MTLSTCP}, {Name: "virtualInbound", Type: listenertest.PlainTCP},
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 24.7K bytes - Viewed (0) -
pilot/pkg/xds/ads_test.go
{Address: "1.2.3.4", Locality: "region/zone"}, {Address: "1.2.3.5", Locality: "notmatch"}, }), }, }) ads := s.Connect(&model.Proxy{Locality: &core.Locality{Region: "region"}}, nil, watchAll) assertEndpoints(ads, "1.2.3.4:80", "1.2.3.5:80") t.Logf("endpoints: %+v", xdstest.ExtractEndpoints(ads.GetEndpoints()["outbound|80||foo.com"]))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jan 30 17:25:17 UTC 2024 - 30.3K bytes - Viewed (0) -
pilot/pkg/model/sidecar.go
func (sc *SidecarScope) GetEgressListenerForRDS(port int, bind string) *IstioEgressListenerWrapper { if sc == nil { return nil } for _, e := range sc.EgressListeners { // We hit a catchall listener. This is the last listener in the list of listeners // return as is if e.IstioListener == nil || e.IstioListener.Port == nil { return e } // Check if the ports match
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 05 20:32:23 UTC 2024 - 38.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_controller.go
} selectedFlowSchema = catchAllFlowSchema klog.Warningf("no match found for request %#+v and user %#+v; selecting catchAll=%s as fallback flow schema", rd.RequestInfo, rd.User, fcfmt.Fmt(selectedFlowSchema)) } plName := selectedFlowSchema.Spec.PriorityLevelConfiguration.Name plState := cfgCtlr.priorityLevelStates[plName]
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 48.8K bytes - Viewed (0)