Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 25 for QueueSort (0.22 sec)

  1. 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)
  2. pkg/scheduler/framework/preemption/preemption_test.go

    	}
    
    	for _, tt := range tests {
    		t.Run(tt.name, func(t *testing.T) {
    			logger, _ := ktesting.NewTestContext(t)
    			registeredPlugins := append([]tf.RegisterPluginFunc{
    				tf.RegisterQueueSortPlugin(queuesort.Name, queuesort.New)},
    				tf.RegisterBindPlugin(defaultbinder.Name, defaultbinder.New),
    			)
    			var objs []runtime.Object
    			for _, p := range append(tt.testPods, tt.initPods...) {
    				objs = append(objs, p)
    			}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 18.7K bytes
    - Viewed (0)
  3. pkg/scheduler/apis/config/types.go

    	// should be disabled.
    	// When no enabled or disabled plugin is specified for an extension point,
    	// default plugins for that extension point will be used if there is any.
    	// If a QueueSort plugin is specified, the same QueueSort Plugin and
    	// PluginConfig must be specified for all profiles.
    	Plugins *Plugins
    
    	// PluginConfig is an optional set of custom plugin arguments for each plugin.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jan 19 18:47:23 UTC 2024
    - 14.8K bytes
    - Viewed (0)
  4. 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)
  5. pkg/scheduler/framework/runtime/framework_test.go

    		r[queueSortPlugin] = newQueueSortPlugin
    	}
    	if _, ok := r[bindPlugin]; !ok {
    		r[bindPlugin] = newBindPlugin
    	}
    
    	if len(profile.Plugins.QueueSort.Enabled) == 0 {
    		profile.Plugins.QueueSort.Enabled = append(profile.Plugins.QueueSort.Enabled, config.Plugin{Name: queueSortPlugin})
    	}
    	if len(profile.Plugins.Bind.Enabled) == 0 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 103K bytes
    - Viewed (0)
  6. 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)
  7. pkg/scheduler/framework/plugins/defaultpreemption/default_preemption_test.go

    				podInformer.GetStore().Add(tt.pods[i])
    			}
    			// Register NodeResourceFit as the Filter & PreFilter plugin.
    			registeredPlugins := []tf.RegisterPluginFunc{
    				tf.RegisterQueueSortPlugin(queuesort.Name, queuesort.New),
    				tf.RegisterPluginAsExtensions(noderesources.Name, nodeResourcesFitFunc, "Filter", "PreFilter"),
    				tf.RegisterPluginAsExtensions("test-plugin", newTestPlugin, "PreFilter"),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 82.8K bytes
    - Viewed (0)
  8. 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)
  9. cmd/kube-scheduler/app/options/options_test.go

    				Profiles: []kubeschedulerconfig.KubeSchedulerProfile{
    					{
    						SchedulerName: "high-throughput-profile",
    						Plugins: &kubeschedulerconfig.Plugins{
    							QueueSort:  defaults.PluginsV1.QueueSort,
    							PreFilter:  defaults.PluginsV1.PreFilter,
    							Filter:     defaults.PluginsV1.Filter,
    							PostFilter: defaults.PluginsV1.PostFilter,
    							PreScore: kubeschedulerconfig.PluginSet{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 13 07:42:19 UTC 2023
    - 30.3K bytes
    - Viewed (0)
  10. pkg/scheduler/apis/config/v1/zz_generated.conversion.go

    	if err := Convert_v1_PluginSet_To_config_PluginSet(&in.PreEnqueue, &out.PreEnqueue, s); err != nil {
    		return err
    	}
    	if err := Convert_v1_PluginSet_To_config_PluginSet(&in.QueueSort, &out.QueueSort, s); err != nil {
    		return err
    	}
    	if err := Convert_v1_PluginSet_To_config_PluginSet(&in.PreFilter, &out.PreFilter, s); err != nil {
    		return err
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jan 19 18:47:23 UTC 2024
    - 46.9K bytes
    - Viewed (0)
Back to top