Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 405 for volumeName (0.22 sec)

  1. pkg/controller/volume/attachdetach/cache/desired_state_of_world.go

    	}
    
    	volumeObj, volumeExists := nodeObj.volumesToAttach[volumeName]
    	if !volumeExists {
    		volumeObj = volumeToAttach{
    			multiAttachErrorReported: false,
    			volumeName:               volumeName,
    			spec:                     volumeSpec,
    			scheduledPods:            make(map[types.UniquePodName]pod),
    		}
    		dsw.nodesManaged[nodeName].volumesToAttach[volumeName] = volumeObj
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 10:42:15 UTC 2024
    - 13.5K bytes
    - Viewed (0)
  2. pkg/volume/util/operationexecutor/operation_executor.go

    	// IsOperationPending returns true if an operation for the given volumeName
    	// and one of podName or nodeName is pending, otherwise it returns false
    	IsOperationPending(volumeName v1.UniqueVolumeName, podName volumetypes.UniquePodName, nodeName types.NodeName) bool
    	// IsOperationSafeToRetry returns false if an operation for the given volumeName
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 42.6K bytes
    - Viewed (0)
  3. pkg/kubelet/volumemanager/cache/desired_state_of_world.go

    		reportedVolumesMap[reportedVolume] = true
    	}
    
    	for volumeName, volumeObj := range dsw.volumesToMount {
    		_, volumeReported := reportedVolumesMap[volumeName]
    		volumeObj.reportedInUse = volumeReported
    		dsw.volumesToMount[volumeName] = volumeObj
    	}
    }
    
    func (dsw *desiredStateOfWorld) DeletePodFromVolume(
    	podName types.UniquePodName, volumeName v1.UniqueVolumeName) {
    	dsw.Lock()
    	defer dsw.Unlock()
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 27.1K bytes
    - Viewed (0)
  4. pkg/volume/util/operationexecutor/operation_executor_test.go

    	secretName := "secret-volume"
    	volumeName := v1.UniqueVolumeName(secretName)
    
    	// Act
    	for i := range volumesToMount {
    		podName := "pod-" + strconv.Itoa(i+1)
    		pod := getTestPodWithSecret(podName, secretName)
    		volumesToMount[i] = VolumeToMount{
    			Pod:                     pod,
    			VolumeName:              volumeName,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 26.9K bytes
    - Viewed (0)
  5. cmd/storage-rest_test.go

    		t.Fatalf("unexpected error %v", err)
    	}
    
    	testCases := []struct {
    		volumeName string
    		objectName string
    		expectErr  bool
    	}{
    		{"foo", "myobject", false},
    		// file not found error.
    		{"foo", "yourobject", true},
    	}
    
    	for i, testCase := range testCases {
    		_, err := storage.StatInfoFile(context.Background(), testCase.volumeName, testCase.objectName+"/"+xlStorageFormatFile, false)
    		expectErr := (err != nil)
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  6. pkg/controller/volume/persistentvolume/pv_controller.go

    			return nil
    		}
    	} else /* pvc.Spec.VolumeName != nil */ {
    		// [Unit test set 2]
    		// User asked for a specific PV.
    		logger.V(4).Info("Synchronizing unbound PersistentVolumeClaim, volume requested", "PVC", klog.KObj(claim), "volumeName", claim.Spec.VolumeName)
    		obj, found, err := ctrl.volumes.store.GetByKey(claim.Spec.VolumeName)
    		if err != nil {
    			return err
    		}
    		if !found {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 08:42:31 UTC 2024
    - 89.2K bytes
    - Viewed (0)
  7. pkg/kubelet/volumemanager/cache/actual_state_of_world_test.go

    	}
    
    	verifyVolumeExistsAsw(t, volumeName, false /* shouldExist */, asw)
    	verifyVolumeDoesntExistInUnmountedVolumes(t, volumeName, asw)
    	verifyVolumeDoesntExistInGloballyMountedVolumes(t, volumeName, asw)
    	verifyPodDoesntExistInVolumeAsw(
    		t,
    		podName,
    		volumeName,
    		false, /* expectVolumeToExist */
    		asw)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 46.3K bytes
    - Viewed (0)
  8. pkg/kubelet/volumemanager/reconciler/reconstruct_common.go

    	podVolumes := make(map[volumetypes.UniquePodName]v1.UniqueVolumeName)
    	for podName, volume := range gvi.podVolumes {
    		podVolumes[podName] = volume.volumeName
    	}
    
    	return struct {
    		VolumeName     string                                            `json:"volumeName"`
    		VolumeSpecName string                                            `json:"volumeSpecName"`
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Apr 09 07:34:33 UTC 2024
    - 14.1K bytes
    - Viewed (0)
  9. helm/minio/templates/pvc.yaml

      storageClassName: ""
      {{- else }}
      storageClassName: "{{ .Values.persistence.storageClass }}"
      {{- end }}
      {{- end }}
      {{- if .Values.persistence.volumeName }}
      volumeName: "{{ .Values.persistence.volumeName }}"
      {{- end }}
    {{- end }}
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Sun Apr 30 06:59:40 UTC 2023
    - 1014 bytes
    - Viewed (0)
  10. pkg/volume/util/operationexecutor/operation_generator.go

    	if volumetypes.IsOperationFinishedError(mountError) &&
    		actualStateOfWorld.GetDeviceMountState(volumeToMount.VolumeName) == DeviceMountUncertain {
    
    		if actualStateOfWorld.IsVolumeDeviceReconstructed(volumeToMount.VolumeName) {
    			klog.V(2).InfoS("MountVolume.markDeviceErrorState leaving volume uncertain", "volumeName", volumeToMount.VolumeName)
    			return
    		}
    
    		// Only devices which were uncertain can be marked as unmounted
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 101.4K bytes
    - Viewed (0)
Back to top