Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 17 for PreFilterExtensions (0.33 sec)

  1. pkg/scheduler/framework/plugins/nodeports/node_ports.go

    	if len(s) == 0 {
    		return nil, framework.NewStatus(framework.Skip)
    	}
    	cycleState.Write(preFilterStateKey, preFilterState(s))
    	return nil, nil
    }
    
    // PreFilterExtensions do not exist for this plugin.
    func (pl *NodePorts) PreFilterExtensions() framework.PreFilterExtensions {
    	return nil
    }
    
    func getPreFilterState(cycleState *framework.CycleState) (preFilterState, error) {
    	c, err := cycleState.Read(preFilterStateKey)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 26 10:53:29 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  2. pkg/scheduler/testing/framework/fake_plugins.go

    	return pl.Result, pl.Status
    }
    
    // PreFilterExtensions no extensions implemented by this plugin.
    func (pl *FakePreFilterPlugin) PreFilterExtensions() framework.PreFilterExtensions {
    	return nil
    }
    
    // NewFakePreFilterPlugin initializes a fakePreFilterPlugin and returns it.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 19:07:19 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/plugins/volumezone/volume_zone.go

    					key:    key,
    					values: sets.Set[string](volumeVSet),
    				})
    			}
    		}
    	}
    	return podPVTopologies, nil
    }
    
    // PreFilterExtensions returns prefilter extensions, pod add and remove.
    func (pl *VolumeZone) PreFilterExtensions() framework.PreFilterExtensions {
    	return nil
    }
    
    // Filter invoked at the filter extension point.
    //
    // It evaluates if a pod can fit due to the volumes it requests, given
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 16 14:13:06 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  4. pkg/scheduler/framework/interface.go

    	// When it returns Skip status, returned PreFilterResult and other fields in status are just ignored,
    	// and coupled Filter plugin/PreFilterExtensions() will be skipped in this scheduling cycle.
    	PreFilter(ctx context.Context, state *CycleState, p *v1.Pod) (*PreFilterResult, *Status)
    	// PreFilterExtensions returns a PreFilterExtensions interface if the plugin implements one,
    	// or nil if it does not. A Pre-filter plugin can provide extensions to incrementally
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 35.4K bytes
    - Viewed (0)
  5. pkg/scheduler/framework/plugins/volumerestrictions/volume_restrictions.go

    		return framework.NewStatus(framework.Unschedulable, ErrReasonReadWriteOncePodConflict)
    	}
    	return nil
    }
    
    // PreFilterExtensions returns prefilter extensions, pod add and remove.
    func (pl *VolumeRestrictions) PreFilterExtensions() framework.PreFilterExtensions {
    	return pl
    }
    
    // Filter invoked at the filter extension point.
    // It evaluates if a pod can fit due to the volumes it requests, and those that
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Oct 20 17:40:39 UTC 2023
    - 12.5K bytes
    - Viewed (0)
  6. pkg/scheduler/framework/plugins/nodeaffinity/node_affinity.go

    	} else if len(nodeNames) > 0 {
    		return &framework.PreFilterResult{NodeNames: nodeNames}, nil
    	}
    	return nil, nil
    
    }
    
    // PreFilterExtensions not necessary for this plugin as state doesn't depend on pod additions or deletions.
    func (pl *NodeAffinity) PreFilterExtensions() framework.PreFilterExtensions {
    	return nil
    }
    
    // Filter checks if the Node matches the Pod .spec.affinity.nodeAffinity and
    // the plugin's added affinity.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Dec 18 12:00:10 UTC 2023
    - 12.6K bytes
    - Viewed (0)
  7. pkg/scheduler/framework/plugins/podtopologyspread/filtering.go

    		return nil, framework.NewStatus(framework.Skip)
    	}
    
    	cycleState.Write(preFilterStateKey, s)
    	return nil, nil
    }
    
    // PreFilterExtensions returns prefilter extensions, pod add and remove.
    func (pl *PodTopologySpread) PreFilterExtensions() framework.PreFilterExtensions {
    	return pl
    }
    
    // AddPod from pre-computed data in cycleState.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 28 10:42:29 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  8. pkg/scheduler/framework/plugins/interpodaffinity/filtering.go

    		return nil, framework.NewStatus(framework.Skip)
    	}
    
    	cycleState.Write(preFilterStateKey, s)
    	return nil, nil
    }
    
    // PreFilterExtensions returns prefilter extensions, pod add and remove.
    func (pl *InterPodAffinity) PreFilterExtensions() framework.PreFilterExtensions {
    	return pl
    }
    
    // AddPod from pre-computed data in cycleState.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 01 10:24:54 UTC 2023
    - 14.6K bytes
    - Viewed (0)
  9. pkg/scheduler/framework/plugins/volumebinding/volume_binding.go

    			unboundVolumesDelayBinding: podVolumeClaims.unboundVolumesDelayBinding,
    		},
    	})
    	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 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 16 14:13:06 UTC 2024
    - 16.4K bytes
    - Viewed (0)
  10. pkg/scheduler/framework/plugins/nodevolumelimits/csi.go

    			return nil, nil
    		}
    	}
    
    	return nil, framework.NewStatus(framework.Skip)
    }
    
    // PreFilterExtensions returns prefilter extensions, pod add and remove.
    func (pl *CSILimits) PreFilterExtensions() framework.PreFilterExtensions {
    	return nil
    }
    
    // Filter invoked at the filter extension point.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 18:07:11 UTC 2024
    - 16.6K bytes
    - Viewed (0)
Back to top