- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for ContainerMap (0.22 sec)
-
pkg/kubelet/cm/devicemanager/manager.go
pendingAdmissionPod *v1.Pod // containerMap provides a mapping from (pod, container) -> containerID // for all containers in a pod. Used to detect pods running across a restart containerMap containermap.ContainerMap // containerRunningSet identifies which container among those present in `containerMap` // was reported running by the container runtime when `containerMap` was computed.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 15 12:01:56 UTC 2024 - 43K bytes - Viewed (0) -
pkg/kubelet/stats/cri_stats_provider_windows.go
ps *statsapi.PodStats, fsIDtoInfo map[runtimeapi.FilesystemIdentifier]*cadvisorapiv2.FsInfo, containerMap map[string]*runtimeapi.Container, podSandbox *runtimeapi.PodSandbox, rootFsInfo *cadvisorapiv2.FsInfo, updateCPUNanoCoreUsage bool) error { for _, criContainerStat := range criSandboxStat.GetWindows().GetContainers() { container, found := containerMap[criContainerStat.Attributes.Id] if !found { continue }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Feb 18 07:03:11 UTC 2024 - 10.4K bytes - Viewed (0) -
pkg/kubelet/cm/container_manager_linux.go
err := cm.cpuManager.Start(cpumanager.ActivePodsFunc(activePods), sourcesReady, podStatusProvider, runtimeService, containerMap) if err != nil { return fmt.Errorf("start cpu manager error: %v", err) } // Initialize memory manager if utilfeature.DefaultFeatureGate.Enabled(kubefeatures.MemoryManager) { containerMap, _ := buildContainerMapAndRunningSetFromRuntime(ctx, runtimeService)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:18:16 UTC 2024 - 35.1K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/manager_test.go
} activePods := func() []*v1.Pod { return []*v1.Pod{} } // test steady state, initialization where sourcesReady, containerMap and containerRunningSet // are relevant will be tested with a different flow err = w.Start(activePods, &sourcesReadyStub{}, containermap.NewContainerMap(), sets.New[string]()) require.NoError(t, err) return w, updateChan }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 65K bytes - Viewed (0)