- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 117 for oldObj (0.1 sec)
-
pkg/scheduler/framework/plugins/nodeports/node_ports.go
// that change made a previously unschedulable pod schedulable. func (pl *NodePorts) isSchedulableAfterPodDeleted(logger klog.Logger, pod *v1.Pod, oldObj, newObj interface{}) (framework.QueueingHint, error) { deletedPod, _, err := util.As[*v1.Pod](oldObj, nil) if err != nil { return framework.Queue, err } // If the deleted pod is unscheduled, it doesn't make the target pod schedulable.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 26 10:53:29 UTC 2024 - 7.5K bytes - Viewed (0) -
pkg/kube/krt/informer.go
AddExtendedFunc: func(obj I, initialSync bool) { handler(Event[I]{ New: &obj, Event: controllers.EventAdd, }, initialSync) }, UpdateFunc: func(oldObj, newObj I) { handler(Event[I]{ Old: &oldObj, New: &newObj, Event: controllers.EventUpdate, }, false) }, DeleteFunc: func(obj I) { handler(Event[I]{ Old: &obj,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 11:01:46 UTC 2024 - 6.1K bytes - Viewed (0) -
pkg/controller/replication/conversion.go
return } h.handler.OnAdd(rs, isInInitialList) } func (h conversionEventHandler) OnUpdate(oldObj, newObj interface{}) { oldRS, err := convertRCtoRS(oldObj.(*v1.ReplicationController), nil) if err != nil { utilruntime.HandleError(fmt.Errorf("dropping RC OnUpdate event: can't convert old object %#v to RS: %v", oldObj, err)) return } newRS, err := convertRCtoRS(newObj.(*v1.ReplicationController), nil) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Dec 14 18:43:33 UTC 2022 - 12.7K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/noderesources/fit.go
// that change made a previously unschedulable pod schedulable. func (f *Fit) isSchedulableAfterPodChange(logger klog.Logger, pod *v1.Pod, oldObj, newObj interface{}) (framework.QueueingHint, error) { originalPod, modifiedPod, err := schedutil.As[*v1.Pod](oldObj, newObj) if err != nil { return framework.Queue, err } if modifiedPod == nil { if originalPod.Spec.NodeName == "" {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 20.2K bytes - Viewed (0) -
pkg/controlplane/controller/crdregistration/crdregistration_controller.go
cast := obj.(*apiextensionsv1.CustomResourceDefinition) c.enqueueCRD(cast) }, UpdateFunc: func(oldObj, newObj interface{}) { // Enqueue both old and new object to make sure we remove and add appropriate API services. // The working queue will resolve any duplicates and only changes will stay in the queue. c.enqueueCRD(oldObj.(*apiextensionsv1.CustomResourceDefinition)) c.enqueueCRD(newObj.(*apiextensionsv1.CustomResourceDefinition))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/internal/generic/controller.go
} c.queue.Add(key) } registration, err := c.informer.AddEventHandler(cache.ResourceEventHandlerDetailedFuncs{ AddFunc: enqueue, UpdateFunc: func(oldObj, newObj interface{}) { oldMeta, err1 := meta.Accessor(oldObj) newMeta, err2 := meta.Accessor(newObj) if err1 != nil || err2 != nil { if err1 != nil { utilruntime.HandleError(err1) } if err2 != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 7.5K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/attach_detach_controller.go
podInformer.Informer().AddEventHandler(kcache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { adc.podAdd(logger, obj) }, UpdateFunc: func(oldObj, newObj interface{}) { adc.podUpdate(logger, oldObj, newObj) }, DeleteFunc: func(obj interface{}) { adc.podDelete(logger, obj) }, }) // This custom indexer will index pods by its PVC keys. Then we don't need
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cache_watcher.go
oldObj := getMutableObject(event.PrevObject) // We know that if oldObj is cachingObject (which can only be set via // setCachingObjects), its resourceVersion is already set correctly and // we don't need to update it. However, since cachingObject efficiently // handles noop updates, we avoid this microoptimization here. updateResourceVersion(oldObj, c.versioner, event.ResourceVersion)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 12:22:41 UTC 2023 - 18.7K bytes - Viewed (0) -
pkg/controller/endpointslicemirroring/endpointslicemirroring_controller.go
} endpointsInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { c.onEndpointsAdd(logger, obj) }, UpdateFunc: func(oldObj, newObj interface{}) { c.onEndpointsUpdate(logger, oldObj, newObj) }, DeleteFunc: func(obj interface{}) { c.onEndpointsDelete(logger, obj) }, }) c.endpointsLister = endpointsInformer.Lister()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 06 23:18:31 UTC 2024 - 20.1K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/registry/customresource/etcd.go
} func (i *scaleUpdatedObjectInfo) Preconditions() *metav1.Preconditions { return i.reqObjInfo.Preconditions() } func (i *scaleUpdatedObjectInfo) UpdatedObject(ctx context.Context, oldObj runtime.Object) (runtime.Object, error) { cr := oldObj.DeepCopyObject().(*unstructured.Unstructured) const invalidSpecReplicas = -2147483648 // smallest int32 managedFieldsHandler := managedfields.NewScaleHandler( cr.GetManagedFields(),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 08 21:44:00 UTC 2023 - 12.4K bytes - Viewed (0)