Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for ContainerMap (0.22 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
Back to top