- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for NewFIFO (0.1 sec)
-
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/queueset_test.go
requestsWaiting: newFIFO( &request{workEstimate: qs0.completeWorkEstimate(&fcrequest.WorkEstimate{InitialSeats: 1})}, ), requestsExecuting: sets.New[*request](), }, { nextDispatchR: fcrequest.SeatsTimesDuration(1, 100*time.Second), requestsWaiting: newFIFO(
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Sep 26 12:55:23 UTC 2023 - 58.4K bytes - Viewed (0) -
pkg/scheduler/schedule_one_test.go
}) } } func TestSchedulerNoPhantomPodAfterExpire(t *testing.T) { logger, ctx := ktesting.NewTestContext(t) ctx, cancel := context.WithCancel(ctx) defer cancel() queuedPodStore := clientcache.NewFIFO(clientcache.MetaNamespaceKeyFunc) scache := internalcache.New(ctx, 100*time.Millisecond) pod := podWithPort("pod.Name", "", 8080) node := v1.Node{ObjectMeta: metav1.ObjectMeta{Name: "node1", UID: types.UID("node1")}}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:20:55 UTC 2024 - 128.1K bytes - Viewed (0)