- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 232 for podB (0.06 sec)
-
pkg/controller/endpointslice/endpointslice_controller_test.go
} // Ensure SyncService correctly selects Pods. func TestSyncServicePodSelection(t *testing.T) { client, esController := newController(t, []string{"node-1"}, time.Duration(0)) ns := metav1.NamespaceDefault pod1 := newPod(1, ns, true, 0, false) esController.podStore.Add(pod1) // ensure this pod will not match the selector pod2 := newPod(2, ns, true, 0, false) pod2.Labels["foo"] = "boo"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 65.5K bytes - Viewed (0) -
pkg/kubelet/util/manager/cache_based_manager_test.go
store.AddReference("ns1", "name1", "pod1") store.AddReference("ns2", "name2", "pod2") store.AddReference("ns1", "name1", "pod3") store.AddReference("ns1", "name1", "pod4") store.DeleteReference("ns1", "name1", "pod1") store.DeleteReference("ns2", "name2", "pod2") store.AddReference("ns3", "name3", "pod5") // Adds don't issue Get requests. actions := fakeClient.Actions()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 19.6K bytes - Viewed (0) -
pkg/scheduler/schedule_one_test.go
ForgetFunc: func(pod *v1.Pod) { gotForgetPod = pod }, AssumeFunc: func(pod *v1.Pod) { gotAssumedPod = pod }, IsAssumedPodFunc: func(pod *v1.Pod) bool { if pod == nil || gotAssumedPod == nil { return false } return pod.UID == gotAssumedPod.UID }, } client := clientsetfake.NewSimpleClientset(item.sendPod)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:20:55 UTC 2024 - 128.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go
Namespace: "ns", ResourceVersion: rv, }, } } pod1 := makePod("pod", "1001") pod2 := makePod("pod", "1002") pod3 := makePod("pod", "1003") cacher.watchCache.Add(pod1) cacher.watchCache.Update(pod2) cacher.watchCache.Delete(pod3) // At this point, we already have dispatchedEvents fully propagated. verifyEvents := func(w watch.Interface) { var event watch.Event
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 82.9K bytes - Viewed (0) -
pkg/controller/job/job_controller_test.go
Failed: []types.UID{"a", "b"}, }, }, }, pods: func() []*v1.Pod { pods := make([]*v1.Pod, 500) for i := range pods { pods[i] = buildPod().uid(strconv.Itoa(i)).phase(v1.PodSucceeded).trackingFinalizer().Pod } pods = append(pods, buildPod().uid("b").phase(v1.PodFailed).trackingFinalizer().Pod) return pods }(), wantRmFinalizers: 499,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 15:36:36 UTC 2024 - 229.2K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue_test.go
t.Errorf("Unexpected diff after adding pods (-want, +got):\n%s", diff) } if p, err := q.Pop(logger); err != nil || p.Pod != highPriorityPodInfo.Pod { t.Errorf("Expected: %v after Pop, but got: %v", highPriorityPodInfo.Pod.Name, p.Pod.Name) } if p, err := q.Pop(logger); err != nil || p.Pod != medPriorityPodInfo.Pod { t.Errorf("Expected: %v after Pop, but got: %v", medPriorityPodInfo.Pod.Name, p.Pod.Name) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 146.9K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/noderesources/fit_test.go
}) } return &v1.Pod{ Spec: v1.PodSpec{ Containers: containers, }, } } func newResourceInitPod(pod *v1.Pod, usage ...framework.Resource) *v1.Pod { pod.Spec.InitContainers = newResourcePod(usage...).Spec.Containers return pod } func newResourceOverheadPod(pod *v1.Pod, overhead v1.ResourceList) *v1.Pod { pod.Spec.Overhead = overhead return pod }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 57.4K bytes - Viewed (0) -
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) -
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) -
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)