- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for allWatched (0.27 sec)
-
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) -
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) -
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) -
src/testing/sub_test.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Dec 01 21:27:08 UTC 2023 - 23.8K bytes - Viewed (0) -
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) -
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) -
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) -
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)