Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for PodUpdate (0.11 sec)

  1. pkg/kubelet/config/config_test.go

    		// should register an empty PodUpdate operation
    		podUpdate := CreatePodUpdate(kubetypes.SET, TestSource)
    		channel <- podUpdate
    		expectPodUpdate(t, ch, CreatePodUpdate(test.op, TestSource))
    
    		// should ignore following empty sets
    		podUpdate = CreatePodUpdate(kubetypes.SET, TestSource)
    		channel <- podUpdate
    		podUpdate = CreatePodUpdate(kubetypes.ADD, TestSource, CreateValidPod("foo", "new"))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 17.1K bytes
    - Viewed (0)
  2. pkg/controller/tainteviction/taint_eviction.go

    }
    
    func (tc *Controller) handlePodUpdate(ctx context.Context, podUpdate podUpdateItem) {
    	pod, err := tc.podLister.Pods(podUpdate.podNamespace).Get(podUpdate.podName)
    	logger := klog.FromContext(ctx)
    	if err != nil {
    		if apierrors.IsNotFound(err) {
    			// Delete
    			podNamespacedName := types.NamespacedName{Namespace: podUpdate.podNamespace, Name: podUpdate.podName}
    			logger.V(4).Info("Noticed pod deletion", "pod", podNamespacedName)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 19.9K bytes
    - Viewed (0)
  3. pkg/kubelet/config/config.go

    	}
    
    	s.pods[source] = pods
    
    	adds = &kubetypes.PodUpdate{Op: kubetypes.ADD, Pods: copyPods(addPods), Source: source}
    	updates = &kubetypes.PodUpdate{Op: kubetypes.UPDATE, Pods: copyPods(updatePods), Source: source}
    	deletes = &kubetypes.PodUpdate{Op: kubetypes.DELETE, Pods: copyPods(deletePods), Source: source}
    	removes = &kubetypes.PodUpdate{Op: kubetypes.REMOVE, Pods: copyPods(removePods), Source: source}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 16.7K bytes
    - Viewed (0)
  4. 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)
  5. pkg/scheduler/framework/plugins/noderesources/fit.go

    func (f *Fit) EventsToRegister() []framework.ClusterEventWithHint {
    	podActionType := framework.Delete
    	if f.enableInPlacePodVerticalScaling {
    		// If InPlacePodVerticalScaling (KEP 1287) is enabled, then PodUpdate event should be registered
    		// for this plugin since a Pod update may free up resources that make other Pods schedulable.
    		podActionType |= framework.Update
    	}
    	return []framework.ClusterEventWithHint{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 20.2K bytes
    - Viewed (0)
Back to top