- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 1,371 for resourceVersion (0.22 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)