Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 85 for queueset (0.32 sec)

  1. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_controller.go

    	// qsCompleter holds the QueueSetCompleter derived from `config`
    	// and `queues`.
    	qsCompleter fq.QueueSetCompleter
    
    	// The QueueSet for this priority level.
    	// Never nil.
    	queues fq.QueueSet
    
    	// quiescing==true indicates that this priority level should be
    	// removed when its queues have all drained.
    	quiescing bool
    
    	// number of goroutines between Controller::Match and calling the
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 48.8K bytes
    - Viewed (0)
  2. pkg/controller/serviceaccount/tokens_controller.go

    	}
    }
    
    func parseSecretQueueKey(key interface{}) (secretQueueKey, error) {
    	queueKey, ok := key.(secretQueueKey)
    	if !ok || len(queueKey.namespace) == 0 || len(queueKey.name) == 0 || len(queueKey.uid) == 0 || len(queueKey.saName) == 0 {
    		return secretQueueKey{}, fmt.Errorf("invalid secret key: %#v", key)
    	}
    	return queueKey, nil
    }
    
    // produce the same key format as cache.MetaNamespaceKeyFunc
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 20.5K bytes
    - Viewed (0)
  3. pkg/scheduler/apis/config/validation/validation.go

    	if profiles[0].Plugins != nil {
    		canon = profiles[0].Plugins.QueueSort
    		if len(profiles[0].Plugins.QueueSort.Enabled) != 0 {
    			queueSortName = profiles[0].Plugins.QueueSort.Enabled[0].Name
    		}
    		length := len(profiles[0].Plugins.QueueSort.Enabled)
    		if length > 1 {
    			errs = append(errs, field.Invalid(path.Index(0).Child("plugins", "queueSort", "Enabled"), length, "only one queue sort plugin can be enabled"))
    		}
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 06:27:01 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  4. pkg/scheduler/apis/config/validation/validation_test.go

    		SchedulerName: "me",
    		Plugins: &config.Plugins{
    			QueueSort: config.PluginSet{
    				Enabled: []config.Plugin{{Name: "PrioritySort"}},
    			},
    		},
    		PluginConfig: []config.PluginConfig{{
    			Name: "PrioritySort",
    		}},
    	}, {
    		SchedulerName: "other",
    		Plugins: &config.Plugins{
    			QueueSort: config.PluginSet{
    				Enabled: []config.Plugin{{Name: "CustomSort"}},
    			},
    		},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 06:27:01 UTC 2024
    - 12.2K bytes
    - Viewed (0)
  5. pkg/scheduler/schedule_one_test.go

    				return true, gotBinding, item.injectBindError
    			})
    			registerPluginFuncs := append(item.registerPluginFuncs,
    				tf.RegisterQueueSortPlugin(queuesort.Name, queuesort.New),
    				tf.RegisterBindPlugin(defaultbinder.Name, defaultbinder.New),
    			)
    			ctx, cancel := context.WithCancel(context.Background())
    			defer cancel()
    			fwk, err := tf.NewFramework(ctx,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:20:55 UTC 2024
    - 128.1K bytes
    - Viewed (0)
  6. pkg/scheduler/scheduler_test.go

    						Plugins: &schedulerapi.Plugins{
    							QueueSort: schedulerapi.PluginSet{Enabled: []schedulerapi.Plugin{{Name: "PrioritySort"}}},
    							Bind:      schedulerapi.PluginSet{Enabled: []schedulerapi.Plugin{{Name: "DefaultBinder"}}},
    						},
    					},
    					schedulerapi.KubeSchedulerProfile{
    						SchedulerName: "bar",
    						Plugins: &schedulerapi.Plugins{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 42K bytes
    - Viewed (0)
  7. pkg/controlplane/controller/legacytokentracking/controller.go

    	return true
    }
    
    func (c *Controller) syncConfigMap() error {
    	obj, exists, err := c.configMapCache.GetByKey(queueKey)
    	if err != nil {
    		return err
    	}
    
    	now := c.clock.Now()
    	if !exists {
    		r := c.creationRatelimiter.ReserveN(now, 1)
    		if delay := r.DelayFrom(now); delay > 0 {
    			c.queue.AddAfter(queueKey, delay)
    			r.CancelAt(now)
    			return nil
    		}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 6K bytes
    - Viewed (0)
  8. okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt

       * need. Both fields are guarded by [lock].
       */
      private var executeCallCount = 0
      private var runCallCount = 0
    
      /** Queues with tasks that are currently executing their [TaskQueue.activeTask]. */
      private val busyQueues = mutableListOf<TaskQueue>()
    
      /** Queues not in [busyQueues] that have non-empty [TaskQueue.futureTasks]. */
      private val readyQueues = mutableListOf<TaskQueue>()
    
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Mon Apr 29 00:33:04 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  9. 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)
  10. 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)
Back to top