Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 94 for podAdd (0.13 sec)

  1. 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)
  2. 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)
  3. pkg/controller/volume/persistentvolume/volume_host.go

    }
    
    func (ctrl *PersistentVolumeController) GetPodsDir() string {
    	return ""
    }
    
    func (ctrl *PersistentVolumeController) GetPodVolumeDir(podUID types.UID, pluginName string, volumeName string) string {
    	return ""
    }
    
    func (ctrl *PersistentVolumeController) GetPodPluginDir(podUID types.UID, pluginName string) string {
    	return ""
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 11:00:37 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  4. pkg/kubelet/prober/prober.go

    			pb.recordContainerEvent(pod, &container, v1.EventTypeWarning, events.ContainerUnhealthy, "%s probe errored: %v", probeType, err)
    		} else { // result != probe.Success
    			klog.V(1).InfoS("Probe failed", "probeType", probeType, "pod", klog.KObj(pod), "podUID", pod.UID, "containerName", container.Name, "probeResult", result, "output", output)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Feb 16 10:50:13 UTC 2024
    - 8.7K bytes
    - Viewed (0)
  5. pkg/volume/nfs/nfs.go

    	}, nil
    }
    
    func (plugin *nfsPlugin) NewUnmounter(volName string, podUID types.UID) (volume.Unmounter, error) {
    	return plugin.newUnmounterInternal(volName, podUID, plugin.host.GetMounter(plugin.GetPluginName()))
    }
    
    func (plugin *nfsPlugin) newUnmounterInternal(volName string, podUID types.UID, mounter mount.Interface) (volume.Unmounter, error) {
    	return &nfsUnmounter{&nfs{
    		volName:         volName,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  6. pkg/kubelet/container/testing/fake_runtime_helper.go

    func (f *FakeRuntimeHelper) GeneratePodHostNameAndDomain(pod *v1.Pod) (string, string, error) {
    	return f.HostName, f.HostDomain, f.Err
    }
    
    func (f *FakeRuntimeHelper) GetPodDir(podUID kubetypes.UID) string {
    	return "/poddir/" + string(podUID)
    }
    
    func (f *FakeRuntimeHelper) GetExtraSupplementalGroupsForPod(pod *v1.Pod) []int64 {
    	return nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Feb 27 11:01:00 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  7. pkg/volume/local/local_linux_test.go

    	}
    	fsGroup1 := int64(s.Gid)
    	fsGroup2 := fsGroup1 + 1
    	pod1 := &v1.Pod{ObjectMeta: metav1.ObjectMeta{UID: types.UID("poduid")}}
    	pod1.Spec.SecurityContext = &v1.PodSecurityContext{
    		FSGroup: &fsGroup1,
    	}
    	pod2 := &v1.Pod{ObjectMeta: metav1.ObjectMeta{UID: types.UID("poduid")}}
    	pod2.Spec.SecurityContext = &v1.PodSecurityContext{
    		FSGroup: &fsGroup2,
    	}
    	err = testFSGroupMount(plug, pod1, tmpDir, fsGroup1)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Aug 24 19:47:49 UTC 2021
    - 2K bytes
    - Viewed (0)
  8. pkg/kubelet/cm/topologymanager/topology_manager.go

    	}
    
    	manager := &manager{
    		scope: scope,
    	}
    
    	return manager, nil
    }
    
    func (m *manager) GetAffinity(podUID string, containerName string) TopologyHint {
    	return m.scope.GetAffinity(podUID, containerName)
    }
    
    func (m *manager) GetPolicy() Policy {
    	return m.scope.GetPolicy()
    }
    
    func (m *manager) AddHintProvider(h HintProvider) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jul 15 12:43:16 UTC 2023
    - 7.6K bytes
    - Viewed (0)
  9. pkg/kubelet/server/stats/handler.go

    	GetNodeConfig() cm.NodeConfig
    	// ListVolumesForPod returns the stats of the volume used by the pod with
    	// the podUID.
    	ListVolumesForPod(podUID types.UID) (map[string]volume.Volume, bool)
    	// ListBlockVolumesForPod returns the stats of the volume used by the
    	// pod with the podUID.
    	ListBlockVolumesForPod(podUID types.UID) (map[string]volume.BlockVolume, bool)
    	// GetPods returns the specs of all the pods running on this node.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Dec 14 21:31:38 UTC 2023
    - 6.8K bytes
    - Viewed (0)
  10. pkg/volume/iscsi/attacher.go

    	if err != nil {
    		return nil, err
    	}
    	var podUID types.UID
    	if pod != nil {
    		secret, err = createSecretMap(spec, &iscsiPlugin{host: host, targetLocks: targetLocks}, pod.Namespace)
    		if err != nil {
    			return nil, err
    		}
    		podUID = pod.UID
    	}
    	iscsiDisk, err := createISCSIDisk(spec,
    		podUID,
    		&iscsiPlugin{host: host, targetLocks: targetLocks},
    		&ISCSIUtil{},
    		secret,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Aug 04 08:51:31 UTC 2022
    - 6.8K bytes
    - Viewed (0)
Back to top