Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 62 for getResourceVersion (0.27 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/generic/policy_test_context.go

    				policyMeta, err := meta.Accessor(policy.Policy)
    				if err != nil {
    					return true, err
    				} else if policyMeta.GetName() == objectMeta.GetName() && policyMeta.GetResourceVersion() == objectMeta.GetResourceVersion() {
    					return true, nil
    				}
    			}
    			return false, nil
    		})
    	case p.bindingGVK:
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 06 00:00:21 UTC 2024
    - 19K bytes
    - Viewed (0)
  9. 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)
  10. 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)
Back to top