- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 16 for PreFilterExtensions (0.42 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
pkg/scheduler/framework/plugins/nodevolumelimits/non_csi.go
return nil, nil } } return nil, framework.NewStatus(framework.Skip) } // PreFilterExtensions returns prefilter extensions, pod add and remove. func (pl *nonCSILimits) PreFilterExtensions() framework.PreFilterExtensions { return nil } // Filter invoked at the filter extension point.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Dec 30 23:00:56 UTC 2023 - 19.6K bytes - Viewed (0)