- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 16 for deleteVolumes (1.77 sec)
-
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) -
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) -
pkg/volume/portworx/portworx_util.go
return "", 0, nil, err } klog.Infof("Successfully created Portworx volume for PVC: %v", p.options.PVC.Name) return volumeID, requestGiB, nil, err } // DeleteVolume deletes a Portworx volume func (util *portworxVolumeUtil) DeleteVolume(d *portworxVolumeDeleter) error { driver, err := util.getPortworxDriver(d.plugin.host) if err != nil || driver == nil { klog.Errorf("Failed to get portworx driver. Err: %v", err)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 16 11:12:06 UTC 2022 - 12.2K bytes - Viewed (0) -
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) -
pkg/volume/csi/fake/fake_client.go
func (f *ControllerClient) CreateVolume(ctx context.Context, in *csipb.CreateVolumeRequest, opts ...grpc.CallOption) (*csipb.CreateVolumeResponse, error) { return nil, nil } // DeleteVolume implements csi method func (f *ControllerClient) DeleteVolume(ctx context.Context, in *csipb.DeleteVolumeRequest, opts ...grpc.CallOption) (*csipb.DeleteVolumeResponse, error) { return nil, nil } // ControllerPublishVolume implements csi method
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 20 14:49:03 UTC 2023 - 16K bytes - Viewed (0) -
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) -
pkg/volume/portworx/portworx_test.go
labels = make(map[string]string) labels["fakeportworxmanager"] = "yes" return PortworxTestVolume, 100, labels, nil } func (fake *fakePortworxManager) DeleteVolume(cd *portworxVolumeDeleter) error { if cd.volumeID != PortworxTestVolume { return fmt.Errorf("Deleter got unexpected volume name: %s", cd.volumeID) } return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 21 02:17:04 UTC 2021 - 7.4K bytes - Viewed (0) -
pkg/controller/volume/persistentvolume/testing/testing.go
func (r *VolumeReactor) AddVolume(volume *v1.PersistentVolume) { r.lock.Lock() defer r.lock.Unlock() r.volumes[volume.Name] = volume } // DeleteVolume deletes a PV by name. func (r *VolumeReactor) DeleteVolume(name string) { r.lock.Lock() defer r.lock.Unlock() delete(r.volumes, name) } // AddClaimBoundToVolume adds a PVC and binds it to corresponding PV.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 15:46:12 UTC 2023 - 20.1K bytes - Viewed (0) -
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) -
pkg/controller/volume/persistentvolume/recycle_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 00:37:30 UTC 2023 - 14.2K bytes - Viewed (0)