- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 104 for pod6 (0.06 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache_test.go
t.Errorf("unexpected error: %v", err) } if _, ok, _ := store.Get(pod3); ok { t.Errorf("found pod") } // Test List. store.Add(makeTestPod("pod1", 4)) store.Add(makeTestPod("pod2", 5)) store.Add(makeTestPod("pod3", 6)) { expected := map[string]storeElement{ "prefix/ns/pod1": *makeTestStoreElement(makeTestPod("pod1", 4)),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 09:20:10 UTC 2024 - 35.4K bytes - Viewed (0) -
pkg/scheduler/scheduler_test.go
}, waitSchedulingPods: []*v1.Pod{ st.MakePod().Name("pod1").UID("pod1").SchedulerName(testSchedulerProfile1).Obj(), st.MakePod().Name("pod2").UID("pod2").SchedulerName(testSchedulerProfile1).Obj(), st.MakePod().Name("pod3").UID("pod3").SchedulerName(testSchedulerProfile1).Obj(), }, expectPodNamesInWaitingPods: []string{"pod1", "pod2", "pod3"}, }, {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 42K 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/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) -
pkg/scheduler/framework/interface.go
// to a map of currently waiting pods and return status with "Wait" code. // Pod will remain waiting pod for the minimum duration returned by the Permit plugins. RunPermitPlugins(ctx context.Context, state *CycleState, pod *v1.Pod, nodeName string) *Status // WaitOnPermit will block, if the pod is a waiting pod, until the waiting pod is rejected or allowed.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 15:52:16 UTC 2024 - 35.4K bytes - Viewed (0) -
staging/src/k8s.io/api/batch/v1/types.go
// an actual pod condition type. type PodFailurePolicyOnPodConditionsPattern struct { // Specifies the required Pod condition type. To match a pod condition // it is required that specified type equals the pod condition type. Type corev1.PodConditionType `json:"type" protobuf:"bytes,1,req,name=type"` // Specifies the required Pod condition status. To match a pod condition
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 18:37:07 UTC 2024 - 40.6K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/pod.go
func (pc *PodCache) getPodByProxy(proxy *model.Proxy) *v1.Pod { var pod *v1.Pod key := podKeyByProxy(proxy) if key.Name != "" { pod = pc.getPodByKey(key) if pod != nil { return pod } } // only need to fetch the corresponding pod through the first IP, although there are multiple IP scenarios, // because multiple ips belong to the same pod proxyIP := proxy.IPAddresses[0]
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 10.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/rest_test.go
patchBytes: []byte(test.patch), } jp := jsonPatcher{patcher: p} codec := codecs.LegacyCodec(examplev1.SchemeGroupVersion) pod := &examplev1.Pod{} pod.Name = "podA" pod.ObjectMeta.Finalizers = []string{"foo"} versionedJS, err := runtime.Encode(codec, pod) if err != nil { t.Errorf("%s: unexpected error: %v", test.name, err) continue } _, _, err = jp.applyJSPatch(versionedJS)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 28 08:48:22 UTC 2024 - 41.8K bytes - Viewed (0)