add initial functionality

Signed-off-by: Chris Snow <[email protected]>

Author: snowch

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()