- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 160 for oldobj (0.14 sec)
-
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) -
pkg/registry/core/pod/storage/eviction.go
getLatestPod := func(_ context.Context, _, oldObj runtime.Object) (runtime.Object, error) { // Throwaway the newObj. We care only about the latest pod obtained from etcd (oldObj). // So we can add DisruptionTarget condition in conditionAppender without conflicts. latestPod := oldObj.(*api.Pod).DeepCopy() if options.Preconditions != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 08 11:58:48 UTC 2023 - 18.2K bytes - Viewed (0) -
pkg/controller/endpointslice/endpointslice_controller.go
logger := klog.FromContext(ctx) endpointSliceInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: c.onEndpointSliceAdd, UpdateFunc: func(oldObj, newObj interface{}) { c.onEndpointSliceUpdate(logger, oldObj, newObj) }, DeleteFunc: c.onEndpointSliceDelete, }) c.endpointSliceLister = endpointSliceInformer.Lister()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 23.6K bytes - Viewed (0) -
pkg/controller/daemon/daemon_controller.go
} daemonSetInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { dsc.addDaemonset(logger, obj) }, UpdateFunc: func(oldObj, newObj interface{}) { dsc.updateDaemonset(logger, oldObj, newObj) }, DeleteFunc: func(obj interface{}) { dsc.deleteDaemonset(logger, obj) }, }) dsc.dsLister = daemonSetInformer.Lister()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 51.3K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/registry/customresourcedefinition/strategy.go
} return fields } func (statusStrategy) PrepareForUpdate(ctx context.Context, obj, old runtime.Object) { newObj := obj.(*apiextensions.CustomResourceDefinition) oldObj := old.(*apiextensions.CustomResourceDefinition) newObj.Spec = oldObj.Spec // Status updates are for only for updating status, not objectmeta. metav1.ResetObjectMetaForStatus(&newObj.ObjectMeta, &newObj.ObjectMeta) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 28 19:06:46 UTC 2024 - 10.3K bytes - Viewed (0) -
pkg/registry/apps/statefulset/storage/storage.go
func (i *scaleUpdatedObjectInfo) Preconditions() *metav1.Preconditions { return i.reqObjInfo.Preconditions() } func (i *scaleUpdatedObjectInfo) UpdatedObject(ctx context.Context, oldObj runtime.Object) (runtime.Object, error) { statefulset, ok := oldObj.DeepCopyObject().(*apps.StatefulSet) if !ok { return nil, errors.NewBadRequest(fmt.Sprintf("expected existing object type to be StatefulSet, got %T", statefulset)) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 08 21:44:00 UTC 2023 - 12.7K bytes - Viewed (0)