- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 23 for ContainerMap (0.3 sec)
-
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/cm/topologymanager/scope.go
hintProviders []HintProvider // Topology Manager Policy policy Policy // Mapping of (PodUid, ContainerName) to ContainerID for Adding/Removing Pods from PodTopologyHints mapping podMap containermap.ContainerMap } func (s *scope) Name() string { return s.name } func (s *scope) getTopologyHints(podUID string, containerName string) TopologyHint { s.mutex.Lock() defer s.mutex.Unlock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 14 14:44:24 UTC 2023 - 5K bytes - Viewed (0) -
pkg/kubelet/cm/topologymanager/scope_container.go
limitations under the License. */ package topologymanager import ( "k8s.io/api/core/v1" "k8s.io/klog/v2" "k8s.io/kubernetes/pkg/kubelet/cm/admission" "k8s.io/kubernetes/pkg/kubelet/cm/containermap" "k8s.io/kubernetes/pkg/kubelet/lifecycle" "k8s.io/kubernetes/pkg/kubelet/metrics" ) type containerScope struct { scope } // Ensure containerScope implements Scope interface
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 14 14:44:24 UTC 2023 - 2.9K bytes - Viewed (0) -
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) -
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/cm/memorymanager/memory_manager_test.go
} for _, testCase := range testCases { t.Run(testCase.description, func(t *testing.T) { mgr := &manager{ policy: returnPolicyByName(testCase), state: state.NewMemoryState(), containerMap: containermap.NewContainerMap(), containerRuntime: mockRuntimeService{ err: nil, }, activePods: func() []*v1.Pod { return nil }, podStatusProvider: mockPodStatusProvider{}, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 05 13:01:40 UTC 2023 - 70.2K bytes - Viewed (0) -
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) -
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)