- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for makeOld (0.27 sec)
-
pkg/scheduler/framework/plugins/schedulinggates/scheduling_gates_test.go
pod: st.MakePod().Name("p").SchedulingGates([]string{"foo", "bar"}).Obj(), oldObj: st.MakePod().Name("p").SchedulingGates([]string{"foo", "bar"}).Obj(), newObj: st.MakePod().Name("p").SchedulingGates([]string{"foo"}).Obj(), expectedHint: framework.QueueSkip, }, "queue-on-gates-become-empty": { pod: st.MakePod().Name("p").SchedulingGates([]string{"foo"}).Obj(),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 3.7K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/interpodaffinity/plugin_test.go
pod: st.MakePod().Name("p").PodAffinityIn("service", "region", []string{"securityscan", "value2"}, st.PodAffinityWithRequiredReq).Obj(), newPod: st.MakePod().Label("service", "securityscan").Obj(), oldPod: st.MakePod().Label("service", "securityscan").Obj(), expectedHint: framework.QueueSkip, }, { name: "update a pod from match to non-match the pod affinity",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 12 03:08:44 UTC 2024 - 9.7K bytes - Viewed (0) -
pkg/kube/kclient/crdwatcher_test.go
// Happened sync vsCalls.Inc() } }() clienttest.MakeCRD(t, c, gvr.VirtualService) c.RunAndWait(stop) assert.EventuallyEqual(t, vsCalls.Load, 1) } func TestCRDWatcher(t *testing.T) { stop := test.NewStop(t) c := kube.NewFakeClient() clienttest.MakeCRD(t, c, gvr.VirtualService) vsCalls := atomic.NewInt32(0) clienttest.MakeCRD(t, c, gvr.GatewayClass) ctl := c.CrdWatcher()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 25 14:44:17 UTC 2024 - 3.1K bytes - Viewed (0) -
pkg/kube/kclient/clienttest/crd.go
"k8s.io/apimachinery/pkg/runtime/schema" metadatafake "k8s.io/client-go/metadata/fake" "istio.io/istio/pkg/config/schema/gvr" "istio.io/istio/pkg/kube" "istio.io/istio/pkg/test" ) func MakeCRD(t test.Failer, c kube.Client, g schema.GroupVersionResource) { t.Helper() MakeCRDWithAnnotations(t, c, g, nil) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 25 14:44:17 UTC 2024 - 2K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/fake.go
assert.NoError(t, queue.WaitForClose(c.queue, time.Second*5)) }) } c.stop = stop if cleanupStop { t.Cleanup(func() { close(stop) }) } for _, crd := range opts.CRDs { clienttest.MakeCRD(t, c.client, crd) } opts.Client.RunAndWait(c.stop) var fx *xdsfake.Updater if x, ok := xdsUpdater.(*xdsfake.Updater); ok { fx = x } if !opts.SkipRun { go c.Run(c.stop)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 4K bytes - Viewed (0)