Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 14 for WatchList (0.2 sec)

  1. 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)
  2. 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)
  3. staging/src/k8s.io/apiserver/pkg/endpoints/metrics/metrics_test.go

    			initialVerb:   "LIST",
    			suggestedVerb: "WATCHLIST",
    			request: &http.Request{
    				Method: "GET",
    				URL: &url.URL{
    					RawQuery: "/api/v1/watch/pods",
    				},
    			},
    			expectedVerb: "WATCH",
    		},
    		{
    			desc:         "WATCHLIST should be transformed to WATCH",
    			initialVerb:  "WATCHLIST",
    			request:      nil,
    			expectedVerb: "WATCH",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 27 07:29:19 UTC 2023
    - 14.3K bytes
    - Viewed (0)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. staging/src/k8s.io/apiserver/pkg/endpoints/handlers/delete.go

    			scope.err(err, w, req)
    			return
    		}
    
    		metainternalversion.SetListOptionsDefaults(&listOptions, utilfeature.DefaultFeatureGate.Enabled(features.WatchList))
    		if errs := metainternalversionvalidation.ValidateListOptions(&listOptions, 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: Wed Mar 01 10:00:32 UTC 2023
    - 11.4K bytes
    - Viewed (0)
  9. 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)
  10. staging/src/k8s.io/apiserver/pkg/storage/etcd3/watcher.go

    	if resourceVersion > 0 {
    		return resourceVersion, nil
    	}
    	if !utilfeature.DefaultFeatureGate.Enabled(features.WatchList) {
    		return 0, nil
    	}
    	if opts.SendInitialEvents == nil || *opts.SendInitialEvents {
    		// note that when opts.SendInitialEvents=true
    		// we will be issuing a consistent LIST request
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Sep 25 10:26:38 UTC 2023
    - 18.9K bytes
    - Viewed (0)
Back to top