- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 37 for PVName (0.12 sec)
-
pkg/volume/csi/csi_attacher_test.go
bTrue = true ) func makeTestAttachment(attachID, nodeName, pvName string) *storage.VolumeAttachment { return &storage.VolumeAttachment{ ObjectMeta: metav1.ObjectMeta{ Name: attachID, }, Spec: storage.VolumeAttachmentSpec{ NodeName: nodeName, Attacher: "mock", Source: storage.VolumeAttachmentSource{ PersistentVolumeName: &pvName, }, }, Status: storage.VolumeAttachmentStatus{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 12:23:16 UTC 2024 - 58.1K bytes - Viewed (0) -
pkg/controller/volume/pvprotection/pv_protection_controller.go
startTime := time.Now() defer func() { logger.V(4).Info("Finished processing PV", "PV", klog.KRef("", pvName), "cost", time.Since(startTime)) }() pv, err := c.pvLister.Get(pvName) if apierrors.IsNotFound(err) { logger.V(4).Info("PV not found, ignoring", "PV", klog.KRef("", pvName)) return nil } if err != nil { return err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6.4K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/volumebinding/assume_cache.go
} } func (c *PVAssumeCache) GetPV(pvName string) (*v1.PersistentVolume, error) { obj, err := c.Get(pvName) if err != nil { return nil, err } pv, ok := obj.(*v1.PersistentVolume) if !ok { return nil, &assumecache.WrongTypeError{TypeName: "v1.PersistentVolume", Object: obj} } return pv, nil } func (c *PVAssumeCache) GetAPIPV(pvName string) (*v1.PersistentVolume, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 09:46:58 UTC 2024 - 3.7K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/attach_detach_controller_test.go
} podInformer.GetIndexer().Add(newPod) } if tc.pvName != "" { var newPv *v1.PersistentVolume if tc.csiMigration { // NewPV returns a GCEPersistentDisk volume, which is migrated. newPv = controllervolumetesting.NewPV(tc.pvName, tc.volName) } else { // Otherwise use NFS, which is not subject to migration. newPv = controllervolumetesting.NewNFSPV(tc.pvName, tc.volName) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 11:00:37 UTC 2024 - 24.2K bytes - Viewed (0) -
pkg/volume/csi/csi_block_test.go
if err != nil { t.Fatalf("Failed to make a new Mapper: %v", err) } pvName := pv.GetName() nodeName := string(plug.host.GetNodeName()) csiMapper.csiClient = setupClient(t, true) attachID := getAttachmentName(csiMapper.volumeID, string(csiMapper.driverName), string(nodeName)) attachment := makeTestAttachment(attachID, nodeName, pvName) attachment.Status.Attached = true
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Sep 11 06:07:40 UTC 2023 - 26.5K bytes - Viewed (0) -
pkg/registry/storage/volumeattachment/storage/storage_test.go
} func validNewVolumeAttachment(name string) *storageapi.VolumeAttachment { pvName := "foo" return &storageapi.VolumeAttachment{ ObjectMeta: metav1.ObjectMeta{ Name: name, }, Spec: storageapi.VolumeAttachmentSpec{ Attacher: "valid-attacher", Source: storageapi.VolumeAttachmentSource{ PersistentVolumeName: &pvName, }, NodeName: "valid-node", }, } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 15:46:12 UTC 2023 - 6.2K bytes - Viewed (1) -
pkg/scheduler/framework/plugins/volumezone/volume_zone.go
} pvc, err := pl.pvcLister.PersistentVolumeClaims(pod.Namespace).Get(pvcName) if s := getErrorAsStatus(err); !s.IsSuccess() { return nil, s } pvName := pvc.Spec.VolumeName if pvName == "" { scName := storagehelpers.GetPersistentVolumeClaimClass(pvc) if len(scName) == 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 16 14:13:06 UTC 2024 - 10.9K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/testing/testvolumespec.go
PersistentVolumeName: &pvName, }, }, Status: storagev1.VolumeAttachmentStatus{ Attached: status, }, } } // Returns a persistentVolume object func NewPV(pvName, volumeName string) *v1.PersistentVolume { return &v1.PersistentVolume{ ObjectMeta: metav1.ObjectMeta{ UID: types.UID(pvName), Name: pvName, }, Spec: v1.PersistentVolumeSpec{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 17 08:48:30 UTC 2023 - 16.5K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/volumebinding/assume_cache_test.go
func TestAssumeUpdatePVCache(t *testing.T) { logger, _ := ktesting.NewTestContext(t) cache := NewPVAssumeCache(logger, nil) pvName := "test-pv0" // Add a PV pv := makePV(pvName, "").withVersion("1").PersistentVolume assumecache.AddTestObject(cache.AssumeCache, pv) if err := verifyPV(cache, pvName, pv); err != nil { t.Fatalf("failed to get PV: %v", err) } // Assume PV newPV := pv.DeepCopy()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 09:46:58 UTC 2024 - 12.8K bytes - Viewed (0) -
pkg/volume/util/recyclerclient/recycler_client.go
// will be overwritten with unique name based on PV.Name. // client - kube client for API operations. func RecycleVolumeByWatchingPodUntilCompletion(pvName string, pod *v1.Pod, kubeClient clientset.Interface, recorder RecycleEventRecorder) error { return internalRecycleVolumeByWatchingPodUntilCompletion(pvName, pod, newRecyclerClient(kubeClient, recorder)) } // same as above func comments, except 'recyclerClient' is a narrower pod API
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 8.5K bytes - Viewed (1)