- Sort Score
- Result 10 results
- Languages All
Results 31 - 36 of 36 for oldpod (0.1 sec)
-
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) -
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) -
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) -
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) -
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) -
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)