- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 168 for newpod (0.13 sec)
-
staging/src/k8s.io/apiserver/pkg/admission/conversion_test.go
&example.Pod{ObjectMeta: metav1.ObjectMeta{Name: "newpod"}}, &example.Pod{ObjectMeta: metav1.ObjectMeta{Name: "oldpod"}}, ), // name gets overwritten from converted attributes, type gets set explicitly VersionedObject: &examplev1.Pod{TypeMeta: metav1.TypeMeta{APIVersion: "example.apiserver.k8s.io/v1", Kind: "Pod"}, ObjectMeta: metav1.ObjectMeta{Name: "newpod"}},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 12 15:48:03 UTC 2023 - 13.7K bytes - Viewed (0) -
pkg/controller/daemon/daemon_controller_test.go
wantedPods: []*v1.Pod{ newPod("matching-owned-0-", "node-0", simpleDaemonSetLabel, ds), newPod("matching-orphan-0-", "node-0", simpleDaemonSetLabel, nil), newPod("matching-owned-1-", "node-1", simpleDaemonSetLabel, ds), newPod("matching-orphan-1-", "node-1", simpleDaemonSetLabel, nil), func() *v1.Pod { pod := newPod("matching-owned-succeeded-pod-0-", "node-0", simpleDaemonSetLabel, ds)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 111.4K bytes - Viewed (0) -
pkg/controller/daemon/update.go
numUnavailable++ continue } switch { case oldPod == nil && newPod == nil, oldPod != nil && newPod != nil: // the manage loop will handle creating or deleting the appropriate pod, consider this unavailable numUnavailable++ case newPod != nil: // this pod is up to date, check its availability if !podutil.IsPodAvailable(newPod, ds.Spec.MinReadySeconds, metav1.Time{Time: now}) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 13 16:53:53 UTC 2024 - 24.4K bytes - Viewed (0) -
pkg/controller/tainteviction/taint_eviction.go
nodeName = newPod.Spec.NodeName newTolerations = newPod.Spec.Tolerations } if oldPod != nil && newPod != nil && helper.Semantic.DeepEqual(oldTolerations, newTolerations) && oldPod.Spec.NodeName == newPod.Spec.NodeName { return } updateItem := podUpdateItem{ podName: podName, podNamespace: podNamespace, nodeName: nodeName, } tc.podUpdateQueue.Add(updateItem) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 19.9K bytes - Viewed (0) -
pkg/controller/disruption/disruption_test.go
"notthere": {Time: currentTime}, // Should be removed, pod deleted. } add(t, dc.pdbStore, pdb) pod1, _ := newPod(t, "p1") pod1.DeletionTimestamp = &metav1.Time{Time: dc.clock.Now()} pod2, _ := newPod(t, "p2") pod3, _ := newPod(t, "p3") add(t, dc.podStore, pod1) add(t, dc.podStore, pod2) add(t, dc.podStore, pod3) dc.sync(ctx, pdbName)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 50K bytes - Viewed (0) -
pkg/controller/controller_utils_test.go
pods := []v1.Pod{} for i := 0; i < count; i++ { newPod := v1.Pod{ ObjectMeta: metav1.ObjectMeta{ Name: fmt.Sprintf("pod%d", i), Labels: rc.Spec.Selector, Namespace: rc.Namespace, }, Status: v1.PodStatus{Phase: status}, } if store != nil { store.Add(&newPod) } pods = append(pods, newPod) } return &v1.PodList{ Items: pods, } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 39.4K bytes - Viewed (0) -
pkg/scheduler/eventhandlers.go
} if isAssumed { return } logger.V(4).Info("Update event for unscheduled pod", "pod", klog.KObj(newPod)) if err := sched.SchedulingQueue.Update(logger, oldPod, newPod); err != nil { utilruntime.HandleError(fmt.Errorf("unable to update %T: %v", newObj, err)) } } func (sched *Scheduler) deletePodFromSchedulingQueue(obj interface{}) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:21:04 UTC 2024 - 24K bytes - Viewed (0) -
pkg/registry/core/pod/strategy_test.go
newPod := tc.newPod Strategy.PrepareForCreate(genericapirequest.NewContext(), newPod) if errs := Strategy.Validate(genericapirequest.NewContext(), newPod); len(errs) != 0 { t.Errorf("Unexpected error: %v", errs.ToAggregate()) } if diff := cmp.Diff(getLifecycle(newPod), getLifecycle(tc.wantPod)); diff != "" {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 76.2K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceregistry_test.go
newPod := pod.DeepCopy() newPod.Status.PodIP = "2.3.4.5" makePod(t, s.KubeClient().Kube(), newPod) expectEndpoints(t, s, "outbound|80||service.namespace.svc.cluster.local", expectAmbient([]string{"2.3.4.5:80"}, ambient), nodeMeta) if err := s.KubeClient().Kube().CoreV1().Pods(newPod.Namespace).Delete(context.Background(), newPod.Name, metav1.DeleteOptions{}); err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 51.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/namespace/lifecycle/admission_test.go
}, Status: v1.NamespaceStatus{ Phase: phase, }, }) index++ } return true, namespaceList, nil }) return mockClient } // newPod returns a new pod for the specified namespace func newPod(namespace string) v1.Pod { return v1.Pod{ ObjectMeta: metav1.ObjectMeta{Name: "123", Namespace: namespace}, Spec: v1.PodSpec{ Volumes: []v1.Volume{{Name: "vol"}},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 14.2K bytes - Viewed (0)