Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 253 for podAdd (0.24 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top