Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 27 for fExtenders (0.23 sec)

  1. pkg/scheduler/scheduler.go

    	fExtenders = append(fExtenders, ignorableExtenders...)
    
    	// If there are any extended resources found from the Extenders, append them to the pluginConfig for each profile.
    	// This should only have an effect on ComponentConfig, where it is possible to configure Extenders and
    	// plugin args (and in which case the extender ignored resources take precedence).
    	if len(ignoredExtendedResources) == 0 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:20:55 UTC 2024
    - 20.8K bytes
    - Viewed (0)
  2. pkg/scheduler/apis/config/validation/validation_test.go

    	extenderDuplicateManagedResource.Extenders[0].ManagedResources = []config.ExtenderManagedResource{
    		{Name: "example.com/foo", IgnoredByScheduler: false},
    		{Name: "example.com/foo", IgnoredByScheduler: false},
    	}
    
    	extenderDuplicateBind := validConfig.DeepCopy()
    	extenderDuplicateBind.Extenders[0].BindVerb = "foo"
    	extenderDuplicateBind.Extenders = append(extenderDuplicateBind.Extenders, config.Extender{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 06:27:01 UTC 2024
    - 12.2K bytes
    - Viewed (0)
  3. pkg/scheduler/scheduler_test.go

    			}
    
    			// Extenders
    			if len(tc.wantExtenders) != 0 {
    				// Scheduler.Extenders
    				extenders := make([]string, 0, len(s.Extenders))
    				for _, e := range s.Extenders {
    					extenders = append(extenders, e.Name())
    				}
    				if diff := cmp.Diff(tc.wantExtenders, extenders); diff != "" {
    					t.Errorf("unexpected extenders (-want, +got):\n%s", diff)
    				}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 42K bytes
    - Viewed (0)
  4. pkg/scheduler/extender_test.go

    		t.Run(test.name, func(t *testing.T) {
    			client := clientsetfake.NewSimpleClientset()
    			informerFactory := informers.NewSharedInformerFactory(client, 0)
    
    			var extenders []framework.Extender
    			for ii := range test.extenders {
    				extenders = append(extenders, &test.extenders[ii])
    			}
    			logger, ctx := ktesting.NewTestContext(t)
    			ctx, cancel := context.WithCancel(ctx)
    			defer cancel()
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 19:07:19 UTC 2024
    - 16.7K bytes
    - Viewed (0)
  5. pkg/scheduler/apis/config/validation/validation.go

    			}
    		}
    	}
    	return errs
    }
    
    // validateExtenders validates the configured extenders for the Scheduler
    func validateExtenders(fldPath *field.Path, extenders []config.Extender) []error {
    	var errs []error
    	binders := 0
    	extenderManagedResources := sets.New[string]()
    	for i, extender := range extenders {
    		path := fldPath.Index(i)
    		if len(extender.PrioritizeVerb) > 0 && extender.Weight <= 0 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 06:27:01 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  6. pkg/scheduler/schedule_one.go

    			}
    		}
    	}
    
    	if len(extenders) != 0 && nodes != nil {
    		// allNodeExtendersScores has all extenders scores for all nodes.
    		// It is keyed with node name.
    		allNodeExtendersScores := make(map[string]*framework.NodePluginScores, len(nodes))
    		var mu sync.Mutex
    		var wg sync.WaitGroup
    		for i := range extenders {
    			if !extenders[i].IsInterested(pod) {
    				continue
    			}
    			wg.Add(1)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 06 13:28:08 UTC 2024
    - 43.4K bytes
    - Viewed (0)
  7. pkg/scheduler/framework/runtime/framework.go

    		{&plugins.Permit, &f.permitPlugins},
    		{&plugins.PreEnqueue, &f.preEnqueuePlugins},
    		{&plugins.QueueSort, &f.queueSortPlugins},
    	}
    }
    
    // Extenders returns the registered extenders.
    func (f *frameworkImpl) Extenders() []framework.Extender {
    	return f.extenders
    }
    
    type frameworkOptions struct {
    	componentConfigVersion string
    	clientSet              clientset.Interface
    	kubeConfig             *restclient.Config
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 60.9K bytes
    - Viewed (0)
  8. pkg/scheduler/schedule_one_test.go

    				t.Fatal(err)
    			}
    
    			var extenders []framework.Extender
    			for ii := range test.extenders {
    				extenders = append(extenders, &test.extenders[ii])
    			}
    			sched := &Scheduler{
    				Cache:                    cache,
    				nodeInfoSnapshot:         snapshot,
    				percentageOfNodesToScore: schedulerapi.DefaultPercentageOfNodesToScore,
    				Extenders:                extenders,
    			}
    			sched.applyDefaultHandlers()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:20:55 UTC 2024
    - 128.1K bytes
    - Viewed (0)
  9. pkg/scheduler/framework/preemption/preemption.go

    		nodeStatuses[node] = nodeStatus
    	}
    	return candidates, nodeStatuses, err
    }
    
    // callExtenders calls given <extenders> to select the list of feasible candidates.
    // We will only check <candidates> with extenders that support preemption.
    // Extenders which do not support preemption may later prevent preemptor from being scheduled on the nominated
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 25.1K bytes
    - Viewed (0)
  10. pkg/scheduler/apis/config/types.go

    	// with the "default-scheduler" profile, if present here.
    	Profiles []KubeSchedulerProfile
    
    	// Extenders are the list of scheduler extenders, each holding the values of how to communicate
    	// with the extender. These extenders are shared by all scheduler profiles.
    	Extenders []Extender
    
    	// DelayCacheUntilActive specifies when to start caching. If this is true and leader election is enabled,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jan 19 18:47:23 UTC 2024
    - 14.8K bytes
    - Viewed (0)
Back to top