Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 15 for volumetesting (3.03 sec)

  1. pkg/kubelet/volumemanager/reconciler/reconciler_test.go

    	// Act
    	runReconciler(reconciler)
    
    	// Assert
    	assert.NoError(t, volumetesting.VerifyZeroAttachCalls(fakePlugin))
    	assert.NoError(t, volumetesting.VerifyZeroWaitForAttachCallCount(fakePlugin))
    	assert.NoError(t, volumetesting.VerifyZeroMountDeviceCallCount(fakePlugin))
    	assert.NoError(t, volumetesting.VerifyZeroSetUpCallCount(fakePlugin))
    	assert.NoError(t, volumetesting.VerifyZeroTearDownCallCount(fakePlugin))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Apr 09 07:34:33 UTC 2024
    - 75.4K bytes
    - Viewed (0)
  2. pkg/volume/util/operationexecutor/node_expander_test.go

    		},
    		{
    			name:                     "pv.spec.cap > pvc.status.cap, resizeStatus=node_expansion_pending, reize_op=failing",
    			pvc:                      getTestPVC(volumetesting.AlwaysFailNodeExpansion, "2G", "1G", "2G", &nodeResizePending),
    			pv:                       getTestPV(volumetesting.AlwaysFailNodeExpansion, "2G"),
    			expectError:              true,
    			expectedResizeStatus:     nodeResizeFailed,
    			expectResizeCall:         true,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  3. pkg/kubelet/volumemanager/cache/desired_state_of_world_test.go

    				Plugin: volumetesting.FakeVolumePlugin{
    					PluginName: "device-mountable",
    				},
    			},
    		},
    		&volumetesting.FakeAttachableVolumePlugin{
    			FakeDeviceMountableVolumePlugin: volumetesting.FakeDeviceMountableVolumePlugin{
    				FakeBasicVolumePlugin: volumetesting.FakeBasicVolumePlugin{
    					Plugin: volumetesting.FakeVolumePlugin{
    						PluginName: "attachable",
    					},
    				},
    			},
    		},
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 34K bytes
    - Viewed (0)
  4. pkg/controller/volume/attachdetach/cache/desired_state_of_world_test.go

    	controllervolumetesting "k8s.io/kubernetes/pkg/controller/volume/attachdetach/testing"
    	volumetesting "k8s.io/kubernetes/pkg/volume/testing"
    	"k8s.io/kubernetes/pkg/volume/util/types"
    )
    
    // Calls AddNode() once.
    // Verifies node exists, and zero volumes to attach.
    func Test_AddNode_Positive_NewNode(t *testing.T) {
    	// Arrange
    	volumePluginMgr, _ := volumetesting.GetTestVolumePluginMgr(t)
    	dsw := NewDesiredStateOfWorld(volumePluginMgr)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 10:42:15 UTC 2024
    - 35.9K bytes
    - Viewed (0)
  5. pkg/kubelet/volumemanager/reconciler/reconstruct_test.go

    			volumePath:  filepath.Join("pod1uid", "volumes", "fake-plugin", volumetesting.FailOnSetupVolumeName),
    			expectMount: false,
    			volumeMode:  v1.PersistentVolumeFilesystem,
    		},
    		{
    			name:            "reconstructed volume device map fails",
    			volumePath:      filepath.Join("pod1uid", "volumeDevices", "fake-plugin", volumetesting.FailMountDeviceVolumeName),
    			volumeMode:      v1.PersistentVolumeBlock,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 14.8K bytes
    - Viewed (0)
  6. pkg/controller/volume/attachdetach/cache/actual_state_of_world_test.go

    	volumetesting "k8s.io/kubernetes/pkg/volume/testing"
    	volumeutil "k8s.io/kubernetes/pkg/volume/util"
    )
    
    // Calls AddVolumeNode() once with attached set to true.
    // Verifies a single volume/node entry exists.
    func Test_AddVolumeNode_Positive_NewVolumeNewNode(t *testing.T) {
    	// Arrange
    	volumePluginMgr, _ := volumetesting.GetTestVolumePluginMgr(t)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 11 07:35:17 UTC 2024
    - 66.1K bytes
    - Viewed (0)
  7. pkg/controller/volume/attachdetach/reconciler/reconciler_test.go

    func Test_Run_Positive_DoNothing(t *testing.T) {
    	// Arrange
    	volumePluginMgr, fakePlugin := volumetesting.GetTestVolumePluginMgr(t)
    	dsw := cache.NewDesiredStateOfWorld(volumePluginMgr)
    	asw := cache.NewActualStateOfWorld(volumePluginMgr)
    
    	fakeKubeClient := controllervolumetesting.CreateTestClient()
    	fakeRecorder := &record.FakeRecorder{}
    	fakeHandler := volumetesting.NewBlockVolumePathHandler()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 07:00:14 UTC 2024
    - 72.8K bytes
    - Viewed (0)
  8. pkg/volume/util/operationexecutor/operation_generator_test.go

    		},
    		{
    			name:                 "pv.spec.cap > pvc.status.cap, resizeStatus=node_expansion_pending, reize_op=failing",
    			pvc:                  getTestPVC(volumetesting.AlwaysFailNodeExpansion, "2G", "1G", "2G", &nodeResizePending),
    			pv:                   getTestPV(volumetesting.AlwaysFailNodeExpansion, "2G"),
    			expectError:          true,
    			expectedResizeStatus: v1.PersistentVolumeClaimNodeResizeFailed,
    			resizeCallCount:      1,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  9. pkg/controller/volume/attachdetach/metrics/metrics_test.go

    	controllervolumetesting "k8s.io/kubernetes/pkg/controller/volume/attachdetach/testing"
    	"k8s.io/kubernetes/pkg/volume/csimigration"
    	volumetesting "k8s.io/kubernetes/pkg/volume/testing"
    	"k8s.io/kubernetes/pkg/volume/util/types"
    )
    
    func TestVolumesInUseMetricCollection(t *testing.T) {
    	fakeVolumePluginMgr, _ := volumetesting.GetTestVolumePluginMgr(t)
    	fakeClient := &fake.Clientset{}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 10:42:15 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  10. pkg/kubelet/volumemanager/cache/actual_state_of_world_test.go

    	"github.com/stretchr/testify/require"
    	v1 "k8s.io/api/core/v1"
    	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    	"k8s.io/klog/v2/ktesting"
    	"k8s.io/kubernetes/pkg/features"
    	"k8s.io/kubernetes/pkg/volume"
    	volumetesting "k8s.io/kubernetes/pkg/volume/testing"
    	"k8s.io/kubernetes/pkg/volume/util"
    	"k8s.io/kubernetes/pkg/volume/util/operationexecutor"
    	volumetypes "k8s.io/kubernetes/pkg/volume/util/types"
    )
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 46.3K bytes
    - Viewed (0)
Back to top