- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 19 for matchList (0.16 sec)
-
pilot/pkg/model/config.go
found := false var matchHost host.Name var matchValue V for h, v := range wildcard { if strings.HasSuffix(needle, string(h[1:])) { if !found { matchHost = h matchValue = wildcard[h] found = true } else if host.MoreSpecific(h, matchHost) { matchHost = h matchValue = v } } } return matchHost, matchValue, found }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 08:51:03 UTC 2024 - 13.1K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset/typed/apiextensions/v1/customresourcedefinition.go
if watchListOptions, hasWatchListOptionsPrepared, watchListOptionsErr := watchlist.PrepareWatchListOptionsFromListOptions(opts); watchListOptionsErr != nil { klog.Warningf("Failed preparing watchlist options for customresourcedefinitions, falling back to the standard LIST semantics, err = %v", watchListOptionsErr) } else if hasWatchListOptionsPrepared { result, err := c.watchList(ctx, watchListOptions) if err == nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 10:52:54 UTC 2024 - 12K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset/typed/apiextensions/v1beta1/customresourcedefinition.go
if watchListOptions, hasWatchListOptionsPrepared, watchListOptionsErr := watchlist.PrepareWatchListOptionsFromListOptions(opts); watchListOptionsErr != nil { klog.Warningf("Failed preparing watchlist options for customresourcedefinitions, falling back to the standard LIST semantics, err = %v", watchListOptionsErr) } else if hasWatchListOptionsPrepared { result, err := c.watchList(ctx, watchListOptions) if err == nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 10:52:54 UTC 2024 - 12.1K bytes - Viewed (0) -
src/vendor/golang.org/x/net/http/httpproxy/proxy.go
if strings.HasPrefix(phost, "*.") { phost = phost[1:] } matchHost := false if phost[0] != '.' { matchHost = true phost = "." + phost } if v, err := idnaASCII(phost); err == nil { phost = v } c.domainMatchers = append(c.domainMatchers, domainMatch{host: phost, port: pport, matchHost: matchHost}) } } var portMap = map[string]string{ "http": "80",
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat Mar 09 00:09:40 UTC 2024 - 10K bytes - Viewed (0) -
pilot/pkg/security/authz/model/generator.go
iss, sub = value[:idx], value[idx+1:] } else { iss = value } var matchIss, matchSub *matcherpb.StringMatcher switch { case value == "*": matchIss = matchAny matchSub = matchAny case strings.HasPrefix(value, "*"): if found { if iss == "*" { matchIss = matchAny } else { matchIss = matcher.StringMatcherSuffix(strings.TrimPrefix(iss, "*"), false) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 03 18:02:42 UTC 2024 - 14.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/metrics/metrics_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 27 07:29:19 UTC 2023 - 14.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/features/kube_features.go
InPlacePodVerticalScaling featuregate.Feature = "InPlacePodVerticalScaling" // owner: @p0lyn0mial // alpha: v1.27 // // Allow the API server to stream individual items instead of chunking WatchList featuregate.Feature = "WatchList" // owner: @serathius // kep: http://kep.k8s.io/2340 // alpha: v1.28 // // Allow the API server to serve consistent lists from cache
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:36:46 UTC 2024 - 13.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/get.go
scope.err(err, w, req) return } metainternalversion.SetListOptionsDefaults(&opts, utilfeature.DefaultFeatureGate.Enabled(features.WatchList)) if errs := metainternalversionvalidation.ValidateListOptions(&opts, utilfeature.DefaultFeatureGate.Enabled(features.WatchList)); len(errs) > 0 { err := errors.NewInvalid(schema.GroupKind{Group: metav1.GroupName, Kind: "ListOptions"}, "", errs) scope.err(err, w, req) return
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Feb 16 10:22:16 UTC 2024 - 10.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/watcher_test.go
}, } for _, scenario := range scenarios { t.Run(scenario.name, func(t *testing.T) { if scenario.enableWatchList { featuregatetesting.SetFeatureGateDuringTest(t, utilfeature.DefaultFeatureGate, features.WatchList, true) } origCtx, store, _ := testSetup(t, scenario.setupFn) ctx, cancel := context.WithCancel(origCtx) defer cancel() w, err := store.watcher.Watch(ctx, "/abc", 0, scenario.requestOpts)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 12.3K bytes - Viewed (1) -
staging/src/k8s.io/apiserver/pkg/endpoints/metrics/metrics.go
reportedVerb := verb if suggestedVerb := getVerbIfWatch(request); suggestedVerb == "WATCH" { reportedVerb = "WATCH" } // normalize the legacy WATCHLIST to WATCH to ensure users aren't surprised by metrics if verb == "WATCHLIST" { reportedVerb = "WATCH" } if verb == "PATCH" && request.Header.Get("Content-Type") == string(types.ApplyPatchType) { reportedVerb = "APPLY" }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 27 07:29:19 UTC 2023 - 35K bytes - Viewed (0)