Merge pull request #238 from hpe-container-platform-community/snowch/implement-cluster-upgrade-209

Example edit

Author: snowch

README.md

@@ -10,7 +10,7 @@
 [![Gitpod Ready-to-Code](https://img.shields.io/badge/Gitpod-ready--to--code-blue?logo=gitpod)](https://gitpod.io/#https://github.com/hpe-container-platform-community/hpecp-python-library)
 [![Good first issues open](https://img.shields.io/github/issues/hpe-container-platform-community/hpecp-python-library/good%20first%20issue.svg?label=good%20first%20issue)](https://github.com/hpe-container-platform-community/hpecp-python-library/issues?q=is%3Aissue+is%3Aopen+label%3A%22good+first+issue%22)
 
-
+   
 ----
 
 ## Documentation

hpecp/cli/k8scluster.py

@@ -290,3 +290,24 @@ def k8s_supported_versions(
             print(vers)
         else:
             print(" ".join(vers))
+
+    @base.intercept_exception
+    def upgrade_cluster(
+        self, id, k8s_upgrade_version, worker_upgrade_percent=20
+    ):
+        """Upgrade a cluster.
+
+        TODO
+
+        Returns
+        -------
+        TODO
+
+        Raises
+        ------
+        APIException
+        """
+
+        base.get_client().k8s_cluster.upgrade_cluster(
+            id, k8s_upgrade_version, worker_upgrade_percent
+        )

hpecp/k8s_cluster.py

@@ -514,3 +514,37 @@ def add_addons(self, id, addons=[]):
             description="k8s_cluster/add_addons",
             data=data,
         )
+
+    def upgrade_cluster(
+        self, id, k8s_upgrade_version, worker_upgrade_percent=20
+    ):
+        """Upgrade a cluster.
+
+        TODO
+
+        Returns
+        -------
+        TODO
+
+        Raises
+        ------
+        APIException
+        """
+        data = {
+            "change_spec": {
+                "k8s_upgrade": {
+                    "worker_upgrade_percent": worker_upgrade_percent,
+                    "k8s_upgrade_version": k8s_upgrade_version,
+                }
+            },
+            "operation": "reconfigure",
+            "reason": "Kubernetes upgrade",
+        }
+
+        response = self.client._request(
+            url="{}/change_task".format(id),
+            http_method="post",
+            description="K8sClusterController/upgrade_cluster",
+            data=data,
+        )
+        return response.json()