- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 23 for queueset (0.11 sec)
-
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/queueset_test.go
counter.Add(1) // account for the goroutine running this test queue, ok := qs.(*queueSet) if !ok { t.Fatalf("expected a QueueSet of type: %T but got: %T", &queueSet{}, qs) } if queue.totRequestsExecuting != 0 { t.Fatalf("precondition: expected total requests currently executing of the QueueSet to be 0, but got: %d", queue.totRequestsExecuting) } if queue.dCfg.ConcurrencyLimit != 1 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Sep 26 12:55:23 UTC 2023 - 58.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/filters/priority-and-fairness_test.go
// automatically even if the server doesn't cancel is explicitly. // This is required to ensure we won't be leaking goroutines that wait for context // cancelling (e.g. in queueset::StartRequest method). // Even though in production we are not using httptest.Server, this logic is shared // across these two. func TestContextClosesOnRequestProcessed(t *testing.T) { epmetrics.Register()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:40 UTC 2023 - 52.6K bytes - Viewed (0) -
pkg/apis/flowcontrol/validation/validation_test.go
Type: flowcontrol.LimitResponseTypeQueue, Queuing: &flowcontrol.QueuingConfiguration{ Queues: 512, HandSize: 4, QueueLengthLimit: 100, }}}}, }, expectedErrors: field.ErrorList{}, }, { name: "customized priority level w/ overflowing handSize/queues should fail 1", priorityLevelConfiguration: &flowcontrol.PriorityLevelConfiguration{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 22:22:51 UTC 2023 - 54.7K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/defaultpreemption/default_preemption_test.go
podInformer.GetStore().Add(tt.pods[i]) } // Register NodeResourceFit as the Filter & PreFilter plugin. registeredPlugins := []tf.RegisterPluginFunc{ tf.RegisterQueueSortPlugin(queuesort.Name, queuesort.New), tf.RegisterPluginAsExtensions(noderesources.Name, nodeResourcesFitFunc, "Filter", "PreFilter"), tf.RegisterPluginAsExtensions("test-plugin", newTestPlugin, "PreFilter"),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 15:52:16 UTC 2024 - 82.8K bytes - Viewed (0) -
pkg/apis/flowcontrol/v1beta3/zz_generated.conversion.go
} func autoConvert_v1beta3_QueuingConfiguration_To_flowcontrol_QueuingConfiguration(in *v1beta3.QueuingConfiguration, out *flowcontrol.QueuingConfiguration, s conversion.Scope) error { out.Queues = in.Queues out.HandSize = in.HandSize out.QueueLengthLimit = in.QueueLengthLimit return nil } // Convert_v1beta3_QueuingConfiguration_To_flowcontrol_QueuingConfiguration is an autogenerated conversion function.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:41 UTC 2023 - 53.1K bytes - Viewed (0) -
pkg/apis/flowcontrol/v1/zz_generated.conversion.go
} func autoConvert_v1_QueuingConfiguration_To_flowcontrol_QueuingConfiguration(in *v1.QueuingConfiguration, out *flowcontrol.QueuingConfiguration, s conversion.Scope) error { out.Queues = in.Queues out.HandSize = in.HandSize out.QueueLengthLimit = in.QueueLengthLimit return nil } // Convert_v1_QueuingConfiguration_To_flowcontrol_QueuingConfiguration is an autogenerated conversion function.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:41 UTC 2023 - 52.4K bytes - Viewed (0) -
pkg/apis/flowcontrol/v1beta1/zz_generated.conversion.go
} func autoConvert_v1beta1_QueuingConfiguration_To_flowcontrol_QueuingConfiguration(in *v1beta1.QueuingConfiguration, out *flowcontrol.QueuingConfiguration, s conversion.Scope) error { out.Queues = in.Queues out.HandSize = in.HandSize out.QueueLengthLimit = in.QueueLengthLimit return nil } // Convert_v1beta1_QueuingConfiguration_To_flowcontrol_QueuingConfiguration is an autogenerated conversion function.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 14 01:00:06 UTC 2023 - 53.5K bytes - Viewed (0) -
pkg/apis/flowcontrol/v1beta2/zz_generated.conversion.go
} func autoConvert_v1beta2_QueuingConfiguration_To_flowcontrol_QueuingConfiguration(in *v1beta2.QueuingConfiguration, out *flowcontrol.QueuingConfiguration, s conversion.Scope) error { out.Queues = in.Queues out.HandSize = in.HandSize out.QueueLengthLimit = in.QueueLengthLimit return nil } // Convert_v1beta2_QueuingConfiguration_To_flowcontrol_QueuingConfiguration is an autogenerated conversion function.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 14 01:00:06 UTC 2023 - 53.5K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue.go
limitations under the License. */ // This file contains structures that implement scheduling queue types. // Scheduling queues hold pods waiting to be scheduled. This file implements a // priority queue which has two sub queues and a additional data structure, // namely: activeQ, backoffQ and unschedulablePods. // - activeQ holds pods that are being considered for scheduling.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 61.4K bytes - Viewed (0) -
guava/src/com/google/common/collect/MapMakerInternalMap.java
* the type of the concrete implementation. */ abstract S self(); /** Drains the reference queues used by this segment, if any. */ @GuardedBy("this") void maybeDrainReferenceQueues() {} /** Clears the reference queues used by this segment, if any. */ void maybeClearReferenceQueues() {} /** Sets the value of the given {@code entry}. */
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Sat May 18 03:24:34 UTC 2024 - 90.8K bytes - Viewed (0)