Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for QueueSort (0.12 sec)

  1. pkg/scheduler/profile/profile_test.go

    					Plugins: &config.Plugins{
    						QueueSort: config.PluginSet{
    							Enabled: []config.Plugin{
    								{Name: "QueueSort"},
    							},
    						},
    						Bind: config.PluginSet{
    							Enabled: []config.Plugin{
    								{Name: "Bind1"},
    							},
    						},
    					},
    				},
    				{
    					SchedulerName: "profile-2",
    					Plugins: &config.Plugins{
    						QueueSort: config.PluginSet{
    							Enabled: []config.Plugin{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 20 09:49:54 UTC 2023
    - 6.6K bytes
    - Viewed (0)
  2. pkg/scheduler/profile/profile.go

    	}
    
    	queueSort := f.ListPlugins().QueueSort.Enabled[0].Name
    	var queueSortArgs runtime.Object
    	for _, plCfg := range cfg.PluginConfig {
    		if plCfg.Name == queueSort {
    			queueSortArgs = plCfg.Args
    			break
    		}
    	}
    	if len(v.queueSort) == 0 {
    		v.queueSort = queueSort
    		v.queueSortArgs = queueSortArgs
    		return nil
    	}
    	if v.queueSort != queueSort {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jan 06 01:11:19 UTC 2024
    - 4K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/plugins/registry.go

    		nodevolumelimits.CinderName:          runtime.FactoryAdapter(fts, nodevolumelimits.NewCinder),
    		interpodaffinity.Name:                interpodaffinity.New,
    		queuesort.Name:                       queuesort.New,
    		defaultbinder.Name:                   defaultbinder.New,
    		defaultpreemption.Name:               runtime.FactoryAdapter(fts, defaultpreemption.New),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 5K bytes
    - Viewed (0)
  4. pkg/scheduler/testing/framework/framework_helpers.go

    // RegisterQueueSortPlugin returns a function to register a QueueSort Plugin to a given registry.
    func RegisterQueueSortPlugin(pluginName string, pluginNewFunc runtime.PluginFactory) RegisterPluginFunc {
    	return RegisterPluginAsExtensions(pluginName, pluginNewFunc, "QueueSort")
    }
    
    // RegisterPreFilterPlugin returns a function to register a PreFilter Plugin to a given registry.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 03:30:06 UTC 2023
    - 6.3K bytes
    - Viewed (0)
  5. pkg/scheduler/apis/config/v1/default_plugins.go

    	defaultPlugins.PreEnqueue = mergePluginSet(logger, defaultPlugins.PreEnqueue, customPlugins.PreEnqueue)
    	defaultPlugins.QueueSort = mergePluginSet(logger, defaultPlugins.QueueSort, customPlugins.QueueSort)
    	defaultPlugins.PreFilter = mergePluginSet(logger, defaultPlugins.PreFilter, customPlugins.PreFilter)
    	defaultPlugins.Filter = mergePluginSet(logger, defaultPlugins.Filter, customPlugins.Filter)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 06:27:01 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  6. pkg/scheduler/framework/plugins/queuesort/priority_sort.go

    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
    See the License for the specific language governing permissions and
    limitations under the License.
    */
    
    package queuesort
    
    import (
    	"context"
    	"k8s.io/apimachinery/pkg/runtime"
    	corev1helpers "k8s.io/component-helpers/scheduling/corev1"
    	"k8s.io/kubernetes/pkg/scheduler/framework"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 20 09:49:54 UTC 2023
    - 1.7K bytes
    - Viewed (0)
  7. pkg/scheduler/framework/plugins/queuesort/priority_sort_test.go

    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
    See the License for the specific language governing permissions and
    limitations under the License.
    */
    
    package queuesort
    
    import (
    	"testing"
    	"time"
    
    	v1 "k8s.io/api/core/v1"
    	"k8s.io/kubernetes/pkg/scheduler/framework"
    	st "k8s.io/kubernetes/pkg/scheduler/testing"
    )
    
    func TestLess(t *testing.T) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Oct 12 14:11:04 UTC 2022
    - 2.8K bytes
    - Viewed (0)
  8. pkg/scheduler/apis/config/testing/defaults/defaults.go

    // ExpandedPluginsV1 default set of v1 plugins after MultiPoint expansion
    var ExpandedPluginsV1 = &config.Plugins{
    	PreEnqueue: config.PluginSet{
    		Enabled: []config.Plugin{
    			{Name: names.SchedulingGates},
    		},
    	},
    	QueueSort: config.PluginSet{
    		Enabled: []config.Plugin{
    			{Name: names.PrioritySort},
    		},
    	},
    	PreFilter: config.PluginSet{
    		Enabled: []config.Plugin{
    			{Name: names.NodeAffinity},
    			{Name: names.NodePorts},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 06:27:01 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  9. pkg/scheduler/apis/config/v1/defaults.go

    		p.MultiPoint,
    		p.PreFilter,
    		p.Filter,
    		p.PostFilter,
    		p.Reserve,
    		p.PreScore,
    		p.Score,
    		p.PreBind,
    		p.Bind,
    		p.PostBind,
    		p.Permit,
    		p.PreEnqueue,
    		p.QueueSort,
    	}
    	n := sets.New[string]()
    	for _, e := range extensions {
    		for _, pg := range e.Enabled {
    			n.Insert(pg.Name)
    		}
    	}
    	return sets.List(n)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 13 07:42:19 UTC 2023
    - 7.2K bytes
    - Viewed (0)
Back to top