- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 261 for pvcuid (0.25 sec)
-
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) -
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) -
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) -
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) -
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) -
pkg/kubelet/volumemanager/reconciler/reconciler_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 09 07:34:33 UTC 2024 - 75.4K bytes - Viewed (0) -
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) -
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) -
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) -
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)