Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 135 for Queuing (0.23 sec)

  1. pkg/apis/flowcontrol/validation/validation.go

    			fmt.Sprintf("must not be greater than %d", priorityLevelConfigurationQueuingMaxQueues)))
    	}
    
    	if queuing.HandSize <= 0 {
    		allErrs = append(allErrs, field.Invalid(fldPath.Child("handSize"), queuing.HandSize, "must be positive"))
    	} else if queuing.HandSize > queuing.Queues {
    		allErrs = append(allErrs, field.Invalid(fldPath.Child("handSize"), queuing.HandSize,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 22:22:51 UTC 2023
    - 26.7K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/doc.go

    limitations under the License.
    */
    
    // Package queueset implements a technique called "fair queuing for
    // server requests".  One QueueSet is a set of queues operating
    // according to this technique.
    //
    // Fair queuing for server requests is inspired by the fair queuing
    // technique from the world of networking.  You can find a good paper
    // on that at https://dl.acm.org/citation.cfm?doid=75247.75248 or
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Feb 08 12:33:30 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  3. pkg/apis/flowcontrol/v1beta2/zz_generated.defaults.go

    	if in.Spec.Limited != nil {
    		SetDefaults_LimitedPriorityLevelConfiguration(in.Spec.Limited)
    		if in.Spec.Limited.LimitResponse.Queuing != nil {
    			SetDefaults_QueuingConfiguration(in.Spec.Limited.LimitResponse.Queuing)
    		}
    	}
    	if in.Spec.Exempt != nil {
    		SetDefaults_ExemptPriorityLevelConfiguration(in.Spec.Exempt)
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jul 14 01:00:06 UTC 2023
    - 2.5K bytes
    - Viewed (0)
  4. pkg/apis/flowcontrol/v1beta3/zz_generated.defaults.go

    	SetDefaults_PriorityLevelConfiguration(in)
    	if in.Spec.Limited != nil {
    		SetDefaults_LimitedPriorityLevelConfiguration(in.Spec.Limited)
    		if in.Spec.Limited.LimitResponse.Queuing != nil {
    			SetDefaults_QueuingConfiguration(in.Spec.Limited.LimitResponse.Queuing)
    		}
    	}
    	if in.Spec.Exempt != nil {
    		SetDefaults_ExemptPriorityLevelConfiguration(in.Spec.Exempt)
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 12:18:41 UTC 2023
    - 2.6K bytes
    - Viewed (0)
  5. pkg/apis/flowcontrol/validation/validation_test.go

    					LimitResponse: flowcontrol.LimitResponse{
    						Type: flowcontrol.LimitResponseTypeReject},
    				},
    			},
    		},
    		expectedErrors: field.ErrorList{},
    	}, {
    		name: "forbid queuing details when not queuing",
    		priorityLevelConfiguration: &flowcontrol.PriorityLevelConfiguration{
    			ObjectMeta: metav1.ObjectMeta{
    				Name: "system-foo",
    			},
    			Spec: flowcontrol.PriorityLevelConfigurationSpec{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 22:22:51 UTC 2023
    - 54.7K bytes
    - Viewed (0)
  6. pkg/apis/flowcontrol/v1beta3/defaults_test.go

    						LimitResponse: flowcontrolv1beta3.LimitResponse{
    							Type: flowcontrolv1beta3.LimitResponseTypeReject,
    						},
    					},
    				},
    			},
    		},
    		{
    			name: "Defaulting for queuing configuration",
    			original: &flowcontrolv1beta3.PriorityLevelConfiguration{
    				Spec: flowcontrolv1beta3.PriorityLevelConfigurationSpec{
    					Type: flowcontrolv1beta3.PriorityLevelEnablementLimited,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 22:22:51 UTC 2023
    - 9.3K bytes
    - Viewed (0)
  7. staging/src/k8s.io/api/testdata/v1.30.0/flowcontrol.apiserver.k8s.io.v1beta3.PriorityLevelConfiguration.yaml

      selfLink: selfLinkValue
      uid: uidValue
    spec:
      exempt:
        lendablePercent: 2
        nominalConcurrencyShares: 1
      limited:
        borrowingLimitPercent: 4
        lendablePercent: 3
        limitResponse:
          queuing:
            handSize: 2
            queueLengthLimit: 3
            queues: 1
          type: typeValue
        nominalConcurrencyShares: 1
      type: typeValue
    status:
      conditions:
      - lastTransitionTime: "2003-01-01T01:01:01Z"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 08:52:25 UTC 2024
    - 1.3K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/SequentialExecutor.java

          queue.add(submittedTask);
          workerRunningState = QUEUING;
        }
    
        try {
          executor.execute(worker);
        } catch (Throwable t) {
          // Any Exception is either a RuntimeException or sneaky checked exception.
          synchronized (queue) {
            boolean removed =
                (workerRunningState == IDLE || workerRunningState == QUEUING)
                    && queue.removeLastOccurrence(submittedTask);
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Thu Feb 01 21:46:34 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  9. guava/src/com/google/common/util/concurrent/SequentialExecutor.java

          queue.add(submittedTask);
          workerRunningState = QUEUING;
        }
    
        try {
          executor.execute(worker);
        } catch (Throwable t) {
          // Any Exception is either a RuntimeException or sneaky checked exception.
          synchronized (queue) {
            boolean removed =
                (workerRunningState == IDLE || workerRunningState == QUEUING)
                    && queue.removeLastOccurrence(submittedTask);
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Thu Feb 01 21:46:34 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  10. pkg/apis/flowcontrol/v1/zz_generated.defaults.go

    	if in.Spec.Limited != nil {
    		SetDefaults_LimitedPriorityLevelConfiguration(in.Spec.Limited)
    		if in.Spec.Limited.LimitResponse.Queuing != nil {
    			SetDefaults_QueuingConfiguration(in.Spec.Limited.LimitResponse.Queuing)
    		}
    	}
    	if in.Spec.Exempt != nil {
    		SetDefaults_ExemptPriorityLevelConfiguration(in.Spec.Exempt)
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 11:48:22 UTC 2023
    - 2.5K bytes
    - Viewed (0)
Back to top