- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 767 for pod9 (0.99 sec)
-
pkg/controller/deployment/deployment_controller_test.go
rs2 := newReplicaSet(d, "rs2", 1) // Add a Pod for each ReplicaSet. pod1 := generatePodFromRS(rs1) pod2 := generatePodFromRS(rs2) // Add a Pod that has matching labels, but no ControllerRef. pod3 := generatePodFromRS(rs1) pod3.Name = "pod3" pod3.OwnerReferences = nil // Add a Pod that has matching labels and ControllerRef, but is inactive. pod4 := generatePodFromRS(rs1) pod4.Name = "pod4" pod4.Status.Phase = v1.PodFailed
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.5K bytes - Viewed (0) -
pkg/controller/daemon/update_test.go
return ds }(), nodeToPods: func() map[string][]*v1.Pod { mapping := make(map[string][]*v1.Pod) pod0 := newPod("pod-0", "node-0", simpleDaemonSetLabel, nil) pod1 := newPod("pod-1", "node-1", simpleDaemonSetLabel, nil) markPodReady(pod0) markPodReady(pod1) mapping["node-0"] = []*v1.Pod{pod0} mapping["node-1"] = []*v1.Pod{pod1} return mapping }(), maxUnavailable: 1,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Feb 10 21:10:35 UTC 2024 - 28.9K 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) -
pilot/pkg/serviceregistry/kube/controller/controller_test.go
}, wantAZ: map[*corev1.Pod]string{ pod1: "region1/zone1/", pod2: "region2/zone2/", }, }, { name: "should return false if pod isn't in the cache", wantAZ: map[*corev1.Pod]string{ pod1: "", pod2: "", }, }, { name: "should return false if node isn't in the cache", pods: []*corev1.Pod{pod1, pod2}, wantAZ: map[*corev1.Pod]string{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 85K bytes - Viewed (0) -
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) -
pilot/pkg/serviceregistry/kube/controller/pod_test.go
createPod("128.0.0.2", "pod") assert.Equal(t, c.pods.getPodKeys("128.0.0.2"), []types.NamespacedName{{Name: "pod", Namespace: "ns"}}) assert.Equal(t, c.pods.getPodKeys("128.0.0.1"), nil) // A new pod is created with the old IP. We should get new-pod, not pod createPod("128.0.0.1", "new-pod") assert.Equal(t, c.pods.getPodKeys("128.0.0.1"), []types.NamespacedName{{Name: "new-pod", Namespace: "ns"}})
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/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) -
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) -
pkg/kubelet/volumemanager/cache/actual_state_of_world_test.go
// Call MarkVolumeAsDetached() on a volume which mounted by pod(s) should be skipped func Test_MarkVolumeAsDetached_Negative_PodInVolume(t *testing.T) { // Arrange volumePluginMgr, plugin := volumetesting.GetTestVolumePluginMgr(t) devicePath := "fake/device/path" asw := NewActualStateOfWorld("mynode", volumePluginMgr) pod := &v1.Pod{ ObjectMeta: metav1.ObjectMeta{ Name: "pod1", UID: "pod1uid", }, Spec: v1.PodSpec{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 46.3K bytes - Viewed (0) -
pkg/scheduler/util/utils.go
func GetPodFullName(pod *v1.Pod) string { // Use underscore as the delimiter because it is not allowed in pod name // (DNS subdomain format). return pod.Name + "_" + pod.Namespace } // GetPodStartTime returns start time of the given pod or current timestamp // if it hasn't started yet. func GetPodStartTime(pod *v1.Pod) *metav1.Time { if pod.Status.StartTime != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Sep 21 01:40:44 UTC 2023 - 6.2K bytes - Viewed (0)