- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for ContainerMap (0.24 sec)
-
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) -
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) -
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 (1) -
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) -
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) -
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) -
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) -
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) -
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)