Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 966 for pod6 (0.04 sec)

  1. pkg/kubelet/volumemanager/reconciler/reconstruct_test.go

    			for _, tpodInfo := range tc.podInfos {
    				pod := getInlineFakePod(tpodInfo.podName, tpodInfo.podUID, tpodInfo.outerVolumeName, tpodInfo.innerVolumeName)
    				volumeSpec := &volume.Spec{Volume: &pod.Spec.Volumes[0]}
    				podName := util.GetUniquePodName(pod)
    				volumeName, err := rcInstance.desiredStateOfWorld.AddPodToVolume(
    					podName, pod, volumeSpec, volumeSpec.Name(), "" /* volumeGidValue */, nil /* SELinuxContext */)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 14.8K bytes
    - Viewed (0)
  2. pkg/controller/statefulset/stateful_pod_control_test.go

    	pvcs := getPersistentVolumeClaims(set, pod)
    	volumes := make([]v1.Volume, 0, len(pod.Spec.Volumes))
    	for i := range pod.Spec.Volumes {
    		if _, contains := pvcs[pod.Spec.Volumes[i].Name]; !contains {
    			volumes = append(volumes, pod.Spec.Volumes[i])
    		}
    	}
    	pod.Spec.Volumes = volumes
    	fakeClient.AddReactor("update", "pods", func(action core.Action) (bool, runtime.Object, error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 05 19:06:41 UTC 2024
    - 35.5K bytes
    - Viewed (0)
  3. 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)
  4. pkg/kube/krt/index_test.go

    	pod2 := &corev1.Pod{
    		ObjectMeta: metav1.ObjectMeta{
    			Name:      "name2",
    			Namespace: "namespace",
    		},
    		Status: corev1.PodStatus{PodIP: "1.2.3.5"},
    	}
    	pc.CreateOrUpdateStatus(pod2)
    	tt.WaitUnordered("add/namespace/name2")
    	assert.Equal(t, Collection.Get(), ptr.Of("namespace/name,namespace/name2"))
    
    	pc.Delete(pod.Name, pod.Namespace)
    	pc.Delete(pod2.Name, pod2.Namespace)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 09 19:55:53 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  5. hack/testdata/pod.yaml

    apiVersion: v1
    kind: Pod
    metadata:
      name: test-pod
      labels:
        name: test-pod-label
    spec:
      containers:
      - name: kubernetes-pause
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 24 07:02:51 UTC 2024
    - 172 bytes
    - Viewed (0)
  6. pkg/config/analysis/analyzers/deployment/pod.go

    		Name:        "applicationUID.Analyzer",
    		Description: "Checks invalid application UID",
    		Inputs: []config.GroupVersionKind{
    			gvk.Pod,
    			gvk.Deployment,
    		},
    	}
    }
    
    func (appUID *ApplicationUIDAnalyzer) Analyze(context analysis.Context) {
    	context.ForEach(gvk.Pod, func(resource *resource.Instance) bool {
    		appUID.analyzeAppUIDForPod(resource, context)
    		return true
    	})
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Mar 01 01:34:15 UTC 2023
    - 3.2K bytes
    - Viewed (0)
  7. 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)
  8. src/internal/coverage/pods/pods.go

    		}
    		for _, e := range p.elements {
    			pod.CounterDataFiles = append(pod.CounterDataFiles, e.file)
    			pod.Origins = append(pod.Origins, e.origin)
    			pod.ProcessIDs = append(pod.ProcessIDs, e.pid)
    		}
    		pods = append(pods, pod)
    	}
    	slices.SortFunc(pods, func(a, b Pod) int {
    		return strings.Compare(a.MetaFile, b.MetaFile)
    	})
    	return pods
    }
    
    func warning(s string, a ...interface{}) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  9. pkg/kubelet/userns/userns_manager_switch_test.go

    	pods := []types.UID{"pod-1", "pod-2"}
    
    	testUserNsPodsManager := &testUserNsPodsManager{
    		podDir: t.TempDir(),
    		// List the same pods we will record, so the second time we create the userns
    		// manager, it will find these pods on disk with userns data.
    		podList: pods,
    	}
    	m, err := MakeUserNsManager(testUserNsPodsManager)
    	require.NoError(t, err)
    
    	// Record the pods on disk.
    	for _, podUID := range pods {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 5K bytes
    - Viewed (0)
  10. 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)
Back to top