- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 180 for newpod (0.12 sec)
-
pkg/scheduler/framework/plugins/nodevolumelimits/csi.go
} } } return nil } func (pl *CSILimits) filterAttachableVolumes( logger klog.Logger, pod *v1.Pod, csiNode *storagev1.CSINode, newPod bool, result map[string]string) error { for _, vol := range pod.Spec.Volumes { pvcName := "" isEphemeral := false switch { case vol.PersistentVolumeClaim != nil:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 18:07:11 UTC 2024 - 16.6K bytes - Viewed (0) -
pkg/api/pod/util.go
if len(allErrs) != 0 { return true } } } } return false } func MarkPodProposedForResize(oldPod, newPod *api.Pod) { for i, c := range newPod.Spec.Containers { if c.Resources.Requests == nil { continue } if cmp.Equal(oldPod.Spec.Containers[i].Resources, c.Resources) { continue }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 41.3K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex_test.go
pod.Status = corev1.PodStatus{} newPod := s.pc.Create(pod) if markReady { setPodReady(newPod) } newPod.Status.PodIP = ip newPod.Status.Phase = phase newPod.Status.PodIPs = []corev1.PodIP{ { IP: ip, }, } s.pc.UpdateStatus(newPod) } else { s.pc.Update(pod) } } // just overwrites the labels
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 08 01:04:50 UTC 2024 - 70.2K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/nodevolumelimits/non_csi.go
return framework.NewStatus(framework.Unschedulable, ErrReasonMaxVolumeCountExceeded) } return nil } func (pl *nonCSILimits) filterVolumes(logger klog.Logger, pod *v1.Pod, newPod bool, filteredVolumes sets.Set[string]) error { volumes := pod.Spec.Volumes for i := range volumes { vol := &volumes[i] if id, ok := pl.filter.FilterVolume(vol); ok { filteredVolumes.Insert(id) continue
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Dec 30 23:00:56 UTC 2023 - 19.6K bytes - Viewed (0) -
pkg/kubelet/eviction/eviction_manager_test.go
func TestAdmitUnderNodeConditions(t *testing.T) { manager := &managerImpl{} pods := []*v1.Pod{ newPod("guaranteed-pod", scheduling.DefaultPriorityWhenNoDefaultClassExists, makeContainersByQOS(v1.PodQOSGuaranteed), nil), newPod("burstable-pod", scheduling.DefaultPriorityWhenNoDefaultClassExists, makeContainersByQOS(v1.PodQOSBurstable), nil),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 15 23:14:12 UTC 2024 - 119.9K bytes - Viewed (0) -
pkg/kubelet/volumemanager/populator/desired_state_of_world_populator_test.go
newPod := createPodWithVolume("dswp-test-pod", "dswp-test-volume-name", "file-bound", []v1.Container{newContainer}) // Act - add the new Pod fakePodManager.AddPod(newPod) dswp.findAndAddNewPods() // Assert // Check the global volume state uniquePodName := types.UniquePodName(newPod.UID)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 51.4K bytes - Viewed (0) -
pkg/controller/disruption/disruption.go
func (dc *DisruptionController) failSafe(ctx context.Context, pdb *policy.PodDisruptionBudget, err error) error { newPdb := pdb.DeepCopy() newPdb.Status.DisruptionsAllowed = 0 if newPdb.Status.Conditions == nil { newPdb.Status.Conditions = make([]metav1.Condition, 0) } apimeta.SetStatusCondition(&newPdb.Status.Conditions, metav1.Condition{ Type: policy.DisruptionAllowedCondition,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 36.1K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/interpodaffinity/filtering_test.go
func TestGetTPMapMatchingIncomingAffinityAntiAffinity(t *testing.T) { newPod := func(labels ...string) *v1.Pod { pod := st.MakePod().Name("normal").Node("nodeA") for _, l := range labels { pod.Label(l, "") } return pod.Obj() } normalPodA := newPod("aaa") normalPodB := newPod("bbb") normalPodAB := newPod("aaa", "bbb")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 01 10:24:54 UTC 2023 - 58.2K bytes - Viewed (0) -
pkg/controller/endpoint/endpoints_controller_test.go
} oldPod := old.(*v1.Pod) newPod := oldPod.DeepCopy() newPod.Status.PodIP = update.podIP newPod.Status.PodIPs[0].IP = update.podIP newPod.ResourceVersion = strconv.Itoa(resourceVersion) resourceVersion++ endpoints.podStore.Update(newPod) endpoints.updatePod(oldPod, newPod) } time.Sleep(tc.finalDelay)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 06:51:56 UTC 2024 - 87.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/store_test.go
utilruntime.Must(example.AddToScheme(scheme)) utilruntime.Must(examplev1.AddToScheme(scheme)) grpclog.SetLoggerV2(grpclog.NewLoggerV2(ioutil.Discard, ioutil.Discard, os.Stderr)) } func newPod() runtime.Object { return &example.Pod{} } func newPodList() runtime.Object { return &example.PodList{} }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 12:45:33 UTC 2024 - 26.5K bytes - Viewed (0)