Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for MatchAll (0.33 sec)

  1. pkg/proxy/nftables/proxier.go

    	tx.Add(&knftables.Set{
    		Name:    nodePortIPsSet,
    		Type:    ipvX_addr,
    		Comment: ptr.To("IPs that accept NodePort traffic"),
    	})
    	if proxier.nodePortAddresses.MatchAll() {
    		tx.Delete(&knftables.Set{
    			Name: nodePortIPsSet,
    		})
    	} else {
    		tx.Flush(&knftables.Set{
    			Name: nodePortIPsSet,
    		})
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 08 13:48:54 UTC 2024
    - 55.5K bytes
    - Viewed (0)
  2. pilot/pkg/model/sidecar_test.go

    	b.Run("big-match-all", func(b *testing.B) {
    		benchmarkConvertIstioListenerToWrapper(b, 300, 15, "", true)
    	})
    }
    
    func benchmarkConvertIstioListenerToWrapper(b *testing.B, vsNum int, hostNum int, wildcard string, matchAll bool) {
    	// virtual service
    	cfgs := make([]config.Config, 0)
    	for i := 0; i < vsNum; i++ {
    		cfgs = append(cfgs, config.Config{
    			Meta: config.Meta{
    				GroupVersionKind: gvk.VirtualService,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 07 09:38:49 UTC 2024
    - 74.3K bytes
    - Viewed (0)
  3. pkg/proxy/iptables/proxier.go

    		}
    	}
    
    	// Finally, tail-call to the nodePorts chain.  This needs to be after all
    	// other service portal rules.
    	if proxier.nodePortAddresses.MatchAll() {
    		destinations := []string{"-m", "addrtype", "--dst-type", "LOCAL"}
    		// Block localhost nodePorts if they are not supported. (For IPv6 they never
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 14:39:54 UTC 2024
    - 65.1K bytes
    - Viewed (0)
  4. pkg/proxy/ipvs/proxier.go

    		}
    	}
    
    	// List of node IP addresses to be used as IPVS services if nodePort is set. This
    	// can be reused for all nodePort services.
    	var nodeIPs []net.IP
    	if hasNodePort {
    		if proxier.nodePortAddresses.MatchAll() {
    			for _, ipStr := range nodeAddressSet.UnsortedList() {
    				nodeIPs = append(nodeIPs, netutils.ParseIPSloppy(ipStr))
    			}
    		} else {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Apr 28 15:51:23 UTC 2024
    - 77.7K bytes
    - Viewed (0)
  5. pilot/pkg/networking/core/route/route.go

    		return true
    	}
    
    	catchall := false
    
    	switch m := in.MatchType.(type) {
    	case *networking.StringMatch_Regex:
    		// `*` is NOT a RE2 style regex, it's a metacharacter.
    		// It will be translated as present_match, rather than matching "any string".
    		// see https://github.com/istio/istio/pull/20629
    		catchall = m.Regex == "*"
    	}
    
    	return catchall
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 14 14:12:39 UTC 2024
    - 56.1K bytes
    - Viewed (0)
  6. 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)
  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. 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)
  9. 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