Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 104 for oldobj (0.12 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. staging/src/k8s.io/apiextensions-apiserver/pkg/controller/finalizer/crd_finalizer.go

    		c.enqueue(castObj)
    	}
    }
    
    func (c *CRDFinalizer) updateCustomResourceDefinition(oldObj, newObj interface{}) {
    	oldCRD := oldObj.(*apiextensionsv1.CustomResourceDefinition)
    	newCRD := newObj.(*apiextensionsv1.CustomResourceDefinition)
    	// only queue deleted things that haven't been finalized by us
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 12.6K bytes
    - Viewed (0)
  7. pkg/controller/deployment/deployment_controller.go

    	}
    
    	dInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    		AddFunc: func(obj interface{}) {
    			dc.addDeployment(logger, obj)
    		},
    		UpdateFunc: func(oldObj, newObj interface{}) {
    			dc.updateDeployment(logger, oldObj, newObj)
    		},
    		// This will enter the sync loop and no-op, because the deployment has been deleted from the store.
    		DeleteFunc: func(obj interface{}) {
    			dc.deleteDeployment(logger, obj)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 24.2K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/customresource_discovery_controller.go

    	klog.V(4).Infof("Adding customresourcedefinition %s", castObj.Name)
    	c.enqueue(castObj)
    }
    
    func (c *DiscoveryController) updateCustomResourceDefinition(oldObj, newObj interface{}) {
    	castNewObj := newObj.(*apiextensionsv1.CustomResourceDefinition)
    	castOldObj := oldObj.(*apiextensionsv1.CustomResourceDefinition)
    	klog.V(4).Infof("Updating customresourcedefinition %s", castOldObj.Name)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Apr 21 11:40:03 UTC 2024
    - 12.8K bytes
    - Viewed (0)
  9. pkg/kube/kclient/clienttest/test_helpers.go

    	return controllers.EventHandler[controllers.Object]{
    		AddFunc: func(obj controllers.Object) {
    			tracker.Record("add/" + obj.GetName())
    		},
    		UpdateFunc: func(oldObj, newObj controllers.Object) {
    			tracker.Record("update/" + newObj.GetName())
    		},
    		DeleteFunc: func(obj controllers.Object) {
    			tracker.Record("delete/" + obj.GetName())
    		},
    	}
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Feb 23 19:18:21 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  10. pkg/controller/volume/persistentvolume/pv_controller_base.go

    	}
    
    	p.VolumeInformer.Informer().AddEventHandler(
    		cache.ResourceEventHandlerFuncs{
    			AddFunc:    func(obj interface{}) { controller.enqueueWork(ctx, controller.volumeQueue, obj) },
    			UpdateFunc: func(oldObj, newObj interface{}) { controller.enqueueWork(ctx, controller.volumeQueue, newObj) },
    			DeleteFunc: func(obj interface{}) { controller.enqueueWork(ctx, controller.volumeQueue, obj) },
    		},
    	)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 08:42:31 UTC 2024
    - 29.5K bytes
    - Viewed (0)
Back to top