Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for getStateData (0.25 sec)

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

    	})
    	return result, nil
    }
    
    // PreFilterExtensions returns prefilter extensions, pod add and remove.
    func (pl *VolumeBinding) PreFilterExtensions() framework.PreFilterExtensions {
    	return nil
    }
    
    func getStateData(cs *framework.CycleState) (*stateData, error) {
    	state, err := cs.Read(stateKey)
    	if err != nil {
    		return nil, err
    	}
    	s, ok := state.(*stateData)
    	if !ok {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 16 14:13:06 UTC 2024
    - 16.4K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/plugins/volumezone/volume_zone.go

    	// Thus we make a fast path for it, to avoid unnecessary computations in this case.
    	if len(pod.Spec.Volumes) == 0 {
    		return nil
    	}
    	var podPVTopologies []pvTopology
    	state, err := getStateData(cs)
    	if err != nil {
    		// Fallback to calculate pv list here
    		var status *framework.Status
    		podPVTopologies, status = pl.getPVbyPod(ctx, pod)
    		if !status.IsSuccess() {
    			return status
    		}
    	} else {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 16 14:13:06 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/plugins/dynamicresources/dynamicresources.go

    	}
    }
    
    // PreFilterExtensions returns prefilter extensions, pod add and remove.
    func (pl *dynamicResources) PreFilterExtensions() framework.PreFilterExtensions {
    	return nil
    }
    
    func getStateData(cs *framework.CycleState) (*stateData, error) {
    	state, err := cs.Read(stateKey)
    	if err != nil {
    		return nil, err
    	}
    	s, ok := state.(*stateData)
    	if !ok {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 30 15:22:37 UTC 2024
    - 75.9K bytes
    - Viewed (0)
  4. pkg/scheduler/framework/plugins/volumebinding/volume_binding_test.go

    			if !gotPreFilterStatus.IsSuccess() {
    				// scheduler framework will skip Filter if PreFilter fails
    				return
    			}
    
    			t.Logf("Verify: check state after prefilter phase")
    			got, err := getStateData(state)
    			if err != nil {
    				t.Fatal(err)
    			}
    			stateCmpOpts := []cmp.Option{
    				cmp.AllowUnexported(stateData{}),
    				cmp.AllowUnexported(PodVolumeClaims{}),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 03:30:06 UTC 2023
    - 32K bytes
    - Viewed (0)
Back to top