- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 253 for podAdd (0.15 sec)
-
pkg/kubelet/cm/devicemanager/pod_devices.go
func (pdev *podDevices) containerDevices(podUID, contName, resource string) sets.Set[string] { pdev.RLock() defer pdev.RUnlock() if _, podExists := pdev.devs[podUID]; !podExists { return nil } if _, contExists := pdev.devs[podUID][contName]; !contExists { return nil } devs, resourceExists := pdev.devs[podUID][contName][resource] if !resourceExists {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jan 27 02:10:25 UTC 2024 - 16.7K bytes - Viewed (0) -
pkg/kubelet/status/testing/mock_pod_status_provider.go
func (m *MockPodStartupLatencyStateHelper) DeletePodStartupState(podUID types.UID) { m.ctrl.T.Helper() m.ctrl.Call(m, "DeletePodStartupState", podUID) } // DeletePodStartupState indicates an expected call of DeletePodStartupState. func (mr *MockPodStartupLatencyStateHelperMockRecorder) DeletePodStartupState(podUID any) *gomock.Call { mr.mock.ctrl.T.Helper()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 15.4K bytes - Viewed (0) -
pkg/kubelet/userns/userns_manager.go
return err } for _, podUID := range found { allFound.Insert(string(podUID)) } // Lets remove all the pods "found" that are not known. for _, podUID := range found { if allPods.Has(string(podUID)) { continue } klog.V(5).InfoS("Clean up orphaned pod user namespace possible allocation", "podUID", podUID) m.releaseWithLock(podUID) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 14.3K bytes - Viewed (0) -
pkg/kubelet/cm/topologymanager/scope.go
} func (s *scope) getTopologyHints(podUID string, containerName string) TopologyHint { s.mutex.Lock() defer s.mutex.Unlock() return s.podTopologyHints[podUID][containerName] } func (s *scope) setTopologyHints(podUID string, containerName string, th TopologyHint) { s.mutex.Lock() defer s.mutex.Unlock() if s.podTopologyHints[podUID] == nil { s.podTopologyHints[podUID] = make(map[string]TopologyHint) }
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/userns/userns_manager_switch_test.go
require.NoError(t, err) for _, podUID := range pods { pod := v1.Pod{ObjectMeta: metav1.ObjectMeta{UID: podUID}} userns, err := m2.GetOrCreateUserNamespaceMappings(&pod, "") assert.NoError(t, err, "failed to record userns range for pod %v", podUID) assert.Nil(t, userns, "userns range should be nil for pod %v", podUID) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 5K bytes - Viewed (0) -
pkg/kubelet/status/state/state_checkpoint.go
// GetContainerResourceAllocation returns current resources allocated to a pod's container func (sc *stateCheckpoint) GetContainerResourceAllocation(podUID string, containerName string) (v1.ResourceList, bool) { sc.mux.RLock() defer sc.mux.RUnlock() return sc.cache.GetContainerResourceAllocation(podUID, containerName) } // GetPodResourceAllocation returns current pod resource allocation
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 13 00:16:44 UTC 2023 - 6.9K bytes - Viewed (0) -
pkg/volume/fc/fc.go
} mapper.MetricsProvider = volume.NewMetricsBlock(filepath.Join(blockPath, string(podUID))) return mapper, nil } func (plugin *fcPlugin) NewUnmounter(volName string, podUID types.UID) (volume.Unmounter, error) { // Inject real implementations here, test through the internal function.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 17.4K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/fake_cpu_manager.go
return m.state } func (m *fakeManager) GetExclusiveCPUs(podUID, containerName string) cpuset.CPUSet { klog.InfoS("GetExclusiveCPUs", "podUID", podUID, "containerName", containerName) return cpuset.CPUSet{} } func (m *fakeManager) GetAllocatableCPUs() cpuset.CPUSet { klog.InfoS("Get Allocatable CPUs") return cpuset.CPUSet{} } func (m *fakeManager) GetCPUAffinity(podUID, containerName string) cpuset.CPUSet {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 03 16:26:09 UTC 2023 - 2.9K bytes - Viewed (0) -
pkg/kubelet/pod_workers.go
// UpdatePod. func (p *podWorkers) completeSync(podUID types.UID) { p.podLock.Lock() defer p.podLock.Unlock() klog.V(4).InfoS("Pod indicated lifecycle completed naturally and should now terminate", "podUID", podUID) status, ok := p.podSyncStatuses[podUID] if !ok { klog.V(4).InfoS("Pod had no status in completeSync, programmer error?", "podUID", podUID) return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 02 13:22:37 UTC 2024 - 74.8K bytes - Viewed (0) -
pkg/kubelet/status/fake_status_manager.go
klog.InfoS("RemoveOrphanedStatuses()") return } func (m *fakeManager) GetContainerResourceAllocation(podUID string, containerName string) (v1.ResourceList, bool) { klog.InfoS("GetContainerResourceAllocation()") return m.state.GetContainerResourceAllocation(podUID, containerName) } func (m *fakeManager) GetPodResizeStatus(podUID string) (v1.PodResizeStatus, bool) { klog.InfoS("GetPodResizeStatus()") return "", false }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 07 05:59:34 UTC 2023 - 2.7K bytes - Viewed (0)