Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 72 for volumeNames (0.13 sec)

  1. pkg/kubelet/eviction/helpers.go

    func podLocalVolumeUsage(volumeNames []string, podStats statsapi.PodStats) v1.ResourceList {
    	disk := resource.Quantity{Format: resource.BinarySI}
    	inodes := resource.Quantity{Format: resource.DecimalSI}
    	for _, volumeName := range volumeNames {
    		for _, volumeStats := range podStats.VolumeStats {
    			if volumeStats.Name == volumeName {
    				disk.Add(*diskUsage(&volumeStats.FsStats))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 01 18:46:33 UTC 2023
    - 53.6K bytes
    - Viewed (0)
  2. pkg/kubelet/stats/cri_stats_provider_test.go

    	}
    }
    
    func makeFakeVolumeStats(volumeNames []string) []statsapi.VolumeStats {
    	volumes := make([]statsapi.VolumeStats, len(volumeNames))
    	availableBytes := rand.Uint64()
    	capacityBytes := rand.Uint64()
    	usedBytes := rand.Uint64() / 100
    	inodes := rand.Uint64()
    	inodesFree := rand.Uint64()
    	inodesUsed := rand.Uint64() / 100
    	for i, name := range volumeNames {
    		fsStats := statsapi.FsStats{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 14:24:16 UTC 2024
    - 54.5K bytes
    - Viewed (0)
  3. pkg/kubelet/volumemanager/reconciler/reconciler_test.go

    	assert.NoError(t, asw.AddAttachUncertainReconstructedVolume(volumeName2, volumeSpec2, nodeName, ""))
    	assert.NoError(t, asw.MarkDeviceAsUncertain(volumeName2, "/dev/reconstructed", "/var/lib/kubelet/plugins/global2", ""))
    
    	assert.False(t, reconciler.StatesHasBeenSynced())
    
    	reconciler.volumesNeedUpdateFromNodeStatus = append(reconciler.volumesNeedUpdateFromNodeStatus, volumeName1, volumeName2)
    	// Act - run reconcile loop just once.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Apr 09 07:34:33 UTC 2024
    - 75.4K bytes
    - Viewed (0)
  4. pkg/controller/volume/attachdetach/reconciler/reconciler_test.go

    	podName := "pod-uid"
    	volumeName := v1.UniqueVolumeName("volume-name")
    	volumeSpec := controllervolumetesting.GetTestVolumeSpec(string(volumeName), volumeName)
    	nodeName := k8stypes.NodeName("node-name")
    	dsw.AddNode(nodeName)
    	volumeExists := dsw.VolumeExists(volumeName, nodeName)
    	if volumeExists {
    		t.Fatalf(
    			"Volume %q/node %q should not exist, but it does.",
    			volumeName,
    			nodeName)
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 07:00:14 UTC 2024
    - 72.8K bytes
    - Viewed (0)
  5. pkg/controller/volume/attachdetach/cache/actual_state_of_world_test.go

    	asw := NewActualStateOfWorld(volumePluginMgr)
    	volumeName := v1.UniqueVolumeName("volume-name")
    	volumeSpec := controllervolumetesting.GetTestVolumeSpec(string(volumeName), volumeName)
    
    	nodeName := types.NodeName("node-name")
    	devicePath := "fake/device/path"
    
    	// Act
    	logger, _ := ktesting.NewTestContext(t)
    	generatedVolumeName, err := asw.AddVolumeNode(logger, volumeName, volumeSpec, nodeName, devicePath, true)
    
    	// Assert
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 11 07:35:17 UTC 2024
    - 66.1K 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/populator/desired_state_of_world_populator_test.go

    		err := asw.MarkVolumeAsAttached(logger, volumeToMount.VolumeName, volumeToMount.VolumeSpec, "", "")
    		if err != nil {
    			t.Fatalf("Unexpected error when MarkVolumeAsAttached: %v", err)
    		}
    		markVolumeOpts := operationexecutor.MarkVolumeOpts{
    			PodName:             volumeToMount.PodName,
    			PodUID:              volumeToMount.Pod.UID,
    			VolumeName:          volumeToMount.VolumeName,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 51.4K bytes
    - Viewed (0)
  8. pkg/volume/testing/testing.go

    		spec.PersistentVolume.Spec.RBD != nil {
    		volumeName = spec.PersistentVolume.Spec.RBD.RBDImage
    	} else if spec.Volume != nil && spec.Volume.CSI != nil {
    		volumeName = spec.Volume.CSI.Driver
    	}
    	if volumeName == "" {
    		volumeName = spec.Name()
    	}
    	return volumeName, nil
    }
    
    func (plugin *FakeVolumePlugin) CanSupport(spec *volume.Spec) bool {
    	if plugin.CanSupportFn != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 12:32:15 UTC 2024
    - 53.3K bytes
    - Viewed (0)
  9. pkg/apis/storage/validation/validation_test.go

    	}
    }
    
    func TestVolumeAttachmentValidation(t *testing.T) {
    	volumeName := "pv-name"
    	empty := ""
    	migrationEnabledSuccessCases := []storage.VolumeAttachment{{
    		ObjectMeta: metav1.ObjectMeta{Name: "foo"},
    		Spec: storage.VolumeAttachmentSpec{
    			Attacher: "myattacher",
    			Source: storage.VolumeAttachmentSource{
    				PersistentVolumeName: &volumeName,
    			},
    			NodeName: "mynode",
    		},
    	}, {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 69.7K bytes
    - Viewed (0)
  10. pkg/volume/csi/csi_attacher_test.go

    		nodeName            string
    		driverName          string
    		volumeName          string
    		attachID            string
    		spec                *volume.Spec
    		injectAttacherError bool
    		shouldFail          bool
    		watchTimeout        time.Duration
    	}{
    		{
    			name:       "test ok 1",
    			nodeName:   "testnode-01",
    			driverName: "testdriver-01",
    			volumeName: "testvol-01",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 12:23:16 UTC 2024
    - 58.1K bytes
    - Viewed (0)
Back to top