Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 40 for MatchAll (0.14 sec)

  1. 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)
  2. 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)
  3. istioctl/pkg/authz/testdata/configdump.yaml

                "stat_prefix": "PassthroughCluster",
                "cluster": "PassthroughCluster"
               }
              }
             ],
             "name": "virtualOutbound-catchall-tcp"
            }
           ],
           "use_original_dst": true,
           "traffic_direction": "OUTBOUND"
          },
          "last_updated": "2023-06-20T09:07:41.992Z"
         }
        },
        {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jun 21 14:20:23 UTC 2023
    - 206.7K bytes
    - Viewed (1)
  4. pilot/pkg/networking/core/sidecar_simulation_test.go

    			},
    			Disabled: simulation.Result{
    				ClusterMatched:     "InboundPassthroughCluster",
    				FilterChainMatched: "virtualInbound-catchall-http",
    			},
    			Permissive: simulation.Result{
    				ClusterMatched:     "InboundPassthroughCluster",
    				FilterChainMatched: "virtualInbound-catchall-http",
    			},
    			Strict: simulation.Result{
    				// Plaintext to strict fails
    				Error: simulation.ErrNoFilterChain,
    			},
    		},
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 84.7K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. pilot/pkg/networking/core/route/route_test.go

    	testCases := []struct {
    		name     string
    		in       []*envoyroute.Route
    		expected []*envoyroute.Route
    	}{
    		{
    			name:     "routes with catchall match",
    			in:       first,
    			expected: wantFirst,
    		},
    		{
    			name:     "routes without catchall match",
    			in:       second,
    			expected: wantSecond,
    		},
    	}
    
    	for _, tc := range testCases {
    		t.Run(tc.name, func(t *testing.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)
  8. 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)
  9. pilot/pkg/networking/core/listener.go

    	// resource with one or more explicit ports and then added a catch
    	// all listener, implying add all other ports as usual. When we are
    	// iterating through the services for a catchAll egress listener,
    	// the caller would have set the locked bit for each listener Entry
    	// in the map.
    	//
    	// Check if this HTTP listener conflicts with an existing TCP
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon May 06 04:44:06 UTC 2024
    - 55.1K bytes
    - Viewed (0)
  10. pilot/pkg/networking/core/listener_test.go

    	t.Helper()
    	if l == nil {
    		t.Fatalf("nil listener")
    	}
    
    	fc := &tcp.TcpProxy{}
    	if err := getFilterConfig(xdstest.ExtractFilterChain("virtualOutbound-catchall-tcp", l).Filters[0], fc); err != nil {
    		t.Fatalf("failed to get TCP Proxy config: %s", err)
    	}
    	if fc.AccessLog == nil {
    		t.Fatal("expected access log configuration")
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 93.6K bytes
    - Viewed (0)
Back to top