- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 50 for newpod (0.19 sec)
-
pkg/scheduler/framework/plugins/interpodaffinity/plugin_test.go
tests := []struct { name string pod *v1.Pod oldPod, newPod *v1.Pod expectedHint framework.QueueingHint }{ { name: "add a pod which matches the pod affinity", pod: st.MakePod().Name("p").PodAffinityIn("service", "region", []string{"securityscan", "value2"}, st.PodAffinityWithRequiredReq).Obj(), newPod: st.MakePod().Node("fake-node").Label("service", "securityscan").Obj(),
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/kubelet/config/common.go
if err != nil { return false, pods, err } newPods, ok := obj.(*api.PodList) // Check whether the object could be converted to list of pods. if !ok { err = fmt.Errorf("invalid pods list: %#v", obj) return false, pods, err } // Apply default values and validate pods. for i := range newPods.Items { newPod := &newPods.Items[i] if newPod.Name == "" {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 03 18:40:48 UTC 2023 - 5.8K bytes - Viewed (0) -
pkg/apis/core/v1/helper/qos/qos_test.go
testCases := []struct { pod *v1.Pod expected v1.PodQOSClass }{ { pod: newPod("guaranteed", []v1.Container{ newContainer("guaranteed", getResourceList("100m", "100Mi"), getResourceList("100m", "100Mi")), }), expected: v1.PodQOSGuaranteed, }, { pod: newPod("guaranteed-guaranteed", []v1.Container{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Aug 07 14:47:37 UTC 2023 - 6.2K bytes - Viewed (0) -
plugin/pkg/admission/namespace/autoprovision/admission_test.go
Name: ns, ResourceVersion: fmt.Sprintf("%d", i), }, }) } return true, namespaceList, nil }) return mockClient } // newPod returns a new pod for the specified namespace func newPod(namespace string) api.Pod { return api.Pod{ ObjectMeta: metav1.ObjectMeta{Name: "123", Namespace: namespace}, Spec: api.PodSpec{ Volumes: []api.Volume{{Name: "vol"}},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 7.5K bytes - Viewed (0) -
pilot/pkg/controllers/untaint/nodeuntainter_test.go
pod.Status = corev1.PodStatus{} newPod := s.pc.Create(pod) if markReady { setPodReady(newPod) } newPod.Status.PodIP = ip newPod.Status.Phase = corev1.PodRunning newPod.Status.PodIPs = []corev1.PodIP{ { IP: ip, }, } s.pc.UpdateStatus(newPod) } else { s.pc.Update(pod) } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Apr 13 00:50:31 UTC 2024 - 6.1K bytes - Viewed (0) -
pkg/controller/job/tracking_utils_test.go
} } func TestRecordFinishedPodWithTrackingFinalizer(t *testing.T) { metrics.Register() cases := map[string]struct { oldPod *v1.Pod newPod *v1.Pod wantAdd int wantDelete int }{ "new non-finished Pod with finalizer": { newPod: &v1.Pod{ ObjectMeta: metav1.ObjectMeta{ Finalizers: []string{batch.JobTrackingFinalizer}, }, Status: v1.PodStatus{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 14 05:40:02 UTC 2023 - 5.9K bytes - Viewed (0) -
plugin/pkg/admission/namespace/exists/admission_test.go
Name: ns, ResourceVersion: fmt.Sprintf("%d", i), }, }) } return true, namespaceList, nil }) return mockClient } // newPod returns a new pod for the specified namespace func newPod(namespace string) api.Pod { return api.Pod{ ObjectMeta: metav1.ObjectMeta{Name: "123", Namespace: namespace}, Spec: api.PodSpec{ Volumes: []api.Volume{{Name: "vol"}},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 4.4K bytes - Viewed (0) -
pkg/quota/v1/install/update_filter.go
switch resource.GroupResource() { case schema.GroupResource{Resource: "pods"}: oldPod := oldObj.(*v1.Pod) newPod := newObj.(*v1.Pod) return core.QuotaV1Pod(oldPod, clock.RealClock{}) && !core.QuotaV1Pod(newPod, clock.RealClock{}) case schema.GroupResource{Resource: "services"}: oldService := oldObj.(*v1.Service) newService := newObj.(*v1.Service)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 08 22:39:55 UTC 2022 - 1.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_testing_utils_test.go
metav1.AddToGroupVersion(scheme, metav1.SchemeGroupVersion) utilruntime.Must(example.AddToScheme(scheme)) utilruntime.Must(examplev1.AddToScheme(scheme)) utilruntime.Must(example2v1.AddToScheme(scheme)) } func newPod() runtime.Object { return &example.Pod{} } func newPodList() runtime.Object { return &example.PodList{} } func newEtcdTestStorage(t *testing.T, prefix string) (*etcd3testing.EtcdTestServer, storage.Interface) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 20 20:43:52 UTC 2023 - 3.8K bytes - Viewed (0) -
pkg/controller/job/tracking_utils.go
if fin == batch.JobTrackingFinalizer { return true } } return false } func recordFinishedPodWithTrackingFinalizer(oldPod, newPod *v1.Pod) { was := isFinishedPodWithTrackingFinalizer(oldPod) is := isFinishedPodWithTrackingFinalizer(newPod) if was == is { return } var event = metrics.Delete if is { event = metrics.Add }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 14 05:40:02 UTC 2023 - 4.3K bytes - Viewed (0)