- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 14 for createdPod (0.23 sec)
-
pkg/kubelet/pod/mirror_client_test.go
assert.Error(t, err) return } createdPod, err := clientset.CoreV1().Pods(testPodNS).Get(context.TODO(), testPodName, metav1.GetOptions{}) require.NoError(t, err) // Validate created pod assert.Equal(t, testPodHash, createdPod.Annotations[kubetypes.ConfigMirrorAnnotationKey]) assert.Len(t, createdPod.OwnerReferences, 1) expectedOwnerRef := metav1.OwnerReference{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 08 12:44:09 UTC 2023 - 4.2K bytes - Viewed (0) -
pkg/registry/core/pod/strategy_test.go
if len(errs) != 0 { t.Errorf("Unexpected error: %v", errs.ToAggregate()) } createdPod := pod.DeepCopy() Strategy.PrepareForCreate(ctx, createdPod) if len(createdPod.Spec.TopologySpreadConstraints) != 1 || *createdPod.Spec.TopologySpreadConstraints[0].NodeAffinityPolicy != ignore || *createdPod.Spec.TopologySpreadConstraints[0].NodeTaintsPolicy != honor {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 76.2K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/podtopologyspread/plugin.go
"pod", klog.KObj(pod), "createdPod", klog.KObj(modifiedPod)) return framework.Queue, nil } logger.V(5).Info("a scheduled pod was created, but it doesn't matches with the pod's topology spread constraints", "pod", klog.KObj(pod), "createdPod", klog.KObj(modifiedPod)) return framework.QueueSkip, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 16 14:13:06 UTC 2024 - 12.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/testing/watcher_tests.go
} var createdPods []*example.Pod ns := fmt.Sprintf("ns-%v", idx) for _, obj := range scenario.initialPods { obj.Namespace = ns out := &example.Pod{} err := store.Create(ctx, computePodKey(obj), obj, out, 0) require.NoError(t, err, "failed to add a pod: %v", obj) createdPods = append(createdPods, out) } if scenario.useCurrentRV {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 63.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store_test.go
if createResult, err = registry.Create(genericapirequest.NewDefaultContext(), newPod(), rest.ValidateAllObjectFunc, &metav1.CreateOptions{}); err != nil { t.Fatalf("Unexpected error: %v", err) } createdPod, err := registry.Get(genericapirequest.NewDefaultContext(), "foo", &metav1.GetOptions{}) if err != nil { t.Fatalf("Unexpected error: %v", err) } var updateResult runtime.Object p := newPod()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 101.8K bytes - Viewed (0) -
pilot/pkg/xds/workload_test.go
}) ads.ExpectEmptyResponse() // Create pod, due to wildcard subscribe we should receive it createPod(s, "pod", "sa", "127.0.0.1", "not-node") expect(ads.ExpectResponse(), "Kubernetes//Pod/default/pod") // A new pod should push only that one createPod(s, "pod2", "sa", "127.0.0.2", "node") expect(ads.ExpectResponse(), "Kubernetes//Pod/default/pod2")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 18 19:09:43 UTC 2024 - 15.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/util_test.go
} func TestHasInitialEventsEndBookmarkAnnotation(t *testing.T) { createPod := func(name string) *example.Pod { return &example.Pod{ObjectMeta: metav1.ObjectMeta{Name: name}} } createAnnotatedPod := func(name, value string) *example.Pod { p := createPod(name) p.Annotations = map[string]string{} p.Annotations[metav1.InitialEventsAnnotationKey] = value return p }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 11 12:07:39 UTC 2024 - 6.3K bytes - Viewed (0) -
pkg/volume/util/recyclerclient/recycler_client_test.go
client := &mockRecyclerClient{ events: test.eventSequence, pod: test.existingPod, } err := internalRecycleVolumeByWatchingPodUntilCompletion(test.createPod.Name, test.createPod, client) receivedError := "" if err != nil { receivedError = err.Error() } if receivedError != test.expectedError { t.Errorf("Test %q failed, expected error %q, got %q", test.name, test.expectedError, receivedError)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 31 14:16:53 UTC 2022 - 8.5K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/pod_test.go
}) initTestEnv(t, c.client.Kube(), fx) createPod := func(ip, name string) { addPods(t, c, fx, generatePod(ip, name, "ns", "1", "", map[string]string{}, map[string]string{})) } createPod("128.0.0.1", "pod1") assert.Equal(t, c.pods.getPodKeys("128.0.0.1"), []types.NamespacedName{{Name: "pod1", Namespace: "ns"}}) events.WaitOrdered("pod1/add", "pod1/update") createPod("128.0.0.1", "pod2")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 18:27:40 UTC 2024 - 12.3K bytes - Viewed (0) -
pkg/volume/util/recyclerclient/recycler_client.go
if err != nil { klog.V(4).Infof("cannot start watcher for pod %s/%s: %v", pod.Namespace, pod.Name, err) return err } // Start the pod _, err = recyclerClient.CreatePod(pod) if err != nil { if errors.IsAlreadyExists(err) { deleteErr := recyclerClient.DeletePod(pod.Name, pod.Namespace) if deleteErr != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 8.5K bytes - Viewed (0)