Support CDW DBC and VW creation

Signed-off-by: Saravanan Raju <saravanan.footloose@gmail.com>

Author: raju-saravanan

plugins/modules/dw_cluster.py

@@ -47,6 +47,16 @@
     aliases:
       - environment
       - env_crn
+  overlay:
+    description: Set it to true to save IP addresses in the VPC by using a private IP address range for Pods in the cluster.
+    type: bool
+    required: False
+    default: False    
+  private_load_balancer:
+    description: Set up load balancer in private subnets.
+    type: bool
+    required: False
+    default: False    
   aws_public_subnets:
     description: List of zero or more Public AWS Subnet IDs to deploy to
     type: list
@@ -131,7 +141,7 @@
   elements: complex
   contains:
     cluster:
-      tyoe: dict
+      type: dict
       contains:
         name:
           description: The name of the cluster.
@@ -194,6 +204,7 @@ def __init__(self, module):
         self.name = self._get_param('name')
         self.env = self._get_param('env')
         self.overlay = self._get_param('overlay')
+        self.private_load_balancer = self._get_param('private_load_balancer')
         self.az_subnet = self._get_param('az_subnet')
         self.az_enable_az = self._get_param('az_enable_az')
         self.aws_public_subnets = self._get_param('aws_public_subnets')
@@ -281,9 +292,9 @@ def process(self):
                         self.module.fail_json(msg="Could not retrieve CRN for CDP Environment %s" % self.env)
                     else:
                         self.name = self.cdpy.dw.create_cluster(
-                            env_crn=env_crn, overlay=self.overlay, aws_public_subnets=self.aws_public_subnets,
-                            aws_private_subnets=self.aws_private_subnets, az_subnet=self.az_subnet,
-                            az_enable_az=self.az_enable_az
+                            env_crn=env_crn, overlay=self.overlay, private_load_balancer=self.private_load_balancer,
+                            aws_public_subnets=self.aws_public_subnets, aws_private_subnets=self.aws_private_subnets,
+                            az_subnet=self.az_subnet, az_enable_az=self.az_enable_az
                         )
                         if self.wait:
                             self.target = self.cdpy.sdk.wait_for_state(
@@ -304,6 +315,7 @@ def main():
             name=dict(required=False, type='str', aliases=['id']),
             env=dict(required=False, type='str', aliases=['environment', 'env_crn']),
             overlay=dict(required=False, type='bool', default=False),
+            private_load_balancer=dict(required=False, type='bool', default=False),
             az_subnet=dict(required=False, type='str', default=None),
             az_enable_az=dict(required=False, type='bool', default=None),
             aws_public_subnets=dict(required=False, type='list', default=None),

plugins/modules/dw_dbc.py

@@ -0,0 +1,178 @@
+#!/usr/bin/env python
+# -*- coding: utf-8 -*-
+
+# Copyright 2021 Cloudera, Inc. All Rights Reserved.
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#      http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+from ansible.module_utils.basic import AnsibleModule
+from ansible_collections.cloudera.cloud.plugins.module_utils.cdp_common import CdpModule
+
+ANSIBLE_METADATA = {'metadata_version': '1.1',
+                    'status': ['preview'],
+                    'supported_by': 'community'}
+
+DOCUMENTATION = r'''
+---
+module: dw_dbc
+short_description: Create CDP Database Catalog
+description:
+    - Create CDP Database Catalog
+author:
+  - "Webster Mudge (@wmudge)"
+  - "Dan Chaffelson (@chaffelson)"
+requirements:
+  - cdpy
+options:
+  cluster_id:
+    description: ID of cluster where Database Catalog should be created.
+    type: str
+    required: True
+  name:
+    description: Name of the Database Catalog.
+    type: str
+    required: True
+  load_demo_data:
+    description: Set this to true if you demo data should be loaded into the Database Catalog.
+    type: str
+    required: False
+  wait:
+    description:
+      - Flag to enable internal polling to wait for the Data Catalog to achieve the declared state.
+      - If set to FALSE, the module will return immediately.
+    type: bool
+    required: False
+    default: True
+  delay:
+    description:
+      - The internal polling interval (in seconds) while the module waits for the Data Catalog to achieve the declared
+        state.
+    type: int
+    required: False
+    default: 15
+    aliases:
+      - polling_delay
+  timeout:
+    description:
+      - The internal polling timeout (in seconds) while the module waits for the Data Catalog to achieve the declared
+        state.
+    type: int
+    required: False
+    default: 3600
+    aliases:
+      - polling_timeout  
+extends_documentation_fragment:
+  - cloudera.cloud.cdp_sdk_options
+  - cloudera.cloud.cdp_auth_options
+'''
+
+EXAMPLES = r'''
+# Note: These examples do not set authentication details.
+
+# Create Database Catalog
+- cloudera.cloud.dw_dbc:
+    name: example-database-catalog
+    cluster_id: example-cluster-id
+'''
+
+RETURN = r'''
+---
+dbcs:
+  description: The information about the named Database Catalog.
+  type: list
+  returned: always
+  elements: complex
+  contains:
+    id:
+      description: The id of the Database Catalog.
+      returned: always
+      type: str
+    name:
+      description: The name of the Database Catalog.
+      returned: always
+      type: str
+    status:
+      description: The status of the Database Catalog.
+      returned: always
+      type: str
+sdk_out:
+  description: Returns the captured CDP SDK log.
+  returned: when supported
+  type: str
+sdk_out_lines:
+  description: Returns a list of each line of the captured CDP SDK log.
+  returned: when supported
+  type: list
+  elements: str
+'''
+
+
+class DwDbc(CdpModule):
+    def __init__(self, module):
+        super(DwDbc, self).__init__(module)
+
+        # Set variables
+        self.cluster_id = self._get_param('cluster_id')
+        self.name = self._get_param('name')
+        self.load_demo_data = self._get_param('load_demo_data')
+        self.state = self._get_param('state')
+        self.wait = self._get_param('wait')
+        self.delay = self._get_param('delay')
+        self.timeout = self._get_param('timeout')
+
+        # Initialize return values
+        self.dbcs = []
+
+        # Execute logic process
+        self.process()
+
+    @CdpModule._Decorators.process_debug
+    def process(self):
+        self.name = self.cdpy.dw.create_dbc(cluster_id=self.cluster_id, name=self.name,
+                                            load_demo_data=self.load_demo_data)
+        if self.wait:
+            self.target = self.cdpy.sdk.wait_for_state(
+                describe_func=self.cdpy.dw.describe_dbc,
+                params=dict(cluster_id=self.cluster_id, dbc_id=self.name['dbcId']),
+                state='Running', delay=self.delay, timeout=self.timeout
+            )
+        else:
+            self.target = self.cdpy.dw.describe_dbc(cluster_id=self.cluster_id, dbc_id=self.name['dbcId'])
+        self.dbcs.append(self.target)
+
+
+def main():
+    module = AnsibleModule(
+        argument_spec=CdpModule.argument_spec(
+            cluster_id=dict(required=True, type='str', aliases=['cluster_id']),
+            name = dict(required=True, type='str', aliases=['name']),
+            load_demo_data=dict(required=False, type='bool', aliases=['load_demo_data']),
+            state=dict(required=False, type='str', choices=['present', 'absent'], default='present'),
+            wait = dict(required=False, type='bool', default=True),
+            delay = dict(required=False, type='int', aliases=['polling_delay'], default=15),
+            timeout = dict(required=False, type='int', aliases=['polling_timeout'], default=3600)
+        ),
+        supports_check_mode=True
+    )
+
+    result = DwDbc(module)
+    output = dict(changed=False, dbcs=result.dbcs)
+
+    if result.debug:
+        output.update(sdk_out=result.log_out, sdk_out_lines=result.log_lines)
+
+    module.exit_json(**output)
+
+
+if __name__ == '__main__':
+    main()