Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 13 for pod4 (0.76 sec)

  1. pkg/kubelet/pod_workers_test.go

    		return status
    	}
    	withLabel := func(pod *v1.Pod, label, value string) *v1.Pod {
    		if pod.Labels == nil {
    			pod.Labels = make(map[string]string)
    		}
    		pod.Labels[label] = value
    		return pod
    	}
    	withDeletionTimestamp := func(pod *v1.Pod, ts time.Time, gracePeriod *int64) *v1.Pod {
    		pod.DeletionTimestamp = &metav1.Time{Time: ts}
    		pod.DeletionGracePeriodSeconds = gracePeriod
    		return pod
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 75.6K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go

    				Namespace:       "ns",
    				ResourceVersion: rv,
    			},
    		}
    	}
    	pod1 := makePod("pod", "1001")
    	pod2 := makePod("pod", "1002")
    	pod3 := makePod("pod", "1003")
    
    	cacher.watchCache.Add(pod1)
    	cacher.watchCache.Update(pod2)
    	cacher.watchCache.Delete(pod3)
    
    	// At this point, we already have dispatchedEvents fully propagated.
    
    	verifyEvents := func(w watch.Interface) {
    		var event watch.Event
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 82.9K bytes
    - Viewed (0)
  3. pilot/pkg/serviceregistry/kube/controller/controller_test.go

    			},
    			wantAZ: map[*corev1.Pod]string{
    				pod1: "region1/zone1/",
    				pod2: "region2/zone2/",
    			},
    		},
    		{
    			name: "should return false if pod isn't in the cache",
    			wantAZ: map[*corev1.Pod]string{
    				pod1: "",
    				pod2: "",
    			},
    		},
    		{
    			name: "should return false if node isn't in the cache",
    			pods: []*corev1.Pod{pod1, pod2},
    			wantAZ: map[*corev1.Pod]string{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 85K bytes
    - Viewed (0)
  4. pkg/controller/endpointslice/endpointslice_controller_test.go

    }
    
    // Ensure SyncService correctly selects Pods.
    func TestSyncServicePodSelection(t *testing.T) {
    	client, esController := newController(t, []string{"node-1"}, time.Duration(0))
    	ns := metav1.NamespaceDefault
    
    	pod1 := newPod(1, ns, true, 0, false)
    	esController.podStore.Add(pod1)
    
    	// ensure this pod will not match the selector
    	pod2 := newPod(2, ns, true, 0, false)
    	pod2.Labels["foo"] = "boo"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 08:33:32 UTC 2024
    - 65.5K bytes
    - Viewed (0)
  5. pkg/kubelet/cm/devicemanager/manager_test.go

    	})
    	pod2 := makePod(v1.ResourceList{
    		v1.ResourceName(res2.resourceName): res2.resourceQuantity,
    	})
    
    	activePods := []*v1.Pod{pod1, pod2}
    	podsStub.updateActivePods(activePods)
    
    	err = testManager.Allocate(pod1, &pod1.Spec.Containers[0])
    	as.Nil(err)
    	err = testManager.Allocate(pod2, &pod2.Spec.Containers[0])
    	as.Nil(err)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 65K bytes
    - Viewed (0)
  6. pkg/scheduler/framework/plugins/noderesources/fit_test.go

    		})
    	}
    	return &v1.Pod{
    		Spec: v1.PodSpec{
    			Containers: containers,
    		},
    	}
    }
    
    func newResourceInitPod(pod *v1.Pod, usage ...framework.Resource) *v1.Pod {
    	pod.Spec.InitContainers = newResourcePod(usage...).Spec.Containers
    	return pod
    }
    
    func newResourceOverheadPod(pod *v1.Pod, overhead v1.ResourceList) *v1.Pod {
    	pod.Spec.Overhead = overhead
    	return pod
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 57.4K bytes
    - Viewed (0)
  7. staging/src/k8s.io/api/testdata/HEAD/core.v1.Pod.json

    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 52.6K bytes
    - Viewed (0)
  8. pkg/controller/statefulset/stateful_set_utils_test.go

    	}
    	pod.Name = "foo"
    	if identityMatches(set, pod) {
    		t.Error("identity matches for a Pod with the wrong name")
    	}
    	pod = newStatefulSetPod(set, 1)
    	pod.Namespace = ""
    	if identityMatches(set, pod) {
    		t.Error("identity matches for a Pod with the wrong namespace")
    	}
    	pod = newStatefulSetPod(set, 1)
    	delete(pod.Labels, apps.StatefulSetPodNameLabel)
    	if identityMatches(set, pod) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 05 19:06:41 UTC 2024
    - 50.9K bytes
    - Viewed (0)
  9. pkg/kube/inject/testdata/inputs/enable-core-dump.yaml.5.template.gen.yaml

    # defaultTemplates defines the default template to use for pods that do not explicitly specify a template
    defaultTemplates: [sidecar]
    policy: enabled
    alwaysInjectSelector:
      []
    neverInjectSelector:
      []
    injectedAnnotations:
    template: "{{ Template_Version_And_Istio_Version_Mismatched_Check_Installation }}"
    templates:
      sidecar: |
        {{- define "resources"  }}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jun 03 01:55:05 UTC 2024
    - 75.9K bytes
    - Viewed (0)
  10. pkg/kube/inject/testdata/inputs/hello-existing-cncf-networks-json.yaml.16.template.gen.yaml

    # defaultTemplates defines the default template to use for pods that do not explicitly specify a template
    defaultTemplates: [sidecar]
    policy: enabled
    alwaysInjectSelector:
      []
    neverInjectSelector:
      []
    injectedAnnotations:
    template: "{{ Template_Version_And_Istio_Version_Mismatched_Check_Installation }}"
    templates:
      sidecar: |
        {{- define "resources"  }}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jun 03 01:55:05 UTC 2024
    - 75.9K bytes
    - Viewed (0)
Back to top