- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 40 for oldObj (0.39 sec)
-
pkg/scheduler/util/assumecache/assume_cache_test.go
// Assume new object. if err := cache.Assume(newObj); err != nil { t.Fatalf("Assume() returned error %v", err) } verify(ktesting.WithStep(tCtx, "after Assume"), cache, oldObj.GetName(), newObj, oldObj) // Restore object. cache.Restore(oldObj.GetName()) verify(ktesting.WithStep(tCtx, "after second Restore"), cache, oldObj.GetName(), oldObj, oldObj) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 09:46:58 UTC 2024 - 9.5K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/nodeunschedulable/node_unschedulable_test.go
}, }, }, }, oldObj: &v1.Node{ Spec: v1.NodeSpec{ Unschedulable: true, }, }, expectedHint: framework.QueueSkip, }, { name: "queue-on-unschedulable-field-change", pod: &v1.Pod{}, newObj: &v1.Node{ Spec: v1.NodeSpec{ Unschedulable: false, }, }, oldObj: &v1.Node{ Spec: v1.NodeSpec{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Dec 16 12:50:11 UTC 2023 - 4.3K bytes - Viewed (0) -
pkg/registry/networking/servicecidr/strategy_test.go
if len(errors) != 2 { t.Errorf("Expected 2 validation errors for invalid object, got %d", len(errors)) } oldObj := newServiceCIDR() newObj := oldObj.DeepCopy() newObj.Spec.CIDRs = []string{"bad cidr"} errors = Strategy.ValidateUpdate(context.TODO(), newObj, oldObj) if len(errors) != 2 { t.Errorf("Expected 2 validation errors for invalid update, got %d", len(errors)) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jan 04 15:09:29 UTC 2024 - 2.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/conversion.go
// convert the old and new objects to the requested version versionedAttr := &VersionedAttributes{ Attributes: attr, VersionedKind: gvk, } if oldObj := attr.GetOldObject(); oldObj != nil { out, err := ConvertToGVK(oldObj, gvk, o) if err != nil { return nil, err } versionedAttr.VersionedOldObject = out } if obj := attr.GetObject(); obj != nil { out, err := ConvertToGVK(obj, gvk, o)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 07 16:56:12 UTC 2023 - 4.5K bytes - Viewed (0) -
plugin/pkg/admission/storage/persistentvolume/resize/admission_test.go
name string resource schema.GroupVersionResource subresource string oldObj runtime.Object newObj runtime.Object checkError func(error) bool }{ { name: "pvc-resize, update, no error", resource: api.SchemeGroupVersion.WithResource("persistentvolumeclaims"), oldObj: &api.PersistentVolumeClaim{ Spec: api.PersistentVolumeClaimSpec{ VolumeName: "volume1",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Aug 21 13:31:28 UTC 2023 - 7.7K bytes - Viewed (0) -
pkg/kube/controllers/common.go
UpdateFunc: func(oldInterface, newInterface any) { oldObj := ExtractObject(oldInterface) if oldObj == nil { return } newObj := ExtractObject(newInterface) if newObj == nil { return } if onlyIncludeSpecChanges && oldObj.GetResourceVersion() == newObj.GetResourceVersion() { return } newer := filter(newObj) older := filter(oldObj) if !newer && !older { return }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 11 08:27:29 UTC 2024 - 8.9K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/schedulinggates/scheduling_gates_test.go
}) } } func Test_isSchedulableAfterPodChange(t *testing.T) { testcases := map[string]struct { pod *v1.Pod oldObj, newObj interface{} expectedHint framework.QueueingHint expectedErr bool }{ "backoff-wrong-old-object": { pod: &v1.Pod{}, oldObj: "not-a-pod", expectedHint: framework.Queue, expectedErr: true, }, "backoff-wrong-new-object": {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 3.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/fieldmanager/equality.go
// except for timestamp, but the objects are the different. This is the // slow path which checks the full object. oldAccessor, err := meta.Accessor(oldObj) if err != nil { return nil, fmt.Errorf("failed to acquire accessor for oldObj: %v", err) } accessor, err := meta.Accessor(newObj) if err != nil { return nil, fmt.Errorf("failed to acquire accessor for newObj: %v", err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 28 14:56:34 UTC 2022 - 5.3K bytes - Viewed (0) -
pkg/registry/core/configmap/strategy.go
return false } func (strategy) PrepareForUpdate(ctx context.Context, newObj, oldObj runtime.Object) { oldConfigMap := oldObj.(*api.ConfigMap) newConfigMap := newObj.(*api.ConfigMap) dropDisabledFields(newConfigMap, oldConfigMap) } func (strategy) ValidateUpdate(ctx context.Context, newObj, oldObj runtime.Object) field.ErrorList { oldCfg, newCfg := oldObj.(*api.ConfigMap), newObj.(*api.ConfigMap)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 27 20:38:11 UTC 2023 - 3.7K bytes - Viewed (0) -
pkg/scheduler/util/utils.go
} } if oldObj != nil { if realOldObj, ok := oldObj.(cache.DeletedFinalStateUnknown); ok { oldObj = realOldObj.Obj } oldTyped, ok = oldObj.(T) if !ok { return oldTyped, newTyped, fmt.Errorf("expected %T, but got %T", oldTyped, oldObj) } } return oldTyped, newTyped, nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Sep 21 01:40:44 UTC 2023 - 6.2K bytes - Viewed (0)