Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for allWatched (0.27 sec)

  1. pilot/pkg/xds/ads.go

    	allWatched := conn.proxy.CloneWatchedResources()
    	ordered := make([]*model.WatchedResource, 0, len(allWatched))
    	// first add all known types, in order
    	for _, tp := range PushOrder {
    		if allWatched[tp] != nil {
    			ordered = append(ordered, allWatched[tp])
    		}
    	}
    	// Then add any undeclared types
    	for tp, res := range allWatched {
    		if !KnownOrderedTypeUrls.Contains(tp) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jun 03 08:29:05 UTC 2024
    - 23.4K bytes
    - Viewed (0)
  2. src/regexp/regexp.go

    		return nil
    	}
    	n := (1 + re.numSubexp) * 2
    	for len(a) < n {
    		a = append(a, -1)
    	}
    	return a
    }
    
    // allMatches calls deliver at most n times
    // with the location of successive matches in the input text.
    // The input text is b if non-nil, otherwise s.
    func (re *Regexp) allMatches(s string, b []byte, n int, deliver func([]int)) {
    	var end int
    	if b == nil {
    		end = len(s)
    	} else {
    		end = len(b)
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Feb 26 20:50:01 UTC 2024
    - 38.5K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/schema/cel/compilation_test.go

    	String() string
    }
    
    type allMatcher []validationMatcher
    
    func matchesAll(matchers ...validationMatcher) validationMatcher {
    	return allMatcher(matchers)
    }
    
    func (m allMatcher) matches(cr CompilationResult) bool {
    	for _, each := range m {
    		if !each.matches(cr) {
    			return false
    		}
    	}
    	return true
    }
    
    func (m allMatcher) String() string {
    	if len(m) == 0 {
    		return "any result"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 16 20:13:14 UTC 2024
    - 51.5K bytes
    - Viewed (0)
  4. src/testing/sub_test.go

    			t.Run("sub", func(t2 *T) {
    				t2.FailNow()
    			})
    		},
    	}}
    	for _, tc := range testCases {
    		t.Run(tc.desc, func(t *T) {
    			ctx := newTestContext(tc.maxPar, allMatcher())
    			buf := &strings.Builder{}
    			root := &T{
    				common: common{
    					signal:  make(chan bool),
    					barrier: make(chan bool),
    					name:    "",
    					w:       buf,
    				},
    				context: ctx,
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Dec 01 21:27:08 UTC 2023
    - 23.8K bytes
    - Viewed (0)
  5. src/testing/match_test.go

    }
    
    func FuzzNaming(f *F) {
    	for _, tc := range namingTestCases {
    		f.Add(tc.name)
    	}
    	parent := &common{name: "x", level: 1}
    	var m *matcher
    	var seen map[string]string
    	reset := func() {
    		m = allMatcher()
    		seen = make(map[string]string)
    	}
    	reset()
    
    	f.Fuzz(func(t *T, subname string) {
    		if len(subname) > 10 {
    			// Long names attract the OOM killer.
    			t.Skip()
    		}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Sep 16 14:48:54 UTC 2022
    - 8K bytes
    - Viewed (0)
  6. src/testing/match.go

    type alternationMatch []filterMatch
    
    // TODO: fix test_main to avoid race and improve caching, also allowing to
    // eliminate this Mutex.
    var matchMutex sync.Mutex
    
    func allMatcher() *matcher {
    	return newMatcher(nil, "", "", "")
    }
    
    func newMatcher(matchString func(pat, str string) (bool, error), patterns, name, skips string) *matcher {
    	var filter, skip filterMatch
    	if patterns == "" {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Jul 27 22:07:13 UTC 2023
    - 7.7K bytes
    - Viewed (0)
  7. pkg/proxy/iptables/proxier_test.go

    func findAllMatches(lines []string, pattern string) []string {
    	regex := regexp.MustCompile(pattern)
    	allMatches := sets.New[string]()
    	for _, line := range lines {
    		match := regex.FindStringSubmatch(line)
    		if len(match) == 2 {
    			allMatches.Insert(match[1])
    		}
    	}
    	return sets.List(allMatches)
    }
    
    // checkIPTablesRuleJumps checks that every `-j` in the given rules jumps to a chain
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 14:39:54 UTC 2024
    - 249.9K bytes
    - Viewed (1)
  8. pkg/registry/core/service/storage/storage_test.go

    		update                  *api.Service
    		expectSameClusterIPs    bool
    		expectReducedClusterIPs bool
    		expectSameNodePort      bool
    		expectSameHCNP          bool
    	}{{
    		name: "all_patched",
    		before: svctest.MakeService("foo",
    			svctest.SetTypeLoadBalancer,
    			svctest.SetExternalTrafficPolicy(api.ServiceExternalTrafficPolicyLocal),
    			svctest.SetClusterIPs("10.0.0.93", "2000::76"),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 440.2K bytes
    - Viewed (0)
Back to top