- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 62 for getResourceVersion (0.27 sec)
-
pkg/test/framework/components/echo/kube/pod_controller.go
AddFunc: func(pod *corev1.Pod) { q.Push(func() error { return handlers.added(pod) }) }, UpdateFunc: func(old, cur *corev1.Pod) { q.Push(func() error { if old.GetResourceVersion() != cur.GetResourceVersion() { return handlers.updated(cur) } return nil }) }, DeleteFunc: func(pod *corev1.Pod) { q.Push(func() error { return handlers.deleted(pod) }) }, })
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 09 02:22:47 UTC 2023 - 2.6K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/apis/meta/v1/meta.go
GetNamespace() string SetNamespace(namespace string) GetName() string SetName(name string) GetGenerateName() string SetGenerateName(name string) GetUID() types.UID SetUID(uid types.UID) GetResourceVersion() string SetResourceVersion(version string) GetGeneration() int64 SetGeneration(generation int64) GetSelfLink() string SetSelfLink(selfLink string) GetCreationTimestamp() Time
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 05 20:12:50 UTC 2022 - 7.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/registry/rest/table.go
return nil, err } } if m, err := meta.ListAccessor(object); err == nil { table.ResourceVersion = m.GetResourceVersion() table.Continue = m.GetContinue() table.RemainingItemCount = m.GetRemainingItemCount() } else { if m, err := meta.CommonAccessor(object); err == nil { table.ResourceVersion = m.GetResourceVersion() } } if opt, ok := tableOptions.(*metav1.TableOptions); !ok || !opt.NoHeaders {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 14 17:25:12 UTC 2022 - 3.4K bytes - Viewed (0) -
pkg/api/testing/meta_test.go
case isLM: m := lm.GetListMeta() if m == nil { t.Errorf("%v (%v) returns nil ListMeta", gv.WithKind(kind), knownType) continue } m.SetResourceVersion("102030") if m.GetResourceVersion() != "102030" { t.Errorf("%v (%v) did not preserve resource version", gv.WithKind(kind), knownType) continue } case isOM: m := om.GetObjectMeta() if m == nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 14 10:11:56 UTC 2022 - 3.1K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/registry/customresource/tableconvertor/tableconvertor.go
} if m, err := meta.ListAccessor(obj); err == nil { table.ResourceVersion = m.GetResourceVersion() table.Continue = m.GetContinue() table.RemainingItemCount = m.GetRemainingItemCount() } else { if m, err := meta.CommonAccessor(obj); err == nil { table.ResourceVersion = m.GetResourceVersion() } } var err error buf := &bytes.Buffer{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 23 20:21:32 UTC 2022 - 5.2K bytes - Viewed (0) -
pkg/controller/garbagecollector/patch.go
if err != nil { return nil, err } expectedObjectMeta := ObjectMetaForPatch{} expectedObjectMeta.ResourceVersion = accessor.GetResourceVersion() refs := accessor.GetOwnerReferences() for _, ref := range refs { var skip bool for _, ownerUID := range ownerUIDs { if ref.UID == ownerUID { skip = true break } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 05 13:33:52 UTC 2021 - 5.6K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/pv_controller_base.go
return false, err } objResourceVersion, err := strconv.ParseInt(objAccessor.GetResourceVersion(), 10, 64) if err != nil { return false, fmt.Errorf("error parsing ResourceVersion %q of %s %q: %s", objAccessor.GetResourceVersion(), className, objName, err) } oldObjResourceVersion, err := strconv.ParseInt(oldObjAccessor.GetResourceVersion(), 10, 64) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 08:42:31 UTC 2024 - 29.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/generic/policy_test_context.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 19K bytes - Viewed (0) -
pilot/pkg/config/kube/crdclient/client.go
return "", fmt.Errorf("nil spec for %v/%v", cfg.Name, cfg.Namespace) } meta, err := create(cl.client, cfg, getObjectMetadata(cfg)) if err != nil { return "", err } return meta.GetResourceVersion(), nil } // Update implements store interface func (cl *Client) Update(cfg config.Config) (string, error) { if cfg.Spec == nil { return "", fmt.Errorf("nil spec for %v/%v", cfg.Name, cfg.Namespace) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 00:12:28 UTC 2024 - 13.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/internal/generic/controller.go
if err1 != nil { utilruntime.HandleError(err1) } if err2 != nil { utilruntime.HandleError(err2) } return } else if oldMeta.GetResourceVersion() == newMeta.GetResourceVersion() { if len(oldMeta.GetResourceVersion()) == 0 { klog.Warningf("%v throwing out update with empty RV. this is likely to happen if a test did not supply a resource version on an updated object", c.options.Name) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 7.5K bytes - Viewed (0)