Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 15 for matchList (0.39 sec)

  1. src/testing/testing.go

    	if _, err := matchString(*matchList, "non-empty"); err != nil {
    		fmt.Fprintf(os.Stderr, "testing: invalid regexp in -test.list (%q): %s\n", *matchList, err)
    		os.Exit(1)
    	}
    
    	for _, test := range tests {
    		if ok, _ := matchString(*matchList, test.Name); ok {
    			fmt.Println(test.Name)
    		}
    	}
    	for _, bench := range benchmarks {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 76.1K bytes
    - Viewed (0)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. api/openapi-spec/swagger.json

              }
            },
            "schemes": [
              "https"
            ],
            "tags": [
              "core_v1"
            ],
            "x-kubernetes-action": "watchlist",
            "x-kubernetes-group-version-kind": {
              "group": "",
              "kind": "ConfigMap",
              "version": "v1"
            }
          },
          "parameters": [
            {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 05 18:37:07 UTC 2024
    - 3.1M bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go

    	}
    }
    
    func TestWaitUntilWatchCacheFreshAndForceAllEvents(t *testing.T) {
    	featuregatetesting.SetFeatureGateDuringTest(t, utilfeature.DefaultFeatureGate, features.WatchList, true)
    	featuregatetesting.SetFeatureGateDuringTest(t, utilfeature.DefaultFeatureGate, features.ConsistentListFromCache, true)
    
    	scenarios := []struct {
    		name               string
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 82.9K bytes
    - Viewed (0)
  9. pkg/features/kube_features.go

    	genericfeatures.WatchFromStorageWithoutResourceVersion: {Default: false, PreRelease: featuregate.Beta},
    
    	genericfeatures.WatchList: {Default: false, PreRelease: featuregate.Alpha},
    
    	genericfeatures.ZeroLimitedNominalConcurrencyShares: {Default: true, PreRelease: featuregate.GA, LockToDefault: true}, // remove in 1.32
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 22:51:23 UTC 2024
    - 45.2K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go

    	//
    	// it should never happen due to our validation but let's just be super-safe here
    	// and disable sendingInitialEvents when the feature wasn't enabled
    	if !utilfeature.DefaultFeatureGate.Enabled(features.WatchList) && opts.SendInitialEvents != nil {
    		opts.SendInitialEvents = nil
    	}
    	// TODO: we should eventually get rid of this legacy case
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 51.8K bytes
    - Viewed (0)
Back to top