Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 135 for Queuing (0.15 sec)

  1. staging/src/k8s.io/api/flowcontrol/v1beta1/types_swagger_doc_generated.go

    	"queuing": "`queuing` holds the configuration parameters for queuing. This field may be non-empty only if `type` is `\"Queue\"`.",
    }
    
    func (LimitResponse) SwaggerDoc() map[string]string {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Sep 17 09:27:57 UTC 2023
    - 21.2K bytes
    - Viewed (0)
  2. staging/src/k8s.io/api/flowcontrol/v1beta2/generated.proto

      // are held in a queue until they can be executed or a queuing limit
      // is reached.
      // "Reject" means that requests that can not be executed upon arrival
      // are rejected.
      // Required.
      // +unionDiscriminator
      optional string type = 1;
    
      // `queuing` holds the configuration parameters for queuing.
      // This field may be non-empty only if `type` is `"Queue"`.
      // +optional
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 28 15:34:11 UTC 2024
    - 21.4K bytes
    - Viewed (0)
  3. staging/src/k8s.io/api/flowcontrol/v1beta2/types_swagger_doc_generated.go

    	"queuing": "`queuing` holds the configuration parameters for queuing. This field may be non-empty only if `type` is `\"Queue\"`.",
    }
    
    func (LimitResponse) SwaggerDoc() map[string]string {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Sep 17 09:27:57 UTC 2023
    - 21.2K bytes
    - Viewed (0)
  4. staging/src/k8s.io/api/flowcontrol/v1/generated.proto

      // are held in a queue until they can be executed or a queuing limit
      // is reached.
      // "Reject" means that requests that can not be executed upon arrival
      // are rejected.
      // Required.
      // +unionDiscriminator
      optional string type = 1;
    
      // `queuing` holds the configuration parameters for queuing.
      // This field may be non-empty only if `type` is `"Queue"`.
      // +optional
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 28 15:34:11 UTC 2024
    - 21.6K bytes
    - Viewed (0)
  5. staging/src/k8s.io/api/flowcontrol/v1beta1/generated.proto

      // are held in a queue until they can be executed or a queuing limit
      // is reached.
      // "Reject" means that requests that can not be executed upon arrival
      // are rejected.
      // Required.
      // +unionDiscriminator
      optional string type = 1;
    
      // `queuing` holds the configuration parameters for queuing.
      // This field may be non-empty only if `type` is `"Queue"`.
      // +optional
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 28 15:34:11 UTC 2024
    - 21.4K bytes
    - Viewed (0)
  6. staging/src/k8s.io/api/flowcontrol/v1beta3/generated.proto

      // are held in a queue until they can be executed or a queuing limit
      // is reached.
      // "Reject" means that requests that can not be executed upon arrival
      // are rejected.
      // Required.
      // +unionDiscriminator
      optional string type = 1;
    
      // `queuing` holds the configuration parameters for queuing.
      // This field may be non-empty only if `type` is `"Queue"`.
      // +optional
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 28 15:34:11 UTC 2024
    - 21.5K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_filter_test.go

    				LendablePercent:          &lendable,
    				BorrowingLimitPercent:    &borrowingLimit,
    				LimitResponse: flowcontrol.LimitResponse{
    					Type: flowcontrol.LimitResponseTypeQueue,
    					Queuing: &flowcontrol.QueuingConfiguration{
    						Queues:           10,
    						HandSize:         2,
    						QueueLengthLimit: 10,
    					},
    				},
    			},
    		},
    	}
    	cfgObjs = append(cfgObjs, fsObj, plcObj)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 12:18:40 UTC 2023
    - 5.6K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/max_seats_test.go

    					Limited: &flowcontrolv1.LimitedPriorityLevelConfiguration{
    						NominalConcurrencyShares: ptr.To(int32(10000)),
    						LimitResponse: flowcontrolv1.LimitResponse{
    							Queuing: &flowcontrolv1.QueuingConfiguration{
    								HandSize: testcase.handSize,
    							},
    						},
    					},
    				},
    			}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 12:18:40 UTC 2023
    - 4.2K bytes
    - Viewed (0)
  9. cmd/namespace-lock_test.go

    		}()
    		time.Sleep(1 * time.Millisecond) // wait for goroutine to advance; ref=2
    
    		// Unlock the 1st lock; ref=1 after this line
    		nsLk.unlock("volume", "path", false)
    
    		// Taking another lockMapMutex here allows queuing up additional lockers. This should
    		// not be required but makes reproduction much easier.
    		nsLk.lockMapMutex.Lock()
    
    		// lk3 blocks.
    		lk3ch := make(chan bool)
    		go func() {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Apr 23 18:58:53 UTC 2021
    - 3.1K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_controller.go

    			// BTW, we know the Spec has not changed what is says about queuing because the
    			// mandatory objects have immutable Specs as far as queuing is concerned.
    			klog.V(3).Infof("Retaining mandatory priority level %q despite lack of API object", plName)
    		} else {
    			if plState.numPending == 0 && plState.queues.IsIdle() {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 48.8K bytes
    - Viewed (0)
Back to top