- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 482 for pod6 (0.08 sec)
-
staging/src/k8s.io/apimachinery/pkg/test/apis_meta_v1_unstructed_unstructure_test.go
t.Fatalf("unexpected error %v", errs) } if pod, ok := pl.Items[1].(*unstructured.Unstructured); !ok || pod.Object["kind"] != "Pod" || pod.Object["metadata"].(map[string]interface{})["name"] != "test" { t.Errorf("object not converted: %#v", pl.Items[1]) } if pod, ok := pl.Items[2].(*unstructured.Unstructured); !ok || pod.Object["kind"] != "Pod" || pod.Object["metadata"].(map[string]interface{})["name"] != "test" {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 05 20:12:50 UTC 2022 - 17.3K bytes - Viewed (0) -
cni/pkg/nodeagent/net_test.go
err := netServer.syncHostIPSets([]*corev1.Pod{pod}) assert.NoError(t, err) fakeIPSetDeps.AssertExpectations(t) } func TestSyncHostIPSetsIgnoresPodIPAddErrorAndContinues(t *testing.T) { pod1 := buildConvincingPod(false) pod2 := buildConvincingPod(false) pod2.ObjectMeta.SetUID("4455") fakeIPSetDeps := ipset.FakeNLDeps() var pod1UID string = string(pod1.ObjectMeta.UID)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 05:10:23 UTC 2024 - 17.8K bytes - Viewed (0) -
staging/src/k8s.io/client-go/applyconfigurations/core/v1/pod.go
} func extractPod(pod *apicorev1.Pod, fieldManager string, subresource string) (*PodApplyConfiguration, error) { b := &PodApplyConfiguration{} err := managedfields.ExtractInto(pod, internal.Parser().Type("io.k8s.api.core.v1.Pod"), fieldManager, b, subresource) if err != nil { return nil, err } b.WithName(pod.Name) b.WithNamespace(pod.Namespace) b.WithKind("Pod") b.WithAPIVersion("v1") return b, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 23 17:59:55 UTC 2022 - 11.6K bytes - Viewed (0) -
pkg/kubelet/kubelet_volumes_test.go
defer close(stopCh) kubelet.podManager.SetPods(pods) for _, pod := range pods { err := kubelet.volumeManager.WaitForAttachAndMount(context.Background(), pod) assert.NoError(t, err) } for _, pod := range pods { podVolumesExist := kubelet.podVolumesExist(pod.UID) assert.True(t, podVolumesExist, "pod %q", pod.UID) } } func TestPodVolumeDeadlineAttachAndMount(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 17 16:53:28 UTC 2023 - 20.4K bytes - Viewed (0) -
pkg/kubelet/pod/pod_manager.go
return false } return hash == getPodHash(pod) } func podsMapToPods(UIDMap map[kubetypes.ResolvedPodUID]*v1.Pod) []*v1.Pod { pods := make([]*v1.Pod, 0, len(UIDMap)) for _, pod := range UIDMap { pods = append(pods, pod) } return pods } func mirrorPodsMapToMirrorPods(UIDMap map[kubetypes.MirrorPodUID]*v1.Pod) []*v1.Pod { pods := make([]*v1.Pod, 0, len(UIDMap)) for _, pod := range UIDMap {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 06:06:00 UTC 2024 - 11.9K bytes - Viewed (0) -
pkg/scheduler/eventhandlers_test.go
if tt.oldObj.(*v1.Pod).UID != tt.newObj.(*v1.Pod).UID { if pod, err := sched.Cache.GetPod(tt.oldObj.(*v1.Pod)); err == nil { t.Errorf("Get pod UID %v from cache but it should not happen", pod.UID) } } pod, err := sched.Cache.GetPod(tt.newObj.(*v1.Pod)) if err != nil { t.Errorf("Failed to get pod from scheduler: %v", err) } if pod.UID != tt.newObj.(*v1.Pod).UID {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 10 14:38:54 UTC 2024 - 21.5K bytes - Viewed (0) -
pkg/controller/resourceclaim/controller_test.go
}, expectedMetrics: expectedMetrics{0, 0}, }, { name: "no-such-pod", key: podKey(testPodWithResource), }, { name: "pod-deleted", pods: func() []*v1.Pod { deleted := metav1.Now() pods := []*v1.Pod{testPodWithResource.DeepCopy()} pods[0].DeletionTimestamp = &deleted return pods }(), key: podKey(testPodWithResource), }, { name: "no-volumes",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 06 08:56:16 UTC 2024 - 28.2K bytes - Viewed (0) -
pkg/volume/util/nestedpendingoperations/nestedpendingoperations_test.go
} } /* Concurrent operations tests */ // "None" means volume, pod, and node names are all empty // "Volume" means volume name is set, but pod name and node name are empty // "Volume Pod" means volume and pod names are set, but the node name is empty // "Volume Node" means volume and node names are set, but the pod name is empty // The same volume, pod, and node names are used (where they are not empty). // Covered cases:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Aug 26 01:29:17 UTC 2022 - 36.1K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/network_test.go
}, retry.Timeout(time.Second*5)) } pc := clienttest.NewWriter[*corev1.Pod](t, s.client) sc := clienttest.NewWriter[*corev1.Service](t, s.client) pod1 := generatePod("127.0.0.1", "pod1", testNS, "sa1", "node1", map[string]string{"app": "a"}, nil) pc.CreateOrUpdateStatus(pod1) fx.WaitOrFail(t, "xds") pod2 := generatePod("127.0.0.2", "pod2", testNS, "sa2", "node1", map[string]string{"app": "a"}, nil)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 18 19:09:43 UTC 2024 - 10.7K bytes - Viewed (0) -
pkg/controller/job/indexed_job_utils.go
func appendPodsWithSameIndexForRemovalAndRemaining(rm, left, pods []*v1.Pod, ix int) ([]*v1.Pod, []*v1.Pod) { if ix == unknownCompletionIndex { rm = append(rm, pods...) return rm, left } if len(pods) == 1 { left = append(left, pods[0]) return rm, left } sort.Sort(controller.ActivePods(pods)) rm = append(rm, pods[:len(pods)-1]...) left = append(left, pods[len(pods)-1]) return rm, left }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 21 00:44:53 UTC 2023 - 17.5K bytes - Viewed (0)