Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for FindPodVolumes (0.29 sec)

  1. pkg/scheduler/framework/plugins/volumebinding/fake_binder.go

    func (b *FakeVolumeBinder) GetEligibleNodes(_ klog.Logger, boundClaims []*v1.PersistentVolumeClaim) (eligibleNodes sets.Set[string]) {
    	return nil
    }
    
    // FindPodVolumes implements SchedulerVolumeBinder.FindPodVolumes.
    func (b *FakeVolumeBinder) FindPodVolumes(_ klog.Logger, pod *v1.Pod, _ *PodVolumeClaims, node *v1.Node) (podVolumes *PodVolumes, reasons ConflictReasons, err error) {
    	return nil, b.config.FindReasons, b.config.FindErr
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Sep 21 03:28:12 UTC 2023
    - 2.7K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/plugins/volumebinding/binder_test.go

    				equal = false
    				break
    			}
    		}
    	}
    	if !equal {
    		t.Errorf("expected failure reasons %s, got %s", reasonNames(expected), reasonNames(actual))
    	}
    }
    
    // findPodVolumes gets and finds volumes for given pod and node
    func findPodVolumes(logger klog.Logger, binder SchedulerVolumeBinder, pod *v1.Pod, node *v1.Node) (*PodVolumes, ConflictReasons, error) {
    	podVolumeClaims, err := binder.GetPodVolumeClaims(logger, pod)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 09:46:58 UTC 2024
    - 82.8K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/plugins/volumebinding/binder.go

    	b.csiStorageCapacityLister = capacityCheck.CSIStorageCapacityInformer.Lister()
    
    	return b
    }
    
    // FindPodVolumes finds the matching PVs for PVCs and nodes to provision PVs
    // for the given pod and node. If the node does not fit, conflict reasons are
    // returned.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 09 14:55:34 UTC 2024
    - 42.6K bytes
    - Viewed (0)
  4. pkg/scheduler/framework/plugins/volumebinding/volume_binding.go

    	logger := klog.FromContext(ctx)
    	node := nodeInfo.Node()
    
    	state, err := getStateData(cs)
    	if err != nil {
    		return framework.AsStatus(err)
    	}
    
    	podVolumes, reasons, err := pl.Binder.FindPodVolumes(logger, pod, state.podVolumeClaims, node)
    
    	if err != nil {
    		return framework.AsStatus(err)
    	}
    
    	if len(reasons) > 0 {
    		status := framework.NewStatus(framework.UnschedulableAndUnresolvable)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 16 14:13:06 UTC 2024
    - 16.4K bytes
    - Viewed (0)
Back to top