Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 261 for pvcuid (0.25 sec)

  1. pkg/controller/volume/attachdetach/util/util.go

    				return nil, err
    			}
    		}
    
    		pvName, pvcUID := pvc.Spec.VolumeName, pvc.UID
    		logger.V(10).Info("Found bound PV for PVC", "PVC", klog.KRef(pod.Namespace, claimName), "pvcUID", pvcUID, "PV", klog.KRef("", pvName))
    
    		// Fetch actual PV object
    		volumeSpec, err := getPVSpecFromCache(
    			pvName, readOnly, pvcUID, pvLister)
    		if err != nil {
    			return nil, fmt.Errorf(
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 10:42:15 UTC 2024
    - 12K bytes
    - Viewed (0)
  2. pkg/controller/volume/expand/expand_controller_test.go

    				Namespace: "default",
    			},
    			Capacity: map[v1.ResourceName]resource.Quantity{
    				v1.ResourceStorage: resource.MustParse(size),
    			},
    		},
    	}
    	if pvcUID != "" {
    		pv.Spec.ClaimRef.UID = pvcUID
    	}
    
    	if matched, _ := regexp.MatchString(`csi`, pluginName); matched {
    		pv.Spec.PersistentVolumeSource.CSI = &v1.CSIPersistentVolumeSource{
    			Driver:       pluginName,
    			VolumeHandle: volumeName,
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 11:00:37 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  3. pkg/kubelet/volumemanager/populator/desired_state_of_world_populator.go

    				return nil, nil, "", err
    			}
    		}
    		pvName, pvcUID := pvc.Spec.VolumeName, pvc.UID
    		klog.V(5).InfoS("Found bound PV for PVC", "PVC", klog.KRef(pod.Namespace, pvcSource.ClaimName), "PVCUID", pvcUID, "PVName", pvName)
    		// Fetch actual PV object
    		volumeSpec, volumeGidValue, err :=
    			dswp.getPVSpec(pvName, pvcSource.ReadOnly, pvcUID)
    		if err != nil {
    			return nil, nil, "", fmt.Errorf(
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 11 09:02:45 UTC 2024
    - 23.8K bytes
    - Viewed (0)
  4. pkg/controller/volume/expand/expand_controller.go

    	return ""
    }
    
    func (expc *expandController) GetPodVolumeDir(podUID types.UID, pluginName string, volumeName string) string {
    	return ""
    }
    
    func (expc *expandController) GetPodVolumeDeviceDir(podUID types.UID, pluginName string) string {
    	return ""
    }
    
    func (expc *expandController) GetPodPluginDir(podUID types.UID, pluginName string) string {
    	return ""
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  5. pkg/kubelet/volumemanager/reconciler/reconstruct_test.go

    	pv := &v1.PersistentVolume{
    		ObjectMeta: metav1.ObjectMeta{
    			Name: pvName,
    			UID:  "pvuid",
    		},
    		Spec: v1.PersistentVolumeSpec{
    			ClaimRef:   &v1.ObjectReference{Name: pvcName},
    			VolumeMode: &volumeMode,
    		},
    	}
    	pvc := &v1.PersistentVolumeClaim{
    		ObjectMeta: metav1.ObjectMeta{
    			Name: pvcName,
    			UID:  "pvcuid",
    		},
    		Spec: v1.PersistentVolumeClaimSpec{
    			VolumeName: pvName,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 14.8K bytes
    - Viewed (0)
  6. pkg/kubelet/volumemanager/reconciler/reconciler_test.go

    					ObjectMeta: metav1.ObjectMeta{
    						Name: tc.volumeName,
    						UID:  "pvuid",
    					},
    					Spec: v1.PersistentVolumeSpec{
    						ClaimRef:   &v1.ObjectReference{Name: "pvc"},
    						VolumeMode: &mode,
    					},
    				}
    				pvc := &v1.PersistentVolumeClaim{
    					ObjectMeta: metav1.ObjectMeta{
    						Name: "pvc",
    						UID:  "pvcuid",
    					},
    					Spec: v1.PersistentVolumeClaimSpec{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Apr 09 07:34:33 UTC 2024
    - 75.4K bytes
    - Viewed (0)
  7. 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)
  8. pkg/kubelet/status/state/state_mem.go

    }
    
    func (s *stateMemory) deleteContainer(podUID string, containerName string) {
    	delete(s.podAllocation[podUID], containerName)
    	if len(s.podAllocation[podUID]) == 0 {
    		delete(s.podAllocation, podUID)
    		delete(s.podResizeStatus, podUID)
    	}
    	klog.V(3).InfoS("Deleted pod resource allocation", "podUID", podUID, "containerName", containerName)
    }
    
    func (s *stateMemory) Delete(podUID string, containerName string) error {
    	s.Lock()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Feb 24 18:21:21 UTC 2023
    - 4K bytes
    - Viewed (0)
  9. pkg/kubelet/cm/containermap/container_map.go

    		containerName string
    	}{podUID, containerName}
    }
    
    // RemoveByContainerID removes a mapping of (containerID)->(podUID, containerName) from the ContainerMap
    func (cm ContainerMap) RemoveByContainerID(containerID string) {
    	delete(cm, containerID)
    }
    
    // RemoveByContainerRef removes a mapping of (containerID)->(podUID, containerName) from the ContainerMap
    func (cm ContainerMap) RemoveByContainerRef(podUID, containerName string) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 30 15:25:05 UTC 2022
    - 2.5K bytes
    - Viewed (0)
  10. pkg/kubelet/cm/cpumanager/state/state_mem.go

    	klog.InfoS("Updated CPUSet assignments", "assignments", a)
    }
    
    func (s *stateMemory) Delete(podUID string, containerName string) {
    	s.Lock()
    	defer s.Unlock()
    
    	delete(s.assignments[podUID], containerName)
    	if len(s.assignments[podUID]) == 0 {
    		delete(s.assignments, podUID)
    	}
    	klog.V(2).InfoS("Deleted CPUSet assignment", "podUID", podUID, "containerName", containerName)
    }
    
    func (s *stateMemory) ClearState() {
    	s.Lock()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 03 16:26:09 UTC 2023
    - 2.9K bytes
    - Viewed (0)
Back to top