Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 32 for setResourceVersion (0.34 sec)

  1. staging/src/k8s.io/apimachinery/pkg/apis/meta/v1/unstructured/unstructured.go

    	}
    	u.setNestedField(string(uid), "metadata", "uid")
    }
    
    func (u *Unstructured) GetResourceVersion() string {
    	return getNestedString(u.Object, "metadata", "resourceVersion")
    }
    
    func (u *Unstructured) SetResourceVersion(resourceVersion string) {
    	if len(resourceVersion) == 0 {
    		RemoveNestedField(u.Object, "metadata", "resourceVersion")
    		return
    	}
    	u.setNestedField(resourceVersion, "metadata", "resourceVersion")
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun May 28 03:26:35 UTC 2023
    - 13.7K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go

    						return err
    					}
    					// the first call to this function
    					// primes the cacher
    					if !hasBeenPrimed {
    						listAccessor.SetResourceVersion("100")
    						hasBeenPrimed = true
    						return nil
    					}
    					listAccessor.SetResourceVersion("105")
    					return nil
    				}
    				return s
    			}(),
    			verifyBackingStore: func(t *testing.T, s *dummyStorage) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 82.9K bytes
    - Viewed (0)
  3. pkg/apis/networking/validation/validation_test.go

    					t.Fatalf("Expected error: %v, got %v", testCase.expectedErrs[i].Error(), err.Error())
    				}
    			}
    		})
    	}
    }
    
    func TestValidateIngressClassUpdate(t *testing.T) {
    	setResourceVersion := func(version string) netIngressTweak {
    		return func(ingressClass *networking.IngressClass) {
    			ingressClass.ObjectMeta.ResourceVersion = version
    		}
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 31 21:05:06 UTC 2023
    - 73.3K bytes
    - Viewed (0)
  4. pkg/scheduler/framework/plugins/dynamicresources/dynamicresources_test.go

    			if obj.GetResourceVersion() != "" {
    				return true, nil, errors.New("ResourceVersion must not be set on create")
    			}
    			obj.SetUID(types.UID(fmt.Sprintf("UID-%d", uidCounter)))
    			uidCounter++
    			obj.SetResourceVersion(fmt.Sprintf("%d", resourceVersionCounter))
    			resourceVersionCounter++
    		case "update":
    			uid := obj.GetUID()
    			resourceVersion := obj.GetResourceVersion()
    			if uid == "" {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 27 07:57:10 UTC 2024
    - 61.9K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apimachinery/pkg/runtime/interfaces.go

    }
    
    // ResourceVersioner provides methods for setting and retrieving
    // the resource version from an API object.
    type ResourceVersioner interface {
    	SetResourceVersion(obj Object, version string) error
    	ResourceVersion(obj Object) (string, error)
    }
    
    // Namer provides methods for retrieving name and namespace of an API object.
    type Namer interface {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun May 28 03:26:35 UTC 2023
    - 19K bytes
    - Viewed (0)
  6. pilot/pkg/config/kube/gateway/deploymentcontroller.go

    	if !canManage {
    		log.Debugf("skipping %v/%v/%v, already managed", gvr, us.GetName(), us.GetNamespace())
    		return nil
    	}
    	// Ensure our canManage assertion is not stale
    	us.SetResourceVersion(resourceVersion)
    
    	log.Debugf("applying %v", string(j))
    	if err := d.patcher(gvr, us.GetName(), us.GetNamespace(), j); err != nil {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon May 13 21:43:20 UTC 2024
    - 26.3K bytes
    - Viewed (0)
  7. pkg/controller/deployment/deployment_controller_test.go

    			b.Errorf("Invalid map size, expected 2, got: %d", len(m))
    		}
    	}
    }
    
    func bumpResourceVersion(obj metav1.Object) {
    	ver, _ := strconv.ParseInt(obj.GetResourceVersion(), 10, 32)
    	obj.SetResourceVersion(strconv.FormatInt(ver+1, 10))
    }
    
    // generatePodFromRS creates a pod, with the input ReplicaSet's selector and its template
    func generatePodFromRS(rs *apps.ReplicaSet) *v1.Pod {
    	trueVar := true
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 32.5K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apimachinery/pkg/util/managedfields/fieldmanager_test.go

    			"apiVersion": "apps/v1",
    			"kind":       "Deployment",
    		},
    	}
    
    	newObj.SetName("b")
    	newObj.SetNamespace("b")
    	newObj.SetUID("b")
    	newObj.SetGeneration(0)
    	newObj.SetResourceVersion("b")
    	newObj.SetCreationTimestamp(metav1.NewTime(time.Now()))
    	newObj.SetManagedFields([]metav1.ManagedFieldsEntry{
    		{
    			Manager:    "update",
    			Operation:  metav1.ManagedFieldsOperationApply,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 16 20:03:48 UTC 2023
    - 32.5K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apiextensions-apiserver/test/integration/conversion/conversion_test.go

    		APIVersion:         "v1",
    		Kind:               "Namespace",
    		Name:               "default",
    		UID:                "1234",
    		Controller:         nil,
    		BlockOwnerDeletion: nil,
    	}})
    	u.SetResourceVersion("42")
    	u.SetFinalizers([]string{"foo"})
    	if err := unstructured.SetNestedField(u.Object, "foo", "metadata", "garbage"); err != nil {
    		return runtime.RawExtension{}, err
    	}
    
    	raw, err := json.Marshal(u)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 06 05:32:34 UTC 2023
    - 47.1K bytes
    - Viewed (0)
  10. pkg/controller/statefulset/stateful_set_control_test.go

    	obj, isObj := object.(metav1.Object)
    	if !isObj {
    		return
    	}
    	if version := obj.GetResourceVersion(); version == "" {
    		obj.SetResourceVersion("1")
    	} else if intValue, err := strconv.ParseInt(version, 10, 32); err == nil {
    		obj.SetResourceVersion(strconv.FormatInt(intValue+1, 10))
    	}
    }
    func TestParallelScale(t *testing.T) {
    	for _, tc := range []struct {
    		desc                        string
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 07 19:01:47 UTC 2024
    - 108.7K bytes
    - Viewed (0)
Back to top