- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 62 for oldObj (3.02 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/etcd3/watcher.go
return nil } } res = &watch.Event{ Type: watch.Bookmark, Object: object, } case e.isDeleted: if !wc.filter(oldObj) { return nil } res = &watch.Event{ Type: watch.Deleted, Object: oldObj, } case e.isCreated: if !wc.filter(curObj) { return nil } res = &watch.Event{ Type: watch.Added, Object: curObj, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Sep 25 10:26:38 UTC 2023 - 18.9K bytes - Viewed (0) -
pkg/controller/garbagecollector/graph_builder.go
gvk: kind, } gb.graphChanges.Add(event) }, UpdateFunc: func(oldObj, newObj interface{}) { // TODO: check if there are differences in the ownerRefs, // finalizers, and DeletionTimestamp; if not, ignore the update. event := &event{ eventType: updateEvent, obj: newObj, oldObj: oldObj, gvk: kind, } gb.graphChanges.Add(event) },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 36.9K bytes - Viewed (0) -
plugin/pkg/admission/gc/gc_admission.go
return nil } func isChangingOwnerReference(newObj, oldObj runtime.Object) bool { newMeta, err := meta.Accessor(newObj) if err != nil { // if we don't have objectmeta, we don't have the object reference return false } if oldObj == nil { return len(newMeta.GetOwnerReferences()) > 0 } oldMeta, err := meta.Accessor(oldObj) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Sep 05 02:24:38 UTC 2023 - 10.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/registry/rest/update.go
func (i *wrappedUpdatedObjectInfo) UpdatedObject(ctx context.Context, oldObj runtime.Object) (runtime.Object, error) { newObj, err := i.objInfo.UpdatedObject(ctx, oldObj) if err != nil { return newObj, err } // Allow any configured transformers to update the new object or error for _, transformer := range i.transformers { newObj, err = transformer(ctx, newObj, oldObj) if err != nil { return nil, err } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Sep 27 11:48:28 UTC 2022 - 11.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/update.go
transformers = append(transformers, func(ctx context.Context, newObj, oldObj runtime.Object) (runtime.Object, error) { isNotZeroObject, err := hasUID(oldObj) if err != nil { return nil, fmt.Errorf("unexpected error when extracting UID from oldObj: %v", err.Error()) } else if !isNotZeroObject { if mutatingAdmission.Handles(admission.Create) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 01 20:19:46 UTC 2023 - 11.5K bytes - Viewed (0) -
pkg/scheduler/eventhandlers_test.go
SchedulingQueue: queue.NewTestQueue(ctx, nil), logger: logger, } sched.addPodToCache(tt.oldObj) sched.updatePodInCache(tt.oldObj, tt.newObj) if tt.oldObj.(*v1.Pod).UID != tt.newObj.(*v1.Pod).UID { if pod, err := sched.Cache.GetPod(tt.oldObj.(*v1.Pod)); err == nil { t.Errorf("Get pod UID %v from cache but it should not happen", pod.UID) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 10 14:38:54 UTC 2024 - 21.5K bytes - Viewed (0) -
pkg/controller/resourcequota/resource_quota_monitor.go
func (qm *QuotaMonitor) controllerFor(ctx context.Context, resource schema.GroupVersionResource) (cache.Controller, error) { logger := klog.FromContext(ctx) handlers := cache.ResourceEventHandlerFuncs{ UpdateFunc: func(oldObj, newObj interface{}) { if qm.updateFilter != nil && qm.updateFilter(resource, oldObj, newObj) { event := &event{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 11.6K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/interpodaffinity/plugin.go
return } func (pl *InterPodAffinity) isSchedulableAfterPodChange(logger klog.Logger, pod *v1.Pod, oldObj, newObj interface{}) (framework.QueueingHint, error) { originalPod, modifiedPod, err := util.As[*v1.Pod](oldObj, newObj) if err != nil { return framework.Queue, err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 12 03:08:44 UTC 2024 - 10.3K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/podtopologyspread/plugin.go
} func (pl *PodTopologySpread) isSchedulableAfterPodChange(logger klog.Logger, pod *v1.Pod, oldObj, newObj interface{}) (framework.QueueingHint, error) { originalPod, modifiedPod, err := util.As[*v1.Pod](oldObj, newObj) if err != nil { return framework.Queue, err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 16 14:13:06 UTC 2024 - 12.7K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/nodeaffinity/node_affinity_test.go
pod: podWithNodeAffinity.Obj(), oldObj: st.MakeNode().Obj(), newObj: st.MakeNode().Capacity(nil).Obj(), expectedHint: framework.QueueSkip, }, "skip-unrelated-changes-on-labels": { args: &config.NodeAffinityArgs{}, pod: podWithNodeAffinity.DeepCopy(), oldObj: st.MakeNode().Obj(), newObj: st.MakeNode().Label("k", "v").Obj(),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Dec 18 12:00:10 UTC 2023 - 38.7K bytes - Viewed (0)