Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for deleteVolumes (0.92 sec)

  1. pkg/scheduler/framework/plugins/volumebinding/binder_test.go

    			}
    			if versioner.CompareResourceVersion(pvcInCache, pvc) != 0 {
    				return false, nil
    			}
    		}
    		return true, nil
    	})
    }
    
    func (env *testEnv) deleteVolumes(pvs []*v1.PersistentVolume) {
    	for _, pv := range pvs {
    		assumecache.DeleteTestObject(env.internalBinder.pvCache.AssumeCache, pv)
    	}
    }
    
    func (env *testEnv) deleteClaims(pvcs []*v1.PersistentVolumeClaim) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 09:46:58 UTC 2024
    - 82.8K bytes
    - Viewed (0)
  2. pkg/volume/portworx/portworx.go

    type portworxManager interface {
    	// Creates a volume
    	CreateVolume(provisioner *portworxVolumeProvisioner) (volumeID string, volumeSizeGB int64, labels map[string]string, err error)
    	// Deletes a volume
    	DeleteVolume(deleter *portworxVolumeDeleter) error
    	// Attach a volume
    	AttachVolume(mounter *portworxVolumeMounter, attachOptions map[string]string) (string, error)
    	// Detach a volume
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  3. pkg/controller/volume/persistentvolume/pv_controller_base.go

    		} else {
    			logger.Error(err, "Could not sync volume", "volumeName", volume.Name, "err", err)
    		}
    	}
    }
    
    // deleteVolume runs in worker thread and handles "volume deleted" event.
    func (ctrl *PersistentVolumeController) deleteVolume(ctx context.Context, volume *v1.PersistentVolume) {
    	logger := klog.FromContext(ctx)
    	if err := ctrl.volumes.store.Delete(volume); err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 08:42:31 UTC 2024
    - 29.5K bytes
    - Viewed (0)
  4. pkg/kubelet/volumemanager/cache/actual_state_of_world.go

    	}
    
    	return nil
    }
    
    func (asw *actualStateOfWorld) DeleteVolume(volumeName v1.UniqueVolumeName) error {
    	asw.Lock()
    	defer asw.Unlock()
    
    	volumeObj, volumeExists := asw.attachedVolumes[volumeName]
    	if !volumeExists {
    		return nil
    	}
    
    	if len(volumeObj.mountedPods) != 0 {
    		return fmt.Errorf(
    			"failed to DeleteVolume %q, it still has %v mountedPods",
    			volumeName,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Apr 09 07:34:33 UTC 2024
    - 45.8K bytes
    - Viewed (0)
  5. pkg/controller/volume/persistentvolume/pv_controller_test.go

    				obj := ctrl.claims.List()[0]
    				claim := obj.(*v1.PersistentVolumeClaim)
    				reactor.DeleteClaimEvent(claim)
    				return nil
    			},
    		},
    		{
    			// deleteVolume with a bound volume. Check the claim is Lost.
    			name:            "5-4 - delete volume",
    			initialVolumes:  newVolumeArray("volume5-4", "1Gi", "uid5-4", "claim5-4", v1.VolumeBound, v1.PersistentVolumeReclaimRetain, classEmpty),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 43.4K bytes
    - Viewed (0)
  6. pkg/controller/volume/persistentvolume/delete_test.go

    				// Delete the volume before delete operation starts
    				reactor.DeleteVolume("volume8-6")
    			}),
    		},
    		{
    			// delete success(?) - volume is bound just at the time doDelete()
    			// starts. This simulates "volume no longer needs recycling,
    			// skipping".
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 15.8K bytes
    - Viewed (0)
Back to top