Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 20 for queueset (0.17 sec)

  1. 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)
  2. 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)
  3. pkg/scheduler/internal/queue/scheduling_queue_test.go

    		expectedQ string
    	}{
    		{
    			name:      "Queue queues pod to activeQ",
    			podInfo:   &framework.QueuedPodInfo{PodInfo: mustNewPodInfo(p), PendingPlugins: sets.New("foo")},
    			hint:      queueHintReturnQueue,
    			expectedQ: activeQ,
    		},
    		{
    			name:      "Queue queues pod to backoffQ if Pod is backing off",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 146.9K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/cache/LocalCache.java

       */
      static final int DRAIN_THRESHOLD = 0x3F;
    
      /**
       * Maximum number of entries to be drained in a single cleanup run. This applies independently to
       * the cleanup queue and both reference queues.
       */
      // TODO(fry): empirically optimize this
      static final int DRAIN_MAX = 16;
    
      // Fields
    
      static final Logger logger = Logger.getLogger(LocalCache.class.getName());
    
      /**
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Sat May 18 03:24:34 UTC 2024
    - 143.6K bytes
    - Viewed (0)
  5. guava/src/com/google/common/cache/LocalCache.java

       */
      static final int DRAIN_THRESHOLD = 0x3F;
    
      /**
       * Maximum number of entries to be drained in a single cleanup run. This applies independently to
       * the cleanup queue and both reference queues.
       */
      // TODO(fry): empirically optimize this
      static final int DRAIN_MAX = 16;
    
      // Fields
    
      static final Logger logger = Logger.getLogger(LocalCache.class.getName());
    
      /**
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Sat May 18 03:24:34 UTC 2024
    - 149.2K bytes
    - Viewed (0)
  6. pkg/printers/internalversion/printers.go

    	}
    	name := obj.Name
    	ncs := interface{}("<none>")
    	queues := interface{}("<none>")
    	handSize := interface{}("<none>")
    	queueLengthLimit := interface{}("<none>")
    	if obj.Spec.Limited != nil {
    		ncs = obj.Spec.Limited.NominalConcurrencyShares
    		if qc := obj.Spec.Limited.LimitResponse.Queuing; qc != nil {
    			queues = qc.Queues
    			handSize = qc.HandSize
    			queueLengthLimit = qc.QueueLengthLimit
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 14:04:15 UTC 2024
    - 128.3K bytes
    - Viewed (0)
  7. staging/src/k8s.io/api/flowcontrol/v1beta1/generated.pb.go

    			if wireType != 0 {
    				return fmt.Errorf("proto: wrong wireType = %d for field Queues", wireType)
    			}
    			m.Queues = 0
    			for shift := uint(0); ; shift += 7 {
    				if shift >= 64 {
    					return ErrIntOverflowGenerated
    				}
    				if iNdEx >= l {
    					return io.ErrUnexpectedEOF
    				}
    				b := dAtA[iNdEx]
    				iNdEx++
    				m.Queues |= int32(b&0x7F) << shift
    				if b < 0x80 {
    					break
    				}
    			}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 06:06:37 UTC 2024
    - 142K bytes
    - Viewed (0)
  8. staging/src/k8s.io/api/flowcontrol/v1beta2/generated.pb.go

    			if wireType != 0 {
    				return fmt.Errorf("proto: wrong wireType = %d for field Queues", wireType)
    			}
    			m.Queues = 0
    			for shift := uint(0); ; shift += 7 {
    				if shift >= 64 {
    					return ErrIntOverflowGenerated
    				}
    				if iNdEx >= l {
    					return io.ErrUnexpectedEOF
    				}
    				b := dAtA[iNdEx]
    				iNdEx++
    				m.Queues |= int32(b&0x7F) << shift
    				if b < 0x80 {
    					break
    				}
    			}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 06:06:37 UTC 2024
    - 142K bytes
    - Viewed (0)
  9. staging/src/k8s.io/api/flowcontrol/v1beta3/generated.pb.go

    			if wireType != 0 {
    				return fmt.Errorf("proto: wrong wireType = %d for field Queues", wireType)
    			}
    			m.Queues = 0
    			for shift := uint(0); ; shift += 7 {
    				if shift >= 64 {
    					return ErrIntOverflowGenerated
    				}
    				if iNdEx >= l {
    					return io.ErrUnexpectedEOF
    				}
    				b := dAtA[iNdEx]
    				iNdEx++
    				m.Queues |= int32(b&0x7F) << shift
    				if b < 0x80 {
    					break
    				}
    			}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 06:06:37 UTC 2024
    - 141.9K bytes
    - Viewed (0)
  10. staging/src/k8s.io/api/flowcontrol/v1/generated.pb.go

    			if wireType != 0 {
    				return fmt.Errorf("proto: wrong wireType = %d for field Queues", wireType)
    			}
    			m.Queues = 0
    			for shift := uint(0); ; shift += 7 {
    				if shift >= 64 {
    					return ErrIntOverflowGenerated
    				}
    				if iNdEx >= l {
    					return io.ErrUnexpectedEOF
    				}
    				b := dAtA[iNdEx]
    				iNdEx++
    				m.Queues |= int32(b&0x7F) << shift
    				if b < 0x80 {
    					break
    				}
    			}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 06:06:37 UTC 2024
    - 141.8K bytes
    - Viewed (0)
Back to top