Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 1,371 for resourceVersion (0.22 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/endpoints/handlers/fieldmanager/endpoints.yaml

          resourceVersion: '1234567890'
          uid: 11111111-2222-3333-4444-555555555555
      - ip: 10.0.0.1
        targetRef:
          kind: Pod
          name: pod-name-1234-0004
          namespace: default
          resourceVersion: '1234567890'
          uid: 11111111-2222-3333-4444-555555555555
      - ip: 10.0.0.1
        targetRef:
          kind: Pod
          name: pod-name-1234-0005
          namespace: default
          resourceVersion: '1234567890'
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 25 19:51:58 UTC 2019
    - 183.9K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apimachinery/pkg/util/managedfields/endpoints.yaml

          resourceVersion: '1234567890'
          uid: 11111111-2222-3333-4444-555555555555
      - ip: 10.0.0.1
        targetRef:
          kind: Pod
          name: pod-name-1234-0004
          namespace: default
          resourceVersion: '1234567890'
          uid: 11111111-2222-3333-4444-555555555555
      - ip: 10.0.0.1
        targetRef:
          kind: Pod
          name: pod-name-1234-0005
          namespace: default
          resourceVersion: '1234567890'
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 08 21:44:00 UTC 2023
    - 183.9K bytes
    - Viewed (0)
  4. 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)
  5. 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)
  6. staging/src/k8s.io/apimachinery/pkg/api/validation/objectmeta_test.go

    			Old:          metav1.ObjectMeta{Name: "test", ResourceVersion: "1"},
    			New:          metav1.ObjectMeta{Name: "test", ResourceVersion: "1"},
    			ExpectedNew:  metav1.ObjectMeta{Name: "test", ResourceVersion: "1"},
    			ExpectedErrs: []string{},
    		},
    		"valid with deletion fields": {
    			Old:          metav1.ObjectMeta{Name: "test", ResourceVersion: "1", DeletionTimestamp: &now, DeletionGracePeriodSeconds: &gracePeriodShort},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 07 03:12:31 UTC 2022
    - 17.8K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/pkg/storage/api_object_versioner.go

    func (a APIObjectVersioner) UpdateList(obj runtime.Object, resourceVersion uint64, nextKey string, count *int64) error {
    	if resourceVersion == 0 {
    		return fmt.Errorf("illegal resource version from storage: %d", resourceVersion)
    	}
    	listAccessor, err := meta.ListAccessor(obj)
    	if err != nil || listAccessor == nil {
    		return err
    	}
    	versionString := strconv.FormatUint(resourceVersion, 10)
    	listAccessor.SetResourceVersion(versionString)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 11 15:19:32 UTC 2022
    - 3.9K bytes
    - Viewed (0)
  8. 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)
  9. 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)
  10. pilot/pkg/config/memory/store.go

    		return "", errConflict
    	}
    	if cfg.Annotations != nil && cfg.Annotations[ResourceVersion] != "" {
    		cfg.ResourceVersion = cfg.Annotations[ResourceVersion]
    		delete(cfg.Annotations, ResourceVersion)
    	} else {
    		cfg.ResourceVersion = time.Now().String()
    	}
    
    	ns[cfg.Name] = cfg
    	return cfg.ResourceVersion, nil
    }
    
    func (cr *store) UpdateStatus(cfg config.Config) (string, error) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Dec 26 01:14:27 UTC 2023
    - 6.3K bytes
    - Viewed (0)
Back to top