Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 467 for resourceVersion (0.42 sec)

  1. pkg/controller/storageversionmigrator/resourceversion.go

    		logger.V(4).Info("Migration has already succeeded or failed previously, skipping", "svm", name)
    		return nil
    	}
    
    	if len(toBeProcessedSVM.Status.ResourceVersion) != 0 {
    		logger.V(4).Info("Resource version is already set", "svm", name)
    		return nil
    	}
    
    	exists, err := rv.resourceExists(gvr)
    	if err != nil {
    		return err
    	}
    	if !exists {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/storage/cacher/cache_watcher_test.go

    					ObjFields:       fields.Set{"spec.nodeName": ""},
    					ResourceVersion: 2,
    				},
    				{
    					Type:            watch.Modified,
    					PrevObject:      &v1.Pod{ObjectMeta: metav1.ObjectMeta{ResourceVersion: "2"}},
    					PrevObjFields:   fields.Set{"spec.nodeName": ""},
    					Object:          &v1.Pod{ObjectMeta: metav1.ObjectMeta{ResourceVersion: "3"}},
    					ObjFields:       fields.Set{"spec.nodeName": "host"},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 09:20:10 UTC 2024
    - 22.9K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache.go

    		}
    		// SendInitialEvents = false and resourceVersion = 0
    		// means that the request would like to start watching
    		// from Any resourceVersion
    		resourceVersion = w.resourceVersion
    	}
    	if resourceVersion < oldest-1 {
    		return nil, errors.NewResourceExpired(fmt.Sprintf("too old resource version: %d (%d)", resourceVersion, oldest-1))
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 10:20:57 UTC 2024
    - 26.2K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go

    	}
    	commonTestCases := []testCase{
    		{opts: storage.ListOptions{ResourceVersion: "0"}, expectBypass: false},
    		{opts: storage.ListOptions{ResourceVersion: "1"}, expectBypass: false},
    
    		{opts: storage.ListOptions{ResourceVersion: "", Predicate: storage.SelectionPredicate{Continue: "a"}}, expectBypass: true},
    		{opts: storage.ListOptions{ResourceVersion: "0", Predicate: storage.SelectionPredicate{Continue: "a"}}, expectBypass: true},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 82.9K bytes
    - Viewed (0)
  5. pilot/pkg/config/kube/crdclient/types.gen.go

    	}
    }
    
    func delete(c kube.Client, typ config.GroupVersionKind, name, namespace string, resourceVersion *string) error {
    	var deleteOptions metav1.DeleteOptions
    	if resourceVersion != nil {
    		deleteOptions.Preconditions = &metav1.Preconditions{ResourceVersion: resourceVersion}
    	}
    	switch typ {
    	case gvk.AuthorizationPolicy:
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Apr 12 17:37:32 UTC 2024
    - 62.2K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/pkg/storage/testing/watcher_tests.go

    		t.Fatalf("Delete failed: %v", err)
    	}
    
    	// Verify that ResourceVersion has changed on deletion.
    	if storedObj.ResourceVersion == deletedObj.ResourceVersion {
    		t.Fatalf("ResourceVersion didn't changed on deletion: %s", deletedObj.ResourceVersion)
    	}
    
    	testCheckResult(t, w, watch.Event{Type: watch.Deleted, Object: deletedObj})
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 63.8K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/pkg/storage/testing/store_tests.go

    			// We expect the resource version of the returned object to be
    			// updated compared to the last existing object.
    			if storedObj.ResourceVersion == out.ResourceVersion {
    				t.Errorf("expecting resource version to be updated, but get: %s", out.ResourceVersion)
    			}
    			out.ResourceVersion = storedObj.ResourceVersion
    			expectNoDiff(t, "incorrect pod:", tt.expectedObj, out)
    		})
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 12:45:33 UTC 2024
    - 91.4K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/storage/interfaces.go

    // object twice with the same data except for the ResourceVersion and SelfLink must be
    // a no-op. A resourceVersion of type uint64 is a 'raw' resourceVersion,
    // intended to be sent directly to or from the backend. A resourceVersion of
    // type string is a 'safe' resourceVersion, intended for consumption by users.
    type Versioner interface {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 07:53:48 UTC 2024
    - 14.8K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apiextensions-apiserver/pkg/registry/customresourcedefinition/strategy_test.go

    			crd := &apiextensions.CustomResourceDefinition{
    				ObjectMeta: metav1.ObjectMeta{Name: "foos." + test.group, Annotations: map[string]string{v1beta1.KubeAPIApprovedAnnotation: test.annotationValue}, ResourceVersion: "1"},
    				Spec: apiextensions.CustomResourceDefinitionSpec{
    					Group:    test.group,
    					Scope:    apiextensions.NamespaceScoped,
    					Version:  "v1",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 44.6K bytes
    - Viewed (0)
  10. staging/src/k8s.io/api/testdata/v1.30.0/core.v1.Node.yaml

        controller: true
        kind: kindValue
        name: nameValue
        uid: uidValue
      resourceVersion: resourceVersionValue
      selfLink: selfLinkValue
      uid: uidValue
    spec:
      configSource:
        configMap:
          kubeletConfigKey: kubeletConfigKeyValue
          name: nameValue
          namespace: namespaceValue
          resourceVersion: resourceVersionValue
          uid: uidValue
      externalID: externalIDValue
      podCIDR: podCIDRValue
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 08:52:25 UTC 2024
    - 2.9K bytes
    - Viewed (0)
Back to top