- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 1,010 for nodev1 (0.48 sec)
-
pkg/controller/tainteviction/taint_eviction_test.go
testCases := []struct { description string pods []corev1.Pod prevPod *corev1.Pod newPod *corev1.Pod oldNode *corev1.Node newNode *corev1.Node expectPatch bool expectDelete bool }{ { description: "existing pod2 scheduled onto tainted Node", pods: []corev1.Pod{ *testutil.NewPod("pod1", "node1"), }, prevPod: testutil.NewPod("pod2", ""),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 14:24:16 UTC 2024 - 31.3K bytes - Viewed (0) -
pkg/util/node/node.go
} err := wait.ExponentialBackoff(backoff, func() (bool, error) { node, err := client.CoreV1().Nodes().Get(context.TODO(), name, metav1.GetOptions{}) if err != nil { klog.Errorf("Failed to retrieve node info: %v", err) return false, nil } nodeIP, err = GetNodeHostIP(node) if err != nil { klog.Errorf("Failed to retrieve node IP: %v", err) return false, err } return true, nil })
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 27 23:24:38 UTC 2023 - 4.8K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/volumebinding/binder_test.go
// nodes objects node1 = makeNode("node1").withLabel(nodeLabelKey, "node1").Node node2 = makeNode("node2").withLabel(nodeLabelKey, "node2").Node node1NoLabels = makeNode("node1").Node node1Zone1 = makeNode("node1").withLabel("topology.gke.io/zone", "us-east-1").Node node1Zone2 = makeNode("node1").withLabel("topology.gke.io/zone", "us-east-2").Node // csiNode objects
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 09:46:58 UTC 2024 - 82.8K bytes - Viewed (0) -
pilot/pkg/controllers/untaint/nodeuntainter_test.go
t.Helper() for _, node := range nodes { node := generateNode(node, nil) // add our special taint node.Spec.Taints = append(node.Spec.Taints, corev1.Taint{ Key: TaintName, Value: "true", Effect: corev1.TaintEffectNoSchedule, }) s.nc.Create(node) } } func (s *nodeTainterTestServer) addCniPod(t *testing.T, node string, markReady bool) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Apr 13 00:50:31 UTC 2024 - 6.1K bytes - Viewed (0) -
plugin/pkg/auth/authorizer/node/graph_test.go
Volumes: []corev1.Volume{ {Name: "volume1", VolumeSource: corev1.VolumeSource{ConfigMap: &corev1.ConfigMapVolumeSource{LocalObjectReference: corev1.LocalObjectReference{Name: "cm1"}}}}, {Name: "volume2", VolumeSource: corev1.VolumeSource{ConfigMap: &corev1.ConfigMapVolumeSource{LocalObjectReference: corev1.LocalObjectReference{Name: "cm2"}}}},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 23 23:14:19 UTC 2022 - 12.3K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller_test.go
name string pods []*corev1.Pod nodes []*corev1.Node wantAZ map[*corev1.Pod]string }{ { name: "should return correct az for given address", pods: []*corev1.Pod{pod1, pod2}, nodes: []*corev1.Node{ generateNode("node1", map[string]string{NodeZoneLabel: "zone1", NodeRegionLabel: "region1", label.TopologySubzone.Name: "subzone1"}),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 85K bytes - Viewed (0) -
pkg/scheduler/testing/framework/fake_extender.go
// when the given node's name is "node1"; otherwise return false. func Node1PredicateExtender(pod *v1.Pod, node *framework.NodeInfo) *framework.Status { if node.Node().Name == "node1" { return framework.NewStatus(framework.Success) } return framework.NewStatus(framework.Unschedulable, fmt.Sprintf("node %q is not allowed", node.Node().Name)) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 19:07:19 UTC 2024 - 13.9K bytes - Viewed (0) -
tensorflow/compiler/jit/cluster_scoping_pass.cc
// ensures Node_X and Node_Y are put into different clusters. Without the // heuristic, they may be put into the same cluster and it can introduce // artificial dependencies and incur great performance loss. In this example, // Node_Y becomes dependent on IteratorGetNext and the latencies add up if // Node_X and Node_Y are in the same cluster. // // IteratorGetNext -> Node_X -> Stage // // Unstage -> Node_Y
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Feb 22 08:47:20 UTC 2024 - 5.7K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/network_test.go
clienttest.Wrap(t, c.services).Create(&corev1.Service{ ObjectMeta: metav1.ObjectMeta{Name: "istio-meshnetworks-gw", Namespace: "istio-system"}, Spec: corev1.ServiceSpec{ Type: corev1.ServiceTypeLoadBalancer, Ports: []corev1.ServicePort{{Port: 15443, Protocol: corev1.ProtocolTCP}}, }, Status: corev1.ServiceStatus{LoadBalancer: corev1.LoadBalancerStatus{Ingress: []corev1.LoadBalancerIngress{{ IP: "1.2.3.4",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 18 19:09:43 UTC 2024 - 10.7K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex_serviceentry_test.go
ClusterId: testC, Node: "node1", CanonicalName: "a", CanonicalRevision: "latest", ServiceAccount: "sa1", WorkloadType: workloadapi.WorkloadType_POD, WorkloadName: "pod1", }, }, }, }}) s.addPods(t, "140.140.0.11", "pod2", "sa1", map[string]string{"app": "other"}, nil, true, corev1.PodRunning) s.assertEvent(t, s.podXdsName("pod2"))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 27 03:01:04 UTC 2024 - 12.9K bytes - Viewed (0)