Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 14 for ContainerMap (0.17 sec)

  1. pkg/kubelet/cm/helpers.go

    	podSandboxMap := make(map[string]string)
    	podSandboxList, _ := runtimeService.ListPodSandbox(ctx, nil)
    	for _, p := range podSandboxList {
    		podSandboxMap[p.Id] = p.Metadata.Uid
    	}
    
    	runningSet := sets.New[string]()
    	containerMap := containermap.NewContainerMap()
    	containerList, _ := runtimeService.ListContainers(ctx, nil)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 27 13:02:15 UTC 2023
    - 2.8K bytes
    - Viewed (0)
  2. 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)
  3. 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)
  4. pkg/kubelet/cm/memorymanager/fake_memory_manager.go

    	state state.State
    }
    
    func (m *fakeManager) Start(activePods ActivePodsFunc, sourcesReady config.SourcesReady, podStatusProvider status.PodStatusProvider, containerRuntime runtimeService, initialContainers containermap.ContainerMap) error {
    	klog.InfoS("Start()")
    	return nil
    }
    
    func (m *fakeManager) Policy() Policy {
    	klog.InfoS("Policy()")
    	return NewPolicyNone()
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 27 13:02:15 UTC 2023
    - 3.1K bytes
    - Viewed (0)
  5. pkg/kubelet/cm/devicemanager/types.go

    // Manager manages all the Device Plugins running on a node.
    type Manager interface {
    	// Start starts device plugin registration service.
    	Start(activePods ActivePodsFunc, sourcesReady config.SourcesReady, initialContainers containermap.ContainerMap, initialContainerRunningSet sets.Set[string]) error
    
    	// Allocate configures and assigns devices to a container in a pod. From
    	// the requested device resources, Allocate will communicate with the
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 27 13:02:15 UTC 2023
    - 5K bytes
    - Viewed (0)
  6. pkg/kubelet/cm/cpumanager/state/state_checkpoint.go

    	"k8s.io/kubernetes/pkg/kubelet/cm/containermap"
    	"k8s.io/utils/cpuset"
    )
    
    var _ State = &stateCheckpoint{}
    
    type stateCheckpoint struct {
    	mux               sync.RWMutex
    	policyName        string
    	cache             State
    	checkpointManager checkpointmanager.CheckpointManager
    	checkpointName    string
    	initialContainers containermap.ContainerMap
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jul 13 00:59:30 UTC 2023
    - 7.9K bytes
    - Viewed (0)
  7. 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)
  8. pkg/kubelet/stats/cri_stats_provider_linux.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.Linux.Containers {
    		container, found := containerMap[criContainerStat.Attributes.Id]
    		if !found {
    			continue
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 16 11:09:04 UTC 2023
    - 4K bytes
    - Viewed (0)
  9. pkg/kubelet/cm/container_manager_windows.go

    			cm.capacity[rName] = rCap
    		}
    	}
    
    	ctx := context.Background()
    	containerMap, containerRunningSet := buildContainerMapAndRunningSetFromRuntime(ctx, runtimeService)
    
    	// Starts device manager.
    	if err := cm.deviceManager.Start(devicemanager.ActivePodsFunc(activePods), sourcesReady, containerMap, containerRunningSet); err != nil {
    		return err
    	}
    
    	return nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jul 12 11:25:36 UTC 2023
    - 8.7K bytes
    - Viewed (0)
  10. pkg/kubelet/stats/cri_stats_provider_others.go

    	return nil, nil
    }
    
    func (p *criStatsProvider) addCRIPodContainerStats(criSandboxStat *runtimeapi.PodSandboxStats,
    	ps *statsapi.PodStats, fsIDtoInfo map[runtimeapi.FilesystemIdentifier]*cadvisorapiv2.FsInfo,
    	containerMap map[string]*runtimeapi.Container,
    	podSandbox *runtimeapi.PodSandbox,
    	rootFsInfo *cadvisorapiv2.FsInfo, updateCPUNanoCoreUsage bool) error {
    	return nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 16 11:09:04 UTC 2023
    - 1.8K bytes
    - Viewed (0)
Back to top