Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 36 of 36 for oldpod (0.1 sec)

  1. pkg/kubelet/prober/scale_test.go

    							Running: &v1.ContainerStateRunning{
    								StartedAt: metav1.Now(),
    							},
    						},
    						Started: utilpointer.Bool(true),
    					})
    				}
    				podManager.AddPod(&pod)
    				m.statusManager.SetPodStatus(&pod, pod.Status)
    				m.AddPod(&pod)
    			}
    			t.Logf("Adding %d pods with %d containers each in %v", numTestPods, numContainers, time.Since(now))
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Aug 16 16:33:01 UTC 2023
    - 8.2K bytes
    - Viewed (0)
  2. src/cmd/internal/cov/read_test.go

    type visitor struct {
    	metaFileCount    int
    	counterFileCount int
    	funcCounterData  int
    	metaFuncCount    int
    }
    
    func (v *visitor) BeginPod(p pods.Pod) {}
    func (v *visitor) EndPod(p pods.Pod)   {}
    func (v *visitor) VisitMetaDataFile(mdf string, mfr *decodemeta.CoverageMetaFileReader) {
    	v.metaFileCount++
    }
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue May 23 11:36:17 UTC 2023
    - 3.5K bytes
    - Viewed (0)
  3. pkg/kubelet/prober/common_test.go

    	podManager := kubepod.NewBasicPodManager()
    	podStartupLatencyTracker := kubeletutil.NewPodStartupLatencyTracker()
    	// Add test pod to pod manager, so that status manager can get the pod from pod manager if needed.
    	podManager.AddPod(getTestPod())
    	testRootDir := ""
    	if tempDir, err := os.MkdirTemp("", "kubelet_test."); err != nil {
    		return nil
    	} else {
    		testRootDir = tempDir
    	}
    	m := NewManager(
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 12 16:57:26 UTC 2023
    - 4.3K bytes
    - Viewed (0)
  4. pkg/scheduler/framework/cycle_state.go

    type StateData interface {
    	// Clone is an interface to make a copy of StateData. For performance reasons,
    	// clone should make shallow copies for members (e.g., slices or maps) that are not
    	// impacted by PreFilter's optional AddPod/RemovePod methods.
    	Clone() StateData
    }
    
    // StateKey is the type of keys stored in CycleState.
    type StateKey string
    
    // CycleState provides a mechanism for plugins to store and retrieve arbitrary data.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 18 06:48:20 UTC 2023
    - 4K bytes
    - Viewed (0)
  5. pkg/controller/volume/attachdetach/metrics/metrics_test.go

    	volumeName := v1.UniqueVolumeName("volume-name")
    	volumeSpec := controllervolumetesting.GetTestVolumeSpec(string(volumeName), volumeName)
    	nodeName := k8stypes.NodeName("node-name")
    
    	dsw.AddNode(nodeName)
    	_, err := dsw.AddPod(types.UniquePodName(podName), controllervolumetesting.NewPod(podName, podName), volumeSpec, nodeName)
    	if err != nil {
    		t.Fatalf("Expected no error, got %v", err)
    	}
    	logger, _ := ktesting.NewTestContext(t)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 10:42:15 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  6. pkg/scheduler/internal/cache/snapshot.go

    	for _, pod := range pods {
    		nodeName := pod.Spec.NodeName
    		if _, ok := nodeNameToInfo[nodeName]; !ok {
    			nodeNameToInfo[nodeName] = framework.NewNodeInfo()
    		}
    		nodeNameToInfo[nodeName].AddPod(pod)
    	}
    	imageExistenceMap := createImageExistenceMap(nodes)
    
    	for _, node := range nodes {
    		if _, ok := nodeNameToInfo[node.Name]; !ok {
    			nodeNameToInfo[node.Name] = framework.NewNodeInfo()
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 17 01:38:03 UTC 2023
    - 6.6K bytes
    - Viewed (0)
Back to top