Merge branch 'master' of https://github.com/hpe-container-platform-community/hpecp-python-library

Author: snowch

hpecp/__init__.py

@@ -35,4 +35,4 @@
 )
 from .logger import Logger
 
-__version__ = "0.10.5"
+__version__ = "0.10.6"

hpecp/cli/datatap.py

@@ -58,20 +58,19 @@ def examples(self):
     def create_hdfs_with_kerberos(
         self,
         name,
-        description,
-        path_from_endpoint,
-        kdc_data_host,
-        kdc_data_port,
-        realm,
-        client_principal,
-        browse_only,
-        host,
-        service_id,
-        backup_host,
-        endpoint_type,
-        endpoint_port,
-        read_only,
+        description="",
+        path_from_endpoint="",
+        kdc_data_host="",
+        kdc_data_port="",
+        realm="",
+        client_principal="",
+        browse_only=True,
+        host="",
         keytab="",
+        backup_host="",
+        type="",
+        port="",
+        read_only=False,
     ):
         """TODO.
 
@@ -108,7 +107,7 @@ def create_hdfs_with_kerberos(
         read_only : [type]
             [description]
         """
-        base.get_client().datatap.create(
+        base.get_client().datatap.create_hdfs_with_kerberos(
             name,
             description,
             path_from_endpoint,
@@ -119,9 +118,8 @@ def create_hdfs_with_kerberos(
             browse_only,
             host,
             keytab,
-            service_id,
             backup_host,
-            endpoint_type,
-            endpoint_port,
+            type,
+            port,
             read_only,
         )

hpecp/datatap.py

@@ -124,10 +124,9 @@ def create_hdfs_with_kerberos(
         browse_only,
         host,
         keytab,
-        service_id,
         backup_host,
-        endpoint_type,
-        endpoint_port,
+        type,
+        port,
         read_only,
     ):
         """TODO.
@@ -166,22 +165,38 @@ def create_hdfs_with_kerberos(
             [description]
         """
         _data = {
-            "bdfs_root": {"path_from_endpoint": path_from_endpoint},
+            "bdfs_root": {
+                #"path_from_endpoint": path_from_endpoint
+                },
             "endpoint": {
-                "kdc_data": [{"host": kdc_data_host, "port": kdc_data_port}],
+                "kdc_data": [
+                    {
+                        "host": kdc_data_host, 
+                        #"port": kdc_data_port
+                        }
+                    ],
                 "realm": realm,
                 "client_principal": client_principal,
                 "browse_only": browse_only,
                 "host": host,
                 "keytab": keytab,
-                "service_id": service_id,
+                "service_id": "hdfs",
                 "backup_host": backup_host,
-                "type": endpoint_type,
-                "port": endpoint_port,
+                "type": type,
+                "port": str(port),
             },
             "flags": {"read_only": read_only},
             "label": {"name": name, "description": description},
         }
+        
+        if path_from_endpoint != "":
+            _data["bdfs_root"]["path_from_endpoint"] = path_from_endpoint
+
+        if kdc_data_port != "":
+            _data["endpoint"]["kdc_data"]["kdc_data_port"] = kdc_data_port
+
+        #if keytab != "":
+        #    _data["endpoint"]["keytab"] = keytab
 
         self.client._request(
             url=DatatapController.base_resource_path,