Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for ContainerMap (0.16 sec)

  1. pkg/kubelet/cm/cpumanager/state/state_checkpoint_test.go

    	}{
    		{
    			"Restore non-existing checkpoint",
    			"",
    			"none",
    			containermap.ContainerMap{},
    			"",
    			&stateMemory{},
    		},
    		{
    			"Restore default cpu set",
    			`{
    				"policyName": "none",
    				"defaultCPUSet": "4-6",
    				"entries": {},
    				"checksum": 354655845
    			}`,
    			"none",
    			containermap.ContainerMap{},
    			"",
    			&stateMemory{
    				defaultCPUSet: cpuset.New(4, 5, 6),
    			},
    		},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 03 16:26:09 UTC 2023
    - 10.9K bytes
    - Viewed (0)
  2. pkg/kubelet/cm/cpumanager/cpu_manager.go

    	// and the containerID of their containers
    	podStatusProvider status.PodStatusProvider
    
    	// containerMap provides a mapping from (pod, container) -> containerID
    	// for all containers a pod
    	containerMap containermap.ContainerMap
    
    	topology *topology.CPUTopology
    
    	nodeAllocatableReservation v1.ResourceList
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 03 16:26:09 UTC 2023
    - 19.9K bytes
    - Viewed (0)
  3. pkg/kubelet/cm/cpumanager/cpu_manager_test.go

    	containerID := "fakeID"
    	containerMap := containermap.NewContainerMap()
    
    	mgr := &manager{
    		policy: &mockPolicy{
    			err: nil,
    		},
    		state: &mockState{
    			assignments:   state.ContainerCPUAssignments{},
    			defaultCPUSet: cpuset.New(),
    		},
    		lastUpdateState:   state.NewMemoryState(),
    		containerRuntime:  mockRuntimeService{},
    		containerMap:      containerMap,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Oct 06 13:16:15 UTC 2023
    - 42.9K bytes
    - Viewed (0)
  4. pkg/kubelet/cm/memorymanager/memory_manager.go

    	// and the containerID of their containers
    	podStatusProvider status.PodStatusProvider
    
    	// containerMap provides a mapping from (pod, container) -> containerID
    	// for all containers a pod
    	containerMap containermap.ContainerMap
    
    	// sourcesReady provides the readiness of kubelet configuration sources such as apiserver update readiness.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 01 00:50:45 UTC 2023
    - 17.1K bytes
    - Viewed (0)
  5. pkg/kubelet/stats/cri_stats_provider.go

    	}
    
    	containers = removeTerminatedContainers(containers)
    	// Creates container map between the container ID and the Container object.
    	containerMap := make(map[string]*runtimeapi.Container)
    	for _, c := range containers {
    		containerMap[c.Id] = c
    	}
    	return containerMap, podSandboxMap, nil
    }
    
    // ImageFsStats returns the stats of the image filesystem.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 01 18:46:33 UTC 2023
    - 35.1K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. 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)
Back to top