- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 89 for queueset (0.12 sec)
-
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/queueset.go
if qCfg.DesiredNumQueues > 0 { // Adding queues is the only thing that requires immediate action // Removing queues is handled by attrition, removing a queue when // it goes empty and there are too many. numQueues := len(qs.queues) if qCfg.DesiredNumQueues > numQueues { qs.queues = append(qs.queues, createQueues(qCfg.DesiredNumQueues-numQueues, len(qs.queues))...) } } else {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jan 04 16:59:21 UTC 2024 - 42.4K bytes - Viewed (0) -
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) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/controller_test.go
if len(missingQueueSetNames) > 0 { t.Errorf("Fail: missing QueueSets %v", missingQueueSetNames) } nonIdleQueueSetNames := cts.getNonIdleQueueSetNames() extraQueueSetNames := nonIdleQueueSetNames.Difference(expectedQueueSetNames) if len(extraQueueSetNames) > 0 { t.Errorf("Fail: unexpected QueueSets %v", extraQueueSetNames) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:40 UTC 2023 - 18.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/QueuesTest.java
assertEquals(1, Queues.newLinkedBlockingDeque(1).remainingCapacity()); assertEquals(11, Queues.newLinkedBlockingDeque(11).remainingCapacity()); } public void testNewLinkedBlockingQueueCapacity() { assertThrows(IllegalArgumentException.class, () -> Queues.newLinkedBlockingQueue(0)); assertEquals(1, Queues.newLinkedBlockingQueue(1).remainingCapacity());
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 12K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/QueuesTest.java
assertEquals(1, Queues.newLinkedBlockingDeque(1).remainingCapacity()); assertEquals(11, Queues.newLinkedBlockingDeque(11).remainingCapacity()); } public void testNewLinkedBlockingQueueCapacity() { assertThrows(IllegalArgumentException.class, () -> Queues.newLinkedBlockingQueue(0)); assertEquals(1, Queues.newLinkedBlockingQueue(1).remainingCapacity());
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 12K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Queues.java
* * @author Kurt Alfred Kluever * @since 11.0 */ @GwtCompatible(emulated = true) @ElementTypesAreNonnullByDefault public final class Queues { private Queues() {} // ArrayBlockingQueue /** * Creates an empty {@code ArrayBlockingQueue} with the given (fixed) capacity and nonfair access * policy. */ @J2ktIncompatible
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 01 16:15:01 UTC 2024 - 16K bytes - Viewed (0) -
guava/src/com/google/common/collect/Queues.java
* * @author Kurt Alfred Kluever * @since 11.0 */ @GwtCompatible(emulated = true) @ElementTypesAreNonnullByDefault public final class Queues { private Queues() {} // ArrayBlockingQueue /** * Creates an empty {@code ArrayBlockingQueue} with the given (fixed) capacity and nonfair access * policy. */ @J2ktIncompatible
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 01 16:15:01 UTC 2024 - 18K bytes - Viewed (0) -
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) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/metrics/metrics.go
func AddRequestsInQueues(ctx context.Context, priorityLevel, flowSchema string, delta int) { apiserverCurrentInqueueRequests.WithLabelValues(priorityLevel, flowSchema).Add(float64(delta)) } // AddSeatsInQueues adds the given delta to the gauge of the # of seats in the queues of the specified flowSchema and priorityLevel
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 24 19:40:05 UTC 2023 - 25.6K bytes - Viewed (0) -
pkg/scheduler/extender_test.go
expectedResult ScheduleResult expectsErr bool }{ { registerPlugins: []tf.RegisterPluginFunc{ tf.RegisterFilterPlugin("TrueFilter", tf.NewTrueFilterPlugin), tf.RegisterQueueSortPlugin(queuesort.Name, queuesort.New), tf.RegisterBindPlugin(defaultbinder.Name, defaultbinder.New), }, extenders: []tf.FakeExtender{ { ExtenderName: "FakeExtender1",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 19:07:19 UTC 2024 - 16.7K bytes - Viewed (0)