Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for expectedVolumes (0.17 sec)

  1. pkg/controller/volume/persistentvolume/delete_test.go

    			name:            "8-1 - successful delete",
    			initialVolumes:  newVolumeArray("volume8-1", "1Gi", "uid8-1", "claim8-1", v1.VolumeBound, v1.PersistentVolumeReclaimDelete, classEmpty, volume.AnnBoundByController),
    			expectedVolumes: novolumes,
    			initialClaims:   noclaims,
    			expectedClaims:  noclaims,
    			expectedEvents:  noevents,
    			errors:          noerrors,
    			// Inject deleter into the controller and call syncVolume. The
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 15.8K bytes
    - Viewed (0)
  2. pkg/controller/volume/persistentvolume/binder_test.go

    			// syncClaim binds to a matching unbound volume.
    			name:            "1-1 - successful bind",
    			initialVolumes:  newVolumeArray("volume1-1", "1Gi", "", "", v1.VolumeAvailable, v1.PersistentVolumeReclaimRetain, classEmpty),
    			expectedVolumes: newVolumeArray("volume1-1", "1Gi", "uid1-1", "claim1-1", v1.VolumeBound, v1.PersistentVolumeReclaimRetain, classEmpty, volume.AnnBoundByController),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 14 00:37:30 UTC 2023
    - 65.8K bytes
    - Viewed (0)
  3. pkg/kubelet/volumemanager/volume_manager.go

    	}
    	return filterUnmountedVolumes(mountedVolumes, expectedVolumes)
    }
    
    // filterUnmountedVolumes adds each element of expectedVolumes that is not in
    // mountedVolumes to a list of unmountedVolumes and returns it.
    func filterUnmountedVolumes(mountedVolumes sets.Set[string], expectedVolumes []string) []string {
    	unmountedVolumes := []string{}
    	for _, expectedVolume := range expectedVolumes {
    		if !mountedVolumes.Has(expectedVolume) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 21.5K bytes
    - Viewed (0)
  4. pkg/controller/volume/persistentvolume/recycle_test.go

    			name:            "6-1 - successful recycle",
    			initialVolumes:  newVolumeArray("volume6-1", "1Gi", "uid6-1", "claim6-1", v1.VolumeBound, v1.PersistentVolumeReclaimRecycle, classEmpty, volume.AnnBoundByController),
    			expectedVolumes: newVolumeArray("volume6-1", "1Gi", "", "", v1.VolumeAvailable, v1.PersistentVolumeReclaimRecycle, classEmpty),
    			initialClaims:   noclaims,
    			expectedClaims:  noclaims,
    			expectedEvents:  noevents,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 14 00:37:30 UTC 2023
    - 14.2K bytes
    - Viewed (0)
  5. pkg/controller/volume/persistentvolume/provision_test.go

    	tests := []controllerTest{
    		{
    			// Provision a volume (with a default class)
    			name:            "11-1 - successful provision with storage class 1",
    			initialVolumes:  novolumes,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 35.3K bytes
    - Viewed (0)
  6. pkg/controller/volume/persistentvolume/pv_controller_test.go

    			name:            "5-2 - complete bind",
    			initialVolumes:  newVolumeArray("volume5-2", "1Gi", "", "", v1.VolumeAvailable, v1.PersistentVolumeReclaimRetain, classEmpty),
    			expectedVolumes: newVolumeArray("volume5-2", "1Gi", "uid5-2", "claim5-2", v1.VolumeBound, v1.PersistentVolumeReclaimRetain, classEmpty, volume.AnnBoundByController),
    			initialClaims:   noclaims, /* added in testAddClaim5_2 */
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 43.4K bytes
    - Viewed (0)
  7. pkg/kubelet/volumemanager/reconciler/reconstruct_test.go

    			// Assert
    			// Convert to []UniqueVolumeName
    			expectedVolumes := make([]v1.UniqueVolumeName, len(tc.expectedVolumesNeedDevicePath))
    			for i := range tc.expectedVolumesNeedDevicePath {
    				expectedVolumes[i] = v1.UniqueVolumeName(tc.expectedVolumesNeedDevicePath[i])
    			}
    			if !reflect.DeepEqual(expectedVolumes, rcInstance.volumesNeedUpdateFromNodeStatus) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 14.8K bytes
    - Viewed (0)
  8. pkg/controller/volume/persistentvolume/testing/testing.go

    			return expected.Error
    		}
    	}
    	return nil
    }
    
    // CheckVolumes compares all expectedVolumes with set of volumes at the end of
    // the test and reports differences.
    func (r *VolumeReactor) CheckVolumes(expectedVolumes []*v1.PersistentVolume) error {
    	r.lock.Lock()
    	defer r.lock.Unlock()
    
    	expectedMap := make(map[string]*v1.PersistentVolume)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 12 15:46:12 UTC 2023
    - 20.1K bytes
    - Viewed (0)
  9. plugin/pkg/admission/serviceaccount/admission_test.go

    		if len(pod.Spec.Containers[0].VolumeMounts[i].Name) > 0 {
    			pod.Spec.Containers[0].VolumeMounts[i].Name = "cleared"
    		}
    	}
    
    	if !reflect.DeepEqual(expectedVolumes, pod.Spec.Volumes) {
    		t.Errorf("unexpected volumes: %s", cmp.Diff(expectedVolumes, pod.Spec.Volumes))
    	}
    	if !reflect.DeepEqual(expectedVolumeMounts, pod.Spec.Containers[0].VolumeMounts) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 12 17:49:30 UTC 2024
    - 36.9K bytes
    - Viewed (0)
  10. pkg/controller/volume/persistentvolume/framework_test.go

    	// Name of the test, for logging
    	name string
    	// Initial content of controller volume cache.
    	initialVolumes []*v1.PersistentVolume
    	// Expected content of controller volume cache at the end of the test.
    	expectedVolumes []*v1.PersistentVolume
    	// Initial content of controller claim cache.
    	initialClaims []*v1.PersistentVolumeClaim
    	// Expected content of controller claim cache at the end of the test.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 01 09:54:00 UTC 2023
    - 38.3K bytes
    - Viewed (0)
Back to top