Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 40 for MatchAll (0.34 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/model/listener.go

    	VirtualOutboundListenerName = "virtualOutbound"
    
    	// VirtualOutboundCatchAllTCPFilterChainName is the name of the catch all tcp filter chain
    	VirtualOutboundCatchAllTCPFilterChainName = "virtualOutbound-catchall-tcp"
    
    	// VirtualOutboundBlackholeFilterChainName is the name of the filter chain to blackhole undesired traffic
    	VirtualOutboundBlackholeFilterChainName = "virtualOutbound-blackhole"
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Mar 10 17:24:55 UTC 2023
    - 1.7K bytes
    - Viewed (0)
  6. samples/bookinfo/src/productpage/static/tailwind/tailwind.css

    ,r=Z.extname(i)){let n=jC(Z.resolve(e,i),LC.includes(r)?NC:$C);if(n===null||t.has(n))return;t.add(n),yield n,e=Z.dirname(n),r=Z.extname(n);let a=te.readFileSync(n,"utf-8");for(let s of[...a.matchAll(/import[\s\S]*?['"](.{3,}?)['"]/gi),...a.matchAll(/import[\s\S]*from[\s\S]*?['"](.{3,}?)['"]/gi),...a.matchAll(/require\(['"`](.+)['"`]\)/gi)])!s[1].startsWith(".")||(yield*uh(s[1],e,t,r))}function wo(i){return i===null?new Set:new Set(uh(i,Z.dirname(i),new Set))}var LC,NC,$C,fh=C(()=>{l();je();gt();...
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 28 14:48:01 UTC 2024
    - 357.1K bytes
    - Viewed (1)
  7. 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)
  8. pilot/pkg/xds/lds_test.go

    				InterceptionMode: model.InterceptionNone,
    				HTTP10:           "1",
    			},
    			IPAddresses:     []string{"10.11.0.1"}, // matches none.yaml s1tcp.none
    			ConfigNamespace: "none",
    		}, nil, watchAll)
    
    		err := adscon.Save(wd + "/none")
    		if err != nil {
    			t.Fatal(err)
    		}
    
    		// 7071 (inbound), 2001 (service - also as http proxy), 18010 (fortio)
    		if len(adscon.GetHTTPListeners()) != 3 {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jan 12 18:20:36 UTC 2024
    - 13.1K bytes
    - Viewed (0)
  9. 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)
  10. 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)
Back to top