- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 48 for watchlist (0.33 sec)
-
staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/typed/cr/v1/example.go
if watchListOptions, hasWatchListOptionsPrepared, watchListOptionsErr := watchlist.PrepareWatchListOptionsFromListOptions(opts); watchListOptionsErr != nil { klog.Warningf("Failed preparing watchlist options for examples, 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 - 8.6K 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) -
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/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) -
security/pkg/nodeagent/cache/secretcache_test.go
t.Fatalf("expected: %v, got: %v", c.expErr, err) } t.Logf("file watch: %v\n", sc.certWatcher.WatchList()) if c.expErr == nil && len(sc.certWatcher.WatchList()) != 1 { t.Fatalf("expected certWatcher to watch 1 file, but it is watching: %d files", len(sc.certWatcher.WatchList())) } for _, v := range sc.certWatcher.WatchList() { if v != c.expFilePathToWatch { t.Fatalf(
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 16 22:12:28 UTC 2024 - 23.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/installer.go
"LIST": "list", "PATCH": "patch", "POST": "create", "PROXY": "proxy", "PUT": "update", "WATCH": "watch", "WATCHLIST": "watch", } // Install handlers for API resources. func (a *APIInstaller) Install() ([]metav1.APIResource, []*storageversion.ResourceInfo, *restful.WebService, []error) { var apiResources []metav1.APIResource
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 18:15:22 UTC 2024 - 51.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/request/width_test.go
featuregatetesting "k8s.io/component-base/featuregate/testing" ) func TestWorkEstimator(t *testing.T) { featuregatetesting.SetFeatureGateDuringTest(t, utilfeature.DefaultFeatureGate, features.WatchList, true) defaultCfg := DefaultWorkEstimatorConfig() tests := []struct { name string requestURI string requestInfo *apirequest.RequestInfo
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 17K bytes - Viewed (0) -
api/openapi-spec/swagger.json
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 18:37:07 UTC 2024 - 3.1M bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/testing/watcher_tests.go
} expectObj := out if watchTest.watchType == watch.Deleted { expectObj = currentObjs[watchTest.obj.Name] expectObj.ResourceVersion = out.ResourceVersion delete(currentObjs, watchTest.obj.Name) } else { currentObjs[watchTest.obj.Name] = out } if watchTest.expectEvent { testCheckResult(t, w, watch.Event{Type: watchTest.watchType, Object: expectObj}) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 63.8K bytes - Viewed (0)