Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 94 for podAdd (0.14 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. pkg/kubelet/stats/host_stats_provider.go

    }
    
    func (h hostStatsProvider) podLogMetrics(podNamespace, podName string, podUID types.UID) (metricsProviderByPath, error) {
    	podLogsDirectoryPath := kuberuntime.BuildPodLogsDirectory(h.podLogsDirectory, podNamespace, podName, podUID)
    	return h.fileMetricsByDir(podLogsDirectoryPath)
    }
    
    func (h hostStatsProvider) podContainerLogMetrics(podNamespace, podName string, podUID types.UID, containerName string) (metricsProviderByPath, error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Feb 16 17:55:59 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  6. pkg/kubelet/status/state/state.go

    type Reader interface {
    	GetContainerResourceAllocation(podUID string, containerName string) (v1.ResourceList, bool)
    	GetPodResourceAllocation() PodResourceAllocation
    	GetPodResizeStatus(podUID string) (v1.PodResizeStatus, bool)
    	GetResizeStatus() PodResizeStatus
    }
    
    type writer interface {
    	SetContainerResourceAllocation(podUID string, containerName string, alloc v1.ResourceList) error
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Feb 24 18:21:21 UTC 2023
    - 2K bytes
    - Viewed (0)
  7. pkg/kubelet/cm/cpumanager/state/state.go

    // Reader interface used to read current cpu/pod assignment state
    type Reader interface {
    	GetCPUSet(podUID string, containerName string) (cpuset.CPUSet, bool)
    	GetDefaultCPUSet() cpuset.CPUSet
    	GetCPUSetOrDefault(podUID string, containerName string) cpuset.CPUSet
    	GetCPUAssignments() ContainerCPUAssignments
    }
    
    type writer interface {
    	SetCPUSet(podUID string, containerName string, cpuset cpuset.CPUSet)
    	SetDefaultCPUSet(cpuset cpuset.CPUSet)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jul 13 00:59:30 UTC 2023
    - 1.7K bytes
    - Viewed (0)
  8. pkg/controller/volume/attachdetach/populator/desired_state_of_world_populator.go

    				podUID := volutil.GetUniquePodName(scheduledPod)
    				dswp.desiredStateOfWorld.DeletePod(podUID, volumeToAttach.VolumeName, volumeToAttach.NodeName)
    				logger.V(4).Info("Removing podUID and volume on node from desired state of world"+
    					" because of the change of volume attachability", "node", klog.KRef("", string(volumeToAttach.NodeName)), "podUID", podUID, "volumeName", volumeToAttach.VolumeName)
    			}
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 14 00:37:30 UTC 2023
    - 7.7K bytes
    - Viewed (0)
  9. pkg/kubelet/stats/host_stats_provider_test.go

    		podEtcHostsPathFunc PodEtcHostsPathFunc
    		podUID              types.UID
    		rootFsInfo          *cadvisorapiv2.FsInfo
    		want                *statsapi.FsStats
    		wantErr             bool
    	}{
    		{
    			name: "Should return nil for runtimes that do not support etc host file",
    			podEtcHostsPathFunc: func(podUID types.UID) string {
    				return ""
    			},
    			podUID:     "fake0001",
    			rootFsInfo: nil,
    			want:       nil,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Feb 10 11:26:59 UTC 2022
    - 1.9K bytes
    - Viewed (0)
  10. pkg/kubelet/kubelet_volumes_linux_test.go

    				if err := tc.validateFunc(kubelet); err != nil {
    					t.Errorf("%s failed validation: %v", name, err)
    				}
    			}
    
    		})
    	}
    }
    
    func TestPodVolumesExistWithMount(t *testing.T) {
    	poduid := types.UID("poduid")
    	testCases := map[string]struct {
    		prepareFunc func(kubelet *Kubelet) error
    		expected    bool
    	}{
    		"noncsivolume-dir-not-exist": {
    			prepareFunc: func(kubelet *Kubelet) error {
    				return nil
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jul 30 03:35:26 UTC 2022
    - 8.9K bytes
    - Viewed (0)
Back to top