Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 105 for oldobj (0.23 sec)

  1. pkg/controller/replicaset/replica_set.go

    		),
    	}
    
    	rsInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    		AddFunc: func(obj interface{}) {
    			rsc.addRS(logger, obj)
    		},
    		UpdateFunc: func(oldObj, newObj interface{}) {
    			rsc.updateRS(logger, oldObj, newObj)
    		},
    		DeleteFunc: func(obj interface{}) {
    			rsc.deleteRS(logger, obj)
    		},
    	})
    	rsInformer.Informer().AddIndexers(cache.Indexers{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 33.2K bytes
    - Viewed (0)
  2. pkg/controller/serviceaccount/serviceaccounts_controller.go

    	c.queue.Add(namespace.Name)
    }
    
    // namespaceUpdated reacts to a Namespace update (or re-list) by creating a default ServiceAccount in the namespace if needed
    func (c *ServiceAccountsController) namespaceUpdated(oldObj interface{}, newObj interface{}) {
    	newNamespace := newObj.(*v1.Namespace)
    	c.queue.Add(newNamespace.Name)
    }
    
    func (c *ServiceAccountsController) runWorker(ctx context.Context) {
    	for c.processNextWorkItem(ctx) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/plugins/nodevolumelimits/csi.go

    	}
    }
    
    func (pl *CSILimits) isSchedulableAfterPodDeleted(logger klog.Logger, pod *v1.Pod, oldObj, newObj interface{}) (framework.QueueingHint, error) {
    	deletedPod, _, err := util.As[*v1.Pod](oldObj, newObj)
    	if err != nil {
    		return framework.Queue, fmt.Errorf("unexpected objects in isSchedulableAfterPodDeleted: %w", err)
    	}
    
    	if len(deletedPod.Spec.Volumes) == 0 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 18:07:11 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiextensions-apiserver/pkg/controller/openapiv3/controller.go

    	castObj := obj.(*apiextensionsv1.CustomResourceDefinition)
    	klog.V(4).Infof("Adding customresourcedefinition %s", castObj.Name)
    	c.enqueue(castObj)
    }
    
    func (c *Controller) updateCustomResourceDefinition(oldObj, newObj interface{}) {
    	castNewObj := newObj.(*apiextensionsv1.CustomResourceDefinition)
    	klog.V(4).Infof("Updating customresourcedefinition %s", castNewObj.Name)
    	c.enqueue(castNewObj)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  5. pkg/controller/namespace/namespace_controller.go

    		cache.ResourceEventHandlerFuncs{
    			AddFunc: func(obj interface{}) {
    				namespace := obj.(*v1.Namespace)
    				namespaceController.enqueueNamespace(namespace)
    			},
    			UpdateFunc: func(oldObj, newObj interface{}) {
    				namespace := newObj.(*v1.Namespace)
    				namespaceController.enqueueNamespace(namespace)
    			},
    		},
    		resyncPeriod,
    	)
    	namespaceController.lister = namespaceInformer.Lister()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  6. pkg/controller/serviceaccount/tokens_controller.go

    	if serviceAccount, ok := obj.(*v1.ServiceAccount); ok {
    		e.syncServiceAccountQueue.Add(makeServiceAccountKey(serviceAccount))
    	}
    }
    
    func (e *TokensController) queueServiceAccountUpdateSync(oldObj interface{}, newObj interface{}) {
    	if serviceAccount, ok := newObj.(*v1.ServiceAccount); ok {
    		e.syncServiceAccountQueue.Add(makeServiceAccountKey(serviceAccount))
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 20.5K bytes
    - Viewed (0)
  7. pkg/controller/statefulset/stateful_set.go

    		// lookup the statefulset and enqueue
    		AddFunc: func(obj interface{}) {
    			ssc.addPod(logger, obj)
    		},
    		// lookup current and old statefulset if labels changed
    		UpdateFunc: func(oldObj, newObj interface{}) {
    			ssc.updatePod(logger, oldObj, newObj)
    		},
    		// lookup statefulset accounting for deletion tombstones
    		DeleteFunc: func(obj interface{}) {
    			ssc.deletePod(logger, obj)
    		},
    	})
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 05 19:06:41 UTC 2024
    - 18.5K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/configmap_cafile_content.go

    			// so we don't have to be choosy about our key.
    			AddFunc: func(obj interface{}) {
    				c.queue.Add(c.keyFn())
    			},
    			UpdateFunc: func(oldObj, newObj interface{}) {
    				c.queue.Add(c.keyFn())
    			},
    			DeleteFunc: func(obj interface{}) {
    				c.queue.Add(c.keyFn())
    			},
    		},
    	})
    
    	return c, nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  9. pkg/controller/storageversiongc/gc_controller.go

    	castObj := obj.(*apiserverinternalv1alpha1.StorageVersion)
    	c.enqueueStorageVersion(logger, castObj)
    }
    
    func (c *Controller) onUpdateStorageVersion(logger klog.Logger, oldObj, newObj interface{}) {
    	castNewObj := newObj.(*apiserverinternalv1alpha1.StorageVersion)
    	c.enqueueStorageVersion(logger, castNewObj)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 10K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiextensions-apiserver/pkg/controller/openapi/controller.go

    	castObj := obj.(*apiextensionsv1.CustomResourceDefinition)
    	klog.V(4).Infof("Adding customresourcedefinition %s", castObj.Name)
    	c.enqueue(castObj)
    }
    
    func (c *Controller) updateCustomResourceDefinition(oldObj, newObj interface{}) {
    	castNewObj := newObj.(*apiextensionsv1.CustomResourceDefinition)
    	klog.V(4).Infof("Updating customresourcedefinition %s", castNewObj.Name)
    	c.enqueue(castNewObj)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 9.6K bytes
    - Viewed (0)
Back to top