- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 253 for podAdd (0.24 sec)
-
pkg/kubelet/cm/cpumanager/cpu_manager_test.go
} func (s *mockState) SetCPUSet(podUID string, containerName string, cset cpuset.CPUSet) { if _, exists := s.assignments[podUID]; !exists { s.assignments[podUID] = make(map[string]cpuset.CPUSet) } s.assignments[podUID][containerName] = cset } func (s *mockState) SetDefaultCPUSet(cset cpuset.CPUSet) { s.defaultCPUSet = cset } func (s *mockState) Delete(podUID string, containerName string) {
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/util/format/pod.go
// with pod UID as part of the string. func PodDesc(podName, podNamespace string, podUID types.UID) string { // Use underscore as the delimiter because it is not allowed in pod name // (DNS subdomain format), while allowed in the container name format. return fmt.Sprintf("%s_%s(%s)", podName, podNamespace, podUID)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 13 08:27:42 UTC 2023 - 1.3K bytes - Viewed (0) -
pkg/volume/util/util.go
podVolumeMapPath, volumeMapName string, podUID utypes.UID, ) error { // map devicePath to global node path as bind mount mapErr := blkUtil.MapDevice(devicePath, globalMapPath, string(podUID), true /* bindMount */) if mapErr != nil { return fmt.Errorf("blkUtil.MapDevice failed. devicePath: %s, globalMapPath:%s, podUID: %s, bindMount: %v: %v", devicePath, globalMapPath, string(podUID), true, mapErr) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 12:32:15 UTC 2024 - 28.8K bytes - Viewed (0) -
pkg/volume/configmap/configmap.go
}, nil } func (plugin *configMapPlugin) NewUnmounter(volName string, podUID types.UID) (volume.Unmounter, error) { return &configMapVolumeUnmounter{ &configMapVolume{ volName, podUID, plugin, plugin.host.GetMounter(plugin.GetPluginName()), volume.NewCachedMetrics(volume.NewMetricsDu(getPath(podUID, volName, plugin.host))), }, }, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 10K bytes - Viewed (0) -
pkg/volume/testing/volume_host.go
} func (f *fakeVolumeHost) GetPodVolumeDir(podUID types.UID, pluginName, volumeName string) string { return filepath.Join(f.rootDir, "pods", string(podUID), "volumes", pluginName, volumeName) } func (f *fakeVolumeHost) GetPodVolumeDeviceDir(podUID types.UID, pluginName string) string { return filepath.Join(f.rootDir, "pods", string(podUID), "volumeDevices", pluginName) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 09:02:45 UTC 2024 - 16.5K bytes - Viewed (0) -
pkg/kubelet/cm/memorymanager/state/state.go
GetMemoryBlocks(podUID string, containerName string) []Block // GetMemoryAssignments returns ContainerMemoryAssignments GetMemoryAssignments() ContainerMemoryAssignments } type writer interface { // SetMachineState stores NUMANodeMap in State SetMachineState(memoryMap NUMANodeMap) // SetMemoryBlocks stores memory assignments of a container SetMemoryBlocks(podUID string, containerName string, blocks []Block)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 08 23:10:00 UTC 2021 - 4.4K bytes - Viewed (0) -
pkg/kubelet/server/stats/testing/mock_stats_provider.go
func (m *MockProvider) ListVolumesForPod(podUID types.UID) (map[string]volume.Volume, bool) { m.ctrl.T.Helper() ret := m.ctrl.Call(m, "ListVolumesForPod", podUID) ret0, _ := ret[0].(map[string]volume.Volume) ret1, _ := ret[1].(bool) return ret0, ret1 } // ListVolumesForPod indicates an expected call of ListVolumesForPod. func (mr *MockProviderMockRecorder) ListVolumesForPod(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 - 11.8K bytes - Viewed (0) -
pkg/kubelet/util/format/pod_test.go
} } func TestPodAndPodDesc(t *testing.T) { testCases := []struct { caseName string podName string podNamespace string podUID types.UID expectedValue string }{ {"field_empty_case", "", "", "", "_()"},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 13 08:27:42 UTC 2023 - 2.1K bytes - Viewed (0) -
pkg/kubelet/cm/memorymanager/fake_memory_manager.go
klog.InfoS("Get Allocatable Memory") return []state.Block{} } // GetMemory returns the memory allocated by a container from NUMA nodes func (m *fakeManager) GetMemory(podUID, containerName string) []state.Block { klog.InfoS("Get Memory", "podUID", podUID, "containerName", containerName) return []state.Block{} } // NewFakeManager creates empty/fake memory manager func NewFakeManager() Manager { return &fakeManager{
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/volume/local/local.go
mountOptions: util.MountOptionFromSpec(spec), readOnly: readOnly, }, nil } func (plugin *localVolumePlugin) NewUnmounter(volName string, podUID types.UID) (volume.Unmounter, error) { return &localVolumeUnmounter{ localVolume: &localVolume{ podUID: podUID, volName: volName, mounter: plugin.host.GetMounter(plugin.GetPluginName()), plugin: plugin, }, }, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 22.2K bytes - Viewed (0)