Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for StatusManager (0.15 sec)

  1. pkg/kubelet/kubelet.go

    	// which pods are running.
    	volumeManager volumemanager.VolumeManager
    
    	// statusManager receives updated pod status updates from the podWorker and updates the API
    	// status of those pods to match. The statusManager is authoritative for the synthesized
    	// status of the pod from the kubelet's perspective (other components own the individual
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 126.1K bytes
    - Viewed (0)
  2. pkg/kubelet/kubelet_test.go

    	kl.HandlePodAdditions(pods)
    	if _, found := kl.statusManager.GetPodStatus(podToTest.UID); !found {
    		t.Fatalf("expected to have status cached for pod2")
    	}
    	// Sync with empty pods so that the entry in status map will be removed.
    	kl.podManager.SetPods([]*v1.Pod{})
    	kl.HandlePodCleanups(ctx)
    	if _, found := kl.statusManager.GetPodStatus(podToTest.UID); found {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 106.9K bytes
    - Viewed (0)
  3. pkg/kubelet/kubelet_pods.go

    				break
    			}
    		}
    	}
    	if !specStatusDiffer {
    		// Clear last resize state from checkpoint
    		if err := kl.statusManager.SetPodResizeStatus(pod.UID, ""); err != nil {
    			klog.ErrorS(err, "SetPodResizeStatus failed", "pod", pod.Name)
    		}
    	} else {
    		if resizeStatus, found := kl.statusManager.GetPodResizeStatus(string(pod.UID)); found {
    			podResizeStatus = resizeStatus
    		}
    	}
    	return podResizeStatus
    }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 101.2K bytes
    - Viewed (0)
  4. pkg/kubelet/kubelet_pods_test.go

    			testKubelet := newTestKubelet(t, false /* controllerAttachDetachEnabled */)
    			defer testKubelet.Cleanup()
    			kl := testKubelet.kubelet
    
    			oldStatus := test.pod.Status
    			kl.statusManager = status.NewFakeManager()
    			kl.statusManager.SetPodStatus(test.pod, oldStatus)
    			actual := kl.generateAPIPodStatus(test.pod, &testKubecontainerPodStatus /* criStatus */, false /* test.isPodTerminal */)
    
    			if actual.Resize != "" {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 00:05:23 UTC 2024
    - 198.8K bytes
    - Viewed (0)
Back to top