Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for getFakeCSINodeLister (0.21 sec)

  1. pkg/scheduler/framework/plugins/nodevolumelimits/non_csi_test.go

    			_, ctx := ktesting.NewTestContext(t)
    			fts := feature.Features{}
    			node, csiNode := getNodeWithPodAndVolumeLimits("node", test.existingPods, test.maxVols, filterName)
    			p := newNonCSILimits(ctx, filterName, getFakeCSINodeLister(csiNode), getFakeCSIStorageClassLister(filterName, driverName), getFakePVLister(filterName), append(getFakePVCLister(filterName), test.extraClaims...), fts).(framework.FilterPlugin)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Dec 30 23:00:56 UTC 2023
    - 36.8K bytes
    - Viewed (0)
  2. pkg/volume/testing/volume_host.go

    		ObjectMeta: metav1.ObjectMeta{Name: f.nodeName},
    		Spec: storagev1.CSINodeSpec{
    			Drivers: []storagev1.CSINodeDriver{},
    		},
    	}
    	enableMigrationOnNode(csiNode, csilibplugins.GCEPDInTreePluginName)
    	return getFakeCSINodeLister(csiNode)
    }
    
    func enableMigrationOnNode(csiNode *storagev1.CSINode, pluginName string) {
    	nodeInfoAnnotations := csiNode.GetAnnotations()
    	if nodeInfoAnnotations == nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 11 09:02:45 UTC 2024
    - 16.5K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/plugins/nodevolumelimits/csi_test.go

    			if csiNode != nil {
    				enableMigrationOnNode(csiNode, csilibplugins.AWSEBSInTreePluginName)
    			}
    			csiTranslator := csitrans.New()
    			p := &CSILimits{
    				csiNodeLister:        getFakeCSINodeLister(csiNode),
    				pvLister:             getFakeCSIPVLister(test.filterName, test.driverNames...),
    				pvcLister:            append(getFakeCSIPVCLister(test.filterName, scName, test.driverNames...), test.extraClaims...),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 18:07:11 UTC 2024
    - 28.6K bytes
    - Viewed (0)
Back to top