Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 13 for ResourceVersionMatchNotOlderThan (0.37 sec)

  1. staging/src/k8s.io/apimachinery/pkg/apis/meta/internalversion/validation/validation.go

    		}
    		if match != metav1.ResourceVersionMatchExact && match != metav1.ResourceVersionMatchNotOlderThan {
    			allErrs = append(allErrs, field.NotSupported(field.NewPath("resourceVersionMatch"), match, []string{string(metav1.ResourceVersionMatchExact), string(metav1.ResourceVersionMatchNotOlderThan), ""}))
    		}
    		if match == metav1.ResourceVersionMatchExact && options.ResourceVersion == "0" {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 01 09:55:40 UTC 2023
    - 3.5K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apimachinery/pkg/apis/meta/internalversion/validation/validation_test.go

    			ResourceVersionMatch: metav1.ResourceVersionMatchNotOlderThan,
    			AllowWatchBookmarks:  true,
    		},
    		watchListFeatureEnabled: true,
    	}, {
    		name: "valid-watch-sendInitialEvents-off",
    		opts: internalversion.ListOptions{
    			Watch:                true,
    			SendInitialEvents:    boolPtrFn(false),
    			ResourceVersionMatch: metav1.ResourceVersionMatchNotOlderThan,
    			AllowWatchBookmarks:  true,
    		},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 02 07:48:42 UTC 2023
    - 7.6K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apimachinery/pkg/apis/meta/internalversion/defaults_test.go

    			expectedObj:             ListOptions{LabelSelector: labels.Everything(), FieldSelector: fields.Everything(), Watch: true, SendInitialEvents: boolPtrFn(true), ResourceVersionMatch: metav1.ResourceVersionMatchNotOlderThan},
    		},
    		{
    			name:                    "defaults applied, match on RV=0",
    			watchListFeatureEnabled: true,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 01 10:00:32 UTC 2023
    - 5.5K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apimachinery/pkg/apis/meta/internalversion/defaults.go

    	}
    	legacy := obj.ResourceVersion == "" || obj.ResourceVersion == "0"
    	if obj.Watch && legacy {
    		turnOnInitialEvents := true
    		obj.SendInitialEvents = &turnOnInitialEvents
    		obj.ResourceVersionMatch = metav1.ResourceVersionMatchNotOlderThan
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 01 10:00:32 UTC 2023
    - 1.4K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/request/list_work_estimator.go

    	hasLimit := opts.Limit > 0 && resourceVersion != "0"
    	// Watch cache only supports ResourceVersionMatchNotOlderThan (default).
    	unsupportedMatch := match != "" && match != metav1.ResourceVersionMatchNotOlderThan
    
    	return consistentReadFromStorage || hasContinuation || hasLimit || unsupportedMatch
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 11:56:42 UTC 2024
    - 7K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/pkg/storage/testing/store_tests.go

    		t.Fatalf("failed to list objects: %v", err)
    	}
    
    	expectNoDiff(t, "incorrect lists", result1, result2)
    
    	// Now also verify the  ResourceVersionMatchNotOlderThan.
    	options.ResourceVersionMatch = metav1.ResourceVersionMatchNotOlderThan
    
    	result3 := example.PodList{}
    	if err := store.GetList(ctx, "/pods", options, &result3); err != nil {
    		t.Fatalf("failed to list objects: %v", err)
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 12:45:33 UTC 2024
    - 91.4K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/pkg/reconcilers/peer_endpoint_lease.go

    func (r *peerEndpointLeaseReconciler) ListLeases() ([]string, error) {
    	storageOpts := storage.ListOptions{
    		ResourceVersion:      "0",
    		ResourceVersionMatch: metav1.ResourceVersionMatchNotOlderThan,
    		Predicate:            storage.Everything,
    		Recursive:            true,
    	}
    	ipInfoList, err := r.getIpInfoList(storageOpts)
    	if err != nil {
    		return nil, err
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Aug 24 09:23:05 UTC 2023
    - 12.3K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/storage/etcd3/store_test.go

    			rv:          "",
    			expectedRev: 0,
    		},
    		{
    			name:        "default",
    			expectedRev: 0,
    		},
    		{
    			name:        "rev resolve to 0 if ResourceVersionMatchNotOlderThan",
    			rv:          "200",
    			rvMatch:     metav1.ResourceVersionMatchNotOlderThan,
    			expectedRev: 0,
    		},
    		{
    			name:        "specified rev if ResourceVersionMatchExact",
    			rv:          "200",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 12:45:33 UTC 2024
    - 26.5K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apimachinery/pkg/apis/meta/fuzzer/fuzzer.go

    				j.Finalizers = nil
    			}
    		},
    		func(j *metav1.ResourceVersionMatch, c fuzz.Continue) {
    			matches := []metav1.ResourceVersionMatch{"", metav1.ResourceVersionMatchExact, metav1.ResourceVersionMatchNotOlderThan}
    			*j = matches[c.Rand.Intn(len(matches))]
    		},
    		func(j *metav1.ListMeta, c fuzz.Continue) {
    			j.ResourceVersion = strconv.FormatUint(c.RandUint64(), 10)
    			j.SelfLink = c.RandString()
    		},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 03 15:12:26 UTC 2024
    - 9.9K bytes
    - Viewed (0)
  10. pkg/controlplane/reconcilers/lease.go

    func (s *storageLeases) ListLeases() ([]string, error) {
    	ipInfoList := &corev1.EndpointsList{}
    	storageOpts := storage.ListOptions{
    		ResourceVersion:      "0",
    		ResourceVersionMatch: metav1.ResourceVersionMatchNotOlderThan,
    		Predicate:            storage.Everything,
    		Recursive:            true,
    	}
    	if err := s.storage.GetList(apirequest.NewDefaultContext(), s.baseKey, storageOpts, ipInfoList); err != nil {
    		return nil, err
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Aug 24 09:23:05 UTC 2023
    - 11.3K bytes
    - Viewed (0)
Back to top