- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 73 for cpod2 (0.08 sec)
-
pilot/pkg/xds/workload_test.go
expectRemoved(ads.ExpectResponse(), "/127.0.0.2") // Once we create it, we should get a push createPod(s, "pod2", "sa", "127.0.0.2", "node") expect(ads.ExpectResponse(), "Kubernetes//Pod/default/pod2") // TODO: implement pod update; this actually cannot really be done without waypoints or VIPs deletePod(s, "pod")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 18 19:09:43 UTC 2024 - 15.9K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set_test.go
pod1.OwnerReferences = []metav1.OwnerReference{controllerRef1} pod1.ResourceVersion = "1" pod2 := pod1 pod2.Labels = labelMap2 pod2.ResourceVersion = "2" manager.updatePod(logger, &pod1, &pod2) expected := sets.NewString(testRSSpec1.Name) for _, name := range expected.List() { t.Logf("Expecting update for %+v", name) select {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 69.2K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller_test.go
pod1 := generatePod("128.0.1.1", "pod1", "nsA", "", "node1", map[string]string{"app": "prod-app"}, map[string]string{}) pod2 := generatePod("128.0.1.2", "pod2", "nsB", "", "node2", map[string]string{"app": "prod-app"}, map[string]string{}) podOverride := generatePod("128.0.1.2", "pod2", "nsB", "", "node1", map[string]string{"app": "prod-app", model.LocalityLabel: "regionOverride.zoneOverride.subzoneOverride"}, map[string]string{})
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 85K bytes - Viewed (0) -
pkg/kubelet/eviction/helpers_test.go
pod1 := newPod("low-priority-high-usage", lowPriority, nil, nil) pod2 := newPod("low-priority-low-usage", lowPriority, nil, nil) pod3 := newPod("high-priority-high-usage", highPriority, nil, nil) pod4 := newPod("high-priority-low-usage", highPriority, nil, nil) stats := map[*v1.Pod]statsapi.PodStats{ pod1: newPodProcessStats(pod1, 20), pod2: newPodProcessStats(pod2, 6), pod3: newPodProcessStats(pod3, 20),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 15 23:14:12 UTC 2024 - 106.7K bytes - Viewed (0) -
pkg/scheduler/util/utils_test.go
pod1 := newPriorityPodWithStartTime("pod1", 1, currentTime) pod2 := newPriorityPodWithStartTime("pod2", 2, currentTime.Add(time.Second)) pod3 := newPriorityPodWithStartTime("pod3", 2, currentTime) tests := map[string]struct { p1 *v1.Pod p2 *v1.Pod expected bool }{ "Pod with higher priority": { p1: pod1, p2: pod2, expected: false, }, "Pod with older created time": {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Sep 21 01:40:44 UTC 2023 - 14.5K bytes - Viewed (0) -
pkg/scheduler/util/utils.go
// but expects those arguments to be *v1.Pod. func MoreImportantPod(pod1, pod2 *v1.Pod) bool { p1 := corev1helpers.PodPriority(pod1) p2 := corev1helpers.PodPriority(pod2) if p1 != p2 { return p1 > p2 } return GetPodStartTime(pod1).Before(GetPodStartTime(pod2)) } // Retriable defines the retriable errors during a scheduling cycle. func Retriable(err error) bool {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Sep 21 01:40:44 UTC 2023 - 6.2K bytes - Viewed (0) -
pkg/apis/core/v1/defaults_test.go
pod = &v1.Pod{ Spec: s, } output = roundTrip(t, runtime.Object(pod)) pod2 = output.(*v1.Pod) defaultRequest = pod2.Spec.Containers[0].Resources.Requests if requestValue := defaultRequest[v1.ResourceCPU]; requestValue.String() != "0" { t.Errorf("Expected 0 request value, got: %s", requestValue.String()) } defaultRequest = pod2.Spec.InitContainers[0].Resources.Requests
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 84.4K bytes - Viewed (0) -
pkg/kube/krt/collection_test.go
assert.EventuallyEqual(t, fetcherSorted(SimpleEndpoints), nil) pod2 := &corev1.Pod{ ObjectMeta: metav1.ObjectMeta{ Name: "name2", Namespace: "namespace", Labels: map[string]string{"app": "foo"}, }, Status: corev1.PodStatus{PodIP: "2.3.4.5"}, } pc.CreateOrUpdateStatus(pod) pc.CreateOrUpdateStatus(pod2) assert.EventuallyEqual(t, fetcherSorted(SimpleEndpoints), []SimpleEndpoint{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 28 04:22:19 UTC 2024 - 14.6K bytes - Viewed (0) -
cmd/kubeadm/app/util/staticpod/utils.go
if err != nil { return pod, errors.Wrap(err, "failed to unmarshal patched manifest") } pod2, ok := obj.(*v1.Pod) if !ok { return pod, errors.Wrap(err, "patched manifest is not a valid Pod object") } return pod2, nil } // WriteStaticPodToDisk writes a static pod file to disk func WriteStaticPodToDisk(componentName, manifestDir string, pod v1.Pod) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 14 13:07:56 UTC 2024 - 14.1K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/nodeports/node_ports_test.go
t.Errorf("status does not match: %v, want: %v", gotStatus, wantStatus) } } func TestGetContainerPorts(t *testing.T) { tests := []struct { pod1 *v1.Pod pod2 *v1.Pod expected []*v1.ContainerPort }{ { pod1: st.MakePod().ContainerPort([]v1.ContainerPort{ { ContainerPort: 8001, HostPort: 8001, Protocol: v1.ProtocolTCP,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 19 11:02:11 UTC 2023 - 10.1K bytes - Viewed (0)