test

Netcracker · Jan 29, 2024 · 8ffb988 · 8ffb988
1 parent 6d9db83
commit 8ffb988
Showing 1 changed file with 79 additions and 0 deletions.
diff --git a/kubemarine/procedures/install.py b/kubemarine/procedures/install.py
@@ -519,6 +519,84 @@ def overview(cluster: KubernetesCluster) -> None:
     control_plane.sudo("kubectl cluster-info", hide=False, warn=True)
 
 
+def test(cluster: KubernetesCluster):
+    # config_new = kubernetes.get_kubeadm_config(cluster.inventory)
+    #
+    # control_plane = cluster.nodes['control-plane'].get_first_member()
+    # control_plane.put(io.StringIO(config_new), '/etc/kubernetes/test-config.yaml', sudo=True)
+    #
+    # control_plane.sudo('kubeadm init phase upload-config kubeadm --config /etc/kubernetes/test-config.yaml')
+
+    for node in cluster.make_group_from_roles(['control-plane', 'worker']).get_ordered_members_list():
+        kubernetes.create_kubeadm_patches_for_node(cluster, node)
+
+    for node in cluster.nodes['control-plane'].get_ordered_members_list():
+        # we need InitConfiguration in audit-on-config.yaml file to take into account kubeadm patch for apiserver
+        init_config = {
+            'apiVersion': cluster.inventory["services"]["kubeadm"]['apiVersion'],
+            'kind': 'InitConfiguration',
+            'localAPIEndpoint': {
+                'advertiseAddress': node.get_config()['internal_address']
+            },
+            'patches': {
+                'directory': '/etc/kubernetes/patches'
+            }
+        }
+
+        config = node.sudo('kubectl get cm -n kube-system kubeadm-config -o=jsonpath="{.data.ClusterConfiguration}"').get_simple_out()
+        # config = kubernetes.get_kubeadm_config(cluster.inventory)
+        config = f'{yaml.dump(init_config)}---\n{config}'
+        node.put(io.StringIO(config), '/etc/kubernetes/test-config.yaml', sudo=True)
+
+        # node.sudo('kubectl get cm -n kube-system kubeadm-config -o=jsonpath="{.data.ClusterConfiguration}" | sudo tee /etc/kubernetes/test-config.yaml > /dev/null' hide=False)
+        node.sudo('kubeadm init phase control-plane apiserver --config /etc/kubernetes/test-config.yaml', hide=False)
+
+        # # force kube-apiserver pod restart, then wait for api to become available
+        # if cluster.inventory['services']['cri']['containerRuntime'] == 'containerd':
+        #     node.call(utils.wait_command_successful, command="crictl rm -f $(sudo crictl ps --name kube-apiserver -q)")
+        # else:
+        #     node.call(utils.wait_command_successful, command="docker stop "
+        #                                                      "$(sudo docker ps -f 'name=k8s_kube-apiserver'"
+        #                                                      " | awk '{print $1}')")
+        # node.call(utils.wait_command_successful, command="kubectl get pod -n kube-system")
+
+
+def test2(cluster: KubernetesCluster):
+    for node in cluster.nodes['control-plane'].get_ordered_members_list():
+        # we need InitConfiguration in audit-on-config.yaml file to take into account kubeadm patch for apiserver
+        init_config = {
+            'apiVersion': cluster.inventory["services"]["kubeadm"]['apiVersion'],
+            'kind': 'InitConfiguration',
+            'localAPIEndpoint': {
+                'advertiseAddress': node.get_config()['internal_address']
+            },
+            'patches': {
+                'directory': '/etc/kubernetes/patches'
+            }
+        }
+
+        # config = node.sudo(
+        #     'kubectl get cm -n kube-system kubeadm-config -o=jsonpath="{.data.ClusterConfiguration}"').get_simple_out()
+
+
+        config = kubernetes.get_kubeadm_config(cluster.inventory)
+        config = f'{yaml.dump(init_config)}---\n{config}'
+        node.put(io.StringIO(config), '/etc/kubernetes/test-config.yaml', sudo=True)
+
+        node.sudo('rm /etc/kubernetes/pki/apiserver.*')
+        node.sudo('kubeadm init phase certs apiserver --config /etc/kubernetes/test-config.yaml', hide=False)
+
+        # # force kube-apiserver pod restart, then wait for api to become available
+        # if cluster.inventory['services']['cri']['containerRuntime'] == 'containerd':
+        #     node.call(utils.wait_command_successful, command="crictl rm -f $(sudo crictl ps --name kube-apiserver -q)")
+        # else:
+        #     node.call(utils.wait_command_successful, command="docker stop "
+        #                                                      "$(sudo docker ps -f 'name=k8s_kube-apiserver'"
+        #                                                      " | awk '{print $1}')")
+        # node.call(utils.wait_command_successful, command="kubectl get pod -n kube-system")
+
+
+
 tasks = OrderedDict({
     "prepare": {
         "check": {
@@ -574,6 +652,7 @@ def overview(cluster: KubernetesCluster) -> None:
             "prepull_images": deploy_kubernetes_prepull_images,
             "init": deploy_kubernetes_init,
             "audit": deploy_kubernetes_audit,
+            # "test": test2,
         },
         "admission": admission.install,
         "coredns": deploy_coredns,