Feature change nodegroup inventory (#259)

Author: mauricioobgo

data-collection/deploy/deploy-in-linked-account.yaml

@@ -238,6 +238,8 @@ Resources:
               - "elasticache:DescribeCacheClusters"
               - "eks:ListClusters"
               - "eks:DescribeCluster"
+              - "eks:ListNodegroups"
+              - "eks:DescribeNodegroup"
               - "lambda:ListFunctions"
             Resource: "*" ## Policy is used for scanning of a wide range of resources
       Roles:
@@ -341,4 +343,4 @@ Resources:
       cfn_nag:
         rules_to_suppress:
           - id: W12
-            reason: "Policy is used for scanning of a wide range of resources"
+            reason: "Policy is used for scanning of a wide range of resources"

data-collection/deploy/module-inventory.yaml

@@ -1142,15 +1142,38 @@ Resources:
                       )
                       .search("clusters")
                   ):
+                      # Get cluster details
                       cluster = client.describe_cluster(name=cluster_name)
-                      yield {
+                      cluster_data = {
                           "Arn": cluster["cluster"]["arn"],
                           "Name": cluster["cluster"]["name"],
                           "CreatedAt": datetime.strftime(
                               cluster["cluster"]["createdAt"].astimezone(tz=timezone.utc), "%Y-%m-%dT%H:%M:%SZ"
                           ),
                           "Version": cluster["cluster"]["version"],
                       }
+                      # Get node groups for the cluster
+                      try:
+                          node_groups = client.list_nodegroups(clusterName=cluster_name).get("nodegroups", [])
+                          cluster_data["NodeGroups"] = []
+                          for node_group in node_groups:
+                              node_group_details = client.describe_nodegroup(clusterName=cluster_name, nodegroupName=node_group)
+                              cluster_data["NodeGroups"].append({
+                                  "NodeGroupName": node_group_details["nodegroup"].get("nodegroupName"),
+                                  "NodeRole": node_group_details["nodegroup"].get("nodeRole"),
+                                  "InstanceTypes": node_group_details["nodegroup"].get("instanceTypes",[]),
+                                  "ScalingConfig": node_group_details["nodegroup"].get("scalingConfig",{}),
+                                  "Subnets": node_group_details["nodegroup"].get("subnets",[]),
+                                  "Status": node_group_details["nodegroup"].get("status","Unknown"),
+                                  "AMIType": node_group_details["nodegroup"].get("amiType","Unknown"),
+                                  "Version": node_group_details["nodegroup"].get("version","Unknown"),
+                                  "CreatedAt": datetime.strftime(
+                                      node_group_details["nodegroup"]["createdAt"].astimezone(tz=timezone.utc), "%Y-%m-%dT%H:%M:%SZ"
+                                  ),
+                              })
+                      except Exception as ng_exc:  # Catch node group-specific issues
+                          logger.error(f"Error fetching node groups for {cluster_name} in {region}: {ng_exc}")
+                      yield cluster_data
               except Exception as exc: #pylint: disable=W0718
                   logger.error(f"Cannot get info from {account_id}/{region}: {type(exc)}-{exc}")
               return []