- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 69 for makeOld (0.13 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/cacher/cache_watcher_test.go
{Type: watch.Added, Object: makePod(1)}, {Type: watch.Added, Object: makePod(2)}, {Type: watch.Added, Object: makePod(5)}, {Type: watch.Bookmark, Object: &v1.Pod{ ObjectMeta: metav1.ObjectMeta{ ResourceVersion: "10", Annotations: map[string]string{metav1.InitialEventsAnnotationKey: "true"}, }, }}, {Type: watch.Added, Object: makePod(15)}, }, true)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 09:20:10 UTC 2024 - 22.9K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/topology_hints_test.go
} func returnTestCases() []testCase { testPod1 := makePod("fakePod", "fakeContainer", "2", "2") testContainer1 := &testPod1.Spec.Containers[0] testPod2 := makePod("fakePod", "fakeContainer", "5", "5") testContainer2 := &testPod2.Spec.Containers[0] testPod3 := makePod("fakePod", "fakeContainer", "7", "7") testContainer3 := &testPod3.Spec.Containers[0] testPod4 := makePod("fakePod", "fakeContainer", "11", "11")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 19K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceregistry_test.go
_, kube, xdsUpdater := setupTest(t) makeService(t, kube, service) xdsUpdater.WaitOrFail(t, "service") makePod(t, kube, pod) xdsUpdater.WaitOrFail(t, "proxy") newPod := pod.DeepCopy() newPod.Labels["newlabel"] = "new" makePod(t, kube, newPod) xdsUpdater.WaitOrFail(t, "proxy") }) t.Run("Kubernetes only: headless pure HTTP service", func(t *testing.T) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 51.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go
watchers = append(watchers, w) } makePod := func(name, rv string) *examplev1.Pod { return &examplev1.Pod{ ObjectMeta: metav1.ObjectMeta{ Name: name, Namespace: "ns", ResourceVersion: rv, }, } } pod1 := makePod("pod", "1001") pod2 := makePod("pod", "1002") pod3 := makePod("pod", "1003") cacher.watchCache.Add(pod1)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 82.9K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue_test.go
var pods = []*v1.Pod{ st.MakePod().Name("p0").Namespace("ns1").Annotation("annot1", "val1").NominatedNodeName("node1").Obj(), st.MakePod().Name("p1").Namespace("ns1").Annotation("annot", "val").Obj(), st.MakePod().Name("p2").Namespace("ns2").Annotation("annot2", "val2").Annotation("annot3", "val3").NominatedNodeName("node3").Obj(),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 146.9K bytes - Viewed (0) -
pkg/kube/kclient/client_test.go
wasm.AddEventHandler(clienttest.TrackerHandler(tracker)) go constantlyAccessForRaceDetection(stop, wasm) // CRD and Delayed client are ready to go by the time we start informers clienttest.MakeCRD(t, c, gvr.WasmPlugin) c.RunAndWait(stop) wt.Create(&istioclient.WasmPlugin{ ObjectMeta: metav1.ObjectMeta{Name: "name", Namespace: "default"}, }) assert.EventuallyEqual(t, func() int {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jun 11 15:12:54 UTC 2024 - 17.2K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/volumebinding/binder_test.go
// If nil, use pod PVCs cachePVCs []*v1.PersistentVolumeClaim // If nil, makePod with podPVCs pod *v1.Pod // Expected podBindingCache fields expectedBindings []*BindingInfo // Expected return values reasons ConflictReasons shouldFail bool } scenarios := map[string]scenarioType{ "no-volumes": { pod: makePod("test-pod"). withNamespace("testns"). withNodeName("node1").Pod,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 09:46:58 UTC 2024 - 82.8K bytes - Viewed (0) -
pkg/controller/volume/ephemeral/controller_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 06:51:56 UTC 2024 - 8.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/util_test.go
return server, storage } server, etcdStorage := newEtcdTestStorage(t, "") defer server.Terminate(t) versioner := storage.APIObjectVersioner{} makePod := func(name string) *example.Pod { return &example.Pod{ ObjectMeta: metav1.ObjectMeta{Namespace: "ns", Name: name}, } } createPod := func(obj *example.Pod) *example.Pod {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 11 12:07:39 UTC 2024 - 6.3K bytes - Viewed (0) -
pkg/api/pod/util_test.go
// preStop // container { oldPod := makePod([]api.Container{makeContainer(tc.oldLifecycleHandler.DeepCopy(), nil)}, nil, nil) newPod := makePod([]api.Container{makeContainer(tc.newLifecycleHandler.DeepCopy(), nil)}, nil, nil) expectPod := makePod([]api.Container{makeContainer(tc.expectLifecycleHandler.DeepCopy(), nil)}, nil, nil)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 108.8K bytes - Viewed (0)