- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 79 for makeOld (0.15 sec)
-
pkg/controller/endpoint/endpoints_controller_test.go
expectedUnready int }{ { name: "pod running phase", pod: makePod(v1.PodRunning, true, false), service: makeService(false), expectedReady: 1, expectedUnready: 0, }, { name: "pod running phase being deleted", pod: makePod(v1.PodRunning, true, true), service: makeService(false), expectedReady: 0,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 06:51:56 UTC 2024 - 87.7K bytes - Viewed (0) -
pkg/controller/resourceclaim/controller_test.go
className = "my-resource-class" nodeName = "worker" testPod = makePod(testPodName, testNamespace, testPodUID) testPodWithResource = makePod(testPodName, testNamespace, testPodUID, *makePodResourceClaim(podResourceClaimName, templateName)) otherTestPod = makePod(testPodName+"-II", testNamespace, testPodUID+"-II")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 06 08:56:16 UTC 2024 - 28.2K bytes - Viewed (0) -
cni/pkg/repair/repair_test.go
"istio.io/istio/tools/istio-iptables/pkg/constants" ) func TestMatchesFilter(t *testing.T) { makeDetectPod := func(name string, terminationMessage string, exitCode int) *corev1.Pod { return makePod(makePodArgs{ PodName: name, Annotations: map[string]string{"sidecar.istio.io/status": "something"}, InitContainerStatus: &corev1.ContainerStatus{ Name: constants.ValidationContainerName,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 24 03:31:28 UTC 2023 - 10.6K bytes - Viewed (0) -
pkg/scheduler/testing/workload_prep.go
Label(v1.LabelHostname, fmt.Sprintf("node%d", i)).Obj() allNodes = append(allNodes, node) } filteredNodes = allNodes[:filteredNodesNum] // build pods for i := 0; i < existingPodsNum; i++ { podWrapper := MakePod().Name(fmt.Sprintf("pod%d", i)).Node(fmt.Sprintf("node%d", i%allNodesNum)) // apply labels[0], labels[0,1], ..., labels[all] to each pod in turn for _, p := range labelPairs[:i%len(labelPairs)+1] {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jan 16 13:43:36 UTC 2023 - 2.3K 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) -
pkg/scheduler/framework/plugins/defaultbinder/default_binder_test.go
"k8s.io/klog/v2/ktesting" frameworkruntime "k8s.io/kubernetes/pkg/scheduler/framework/runtime" st "k8s.io/kubernetes/pkg/scheduler/testing" ) func TestDefaultBinder(t *testing.T) { testPod := st.MakePod().Name("foo").Namespace("ns").Obj() testNode := "foohost.kubernetes.mydomain.com" tests := []struct { name string injectErr error wantBinding *v1.Binding }{ { name: "successful",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 23 02:17:34 UTC 2023 - 2.6K bytes - Viewed (0) -
src/net/http/client_test.go
}{ { desc: "Strip password from error message", in: "http://user:password@dummy.faketld/", out: `Get "http://user:***@dummy.faketld/": dummy impl`, }, { desc: "Don't Strip password from domain name", in: "http://user:password@password.faketld/", out: `Get "http://user:***@password.faketld/": dummy impl`, }, { desc: "Don't Strip password from path",
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 21:30:50 UTC 2024 - 63.8K bytes - Viewed (0) -
pilot/pkg/config/kube/crdclient/client_test.go
if len(l) != 0 { return fmt.Errorf("expected no items returned for unknown CRD") } return nil }, retry.Timeout(time.Second*5), retry.Converge(5)) clienttest.MakeCRD(t, fake, r.GroupVersionResource()) retry.UntilSuccessOrFail(t, func() error { l := store.List(r.GroupVersionKind(), "") if len(l) != 1 { return fmt.Errorf("expected items returned") }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 10 02:58:52 UTC 2024 - 14.1K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/helper/spread_test.go
}, }, } services = append(services, service) fakeInformerFactory.Core().V1().Services().Informer().GetStore().Add(service) } var pods []*v1.Pod for i := 0; i < 5; i++ { pod := st.MakePod().Name(fmt.Sprintf("test-pod-%d", i)). Namespace("test"). Label("app", fmt.Sprintf("test-%d", i)). Label("label", fmt.Sprintf("label-%d", i)). Obj() pods = append(pods, pod) } tests := []struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 05 17:48:55 UTC 2022 - 2.5K bytes - Viewed (0)