- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 135 for Queuing (0.15 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)