- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 149 for node_ (0.05 sec)
-
tests/integration/ambient/untaint/main_test.go
func taintNodes(t resource.Context) error { nodeC := t.Clusters().Default().Kube().CoreV1().Nodes() nodes, err := nodeC.List(context.TODO(), metav1.ListOptions{}) if err != nil { return err } Outer: for _, node := range nodes.Items { for _, taint := range node.Spec.Taints { if taint.Key == "cni.istio.io/not-ready" { continue Outer } } node.Spec.Taints = append(node.Spec.Taints, corev1.Taint{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 14:58:41 UTC 2024 - 3.2K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 85K bytes - Viewed (0) -
cmd/kubeadm/app/cmd/upgrade/node.go
} // Fetches the cluster configuration // NB in case of control-plane node, we are reading all the info for the node; in case of NOT control-plane node // (worker node), we are not reading local API address and the CRI socket from the node object initCfg, err := configutil.FetchInitConfigurationFromCluster(client, nil, "upgrade", !isControlPlaneNode, false) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 16 08:34:39 UTC 2024 - 10K bytes - Viewed (0) -
pkg/controller/daemon/daemon_controller_test.go
newNode: newNode("node1", nil), ds: newDaemonSet("ds"), shouldEnqueue: true, expectedCreates: func() int { return 0 }, }, { test: "Node Allocatable changed", oldNode: newNode("node1", nil), newNode: func() *v1.Node { node := newNode("node1", nil) node.Status.Allocatable = allocatableResources("200M", "200m") return node }(),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 111.4K bytes - Viewed (0) -
pkg/controller/tainteviction/taint_eviction_test.go
newNode: addTaintsToNode(testutil.NewNode("node1"), "testTaint1", "taint1", []int{1}), expectPatch: true, expectDelete: true, }, { description: "new pod2 created on tainted Node", pods: []corev1.Pod{ *testutil.NewPod("pod1", "node1"), }, prevPod: nil, newPod: testutil.NewPod("pod2", "node1"), oldNode: testutil.NewNode("node1"),
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/proxy/node.go
// OnNodeAdd is a handler for Node creates. func (n *NodeEligibleHandler) OnNodeAdd(node *v1.Node) { n.HealthServer.SyncNode(node) } // OnNodeUpdate is a handler for Node updates. func (n *NodeEligibleHandler) OnNodeUpdate(_, node *v1.Node) { n.HealthServer.SyncNode(node) } // OnNodeDelete is a handler for Node deletes. func (n *NodeEligibleHandler) OnNodeDelete(node *v1.Node) { n.HealthServer.SyncNode(node) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 3.5K bytes - Viewed (0) -
pkg/scheduler/framework/runtime/framework_test.go
t.Fatal(err) } return podInfo } // BuildNodeInfos build NodeInfo slice from a v1.Node slice func BuildNodeInfos(nodes []*v1.Node) []*framework.NodeInfo { res := make([]*framework.NodeInfo, len(nodes)) for i := 0; i < len(nodes); i++ { res[i] = framework.NewNodeInfo() res[i].SetNode(nodes[i]) } return res
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 103K bytes - Viewed (0) -
pkg/scheduler/scheduler_test.go
testSchedulerProfile2 = "test-scheduler-profile-2" testSchedulerProfile3 = "test-scheduler-profile-3" ) nodes := []runtime.Object{ st.MakeNode().Name("node1").UID("node1").Obj(), st.MakeNode().Name("node2").UID("node2").Obj(), st.MakeNode().Name("node3").UID("node3").Obj(), } cases := []struct { name string
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 42K bytes - Viewed (0) -
pkg/controller/daemon/util/daemonset_util_test.go
templateGeneration, newPod("pod1", "node1", labels), hash, true, }, { "templateGeneration matches, hash doesn't", templateGeneration, newPod("pod1", "node1", labels), hash + "123", true, }, { "templateGeneration matches, no hash label, has hash", templateGeneration, newPod("pod1", "node1", labelsNoHash), hash, true, }, {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 14.5K bytes - Viewed (0) -
tensorflow/compiler/mlir/lite/quantization/tensorflow/fallback_to_flex_ops.cc
: public PassWrapper<FallbackToFlexOps, OperationPass<func::FuncOp>> { public: FallbackToFlexOps() = default; explicit FallbackToFlexOps(const std::string &mode) { mode_ = mode; } FallbackToFlexOps(const FallbackToFlexOps &other) { mode_ = other.mode_; } void runOnOperation() override; StringRef getArgument() const final { return "quant-raise-flex-fallback"; } StringRef getDescription() const final {
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Apr 25 16:01:03 UTC 2024 - 12.2K bytes - Viewed (0)