func()

in pkg/provider/eks/eks.go [468:485]


func (c *EKS) AllNodeGroupsRunning(*kingpin.ParseContext) error {
	req := &eksCluster{}
	for _, deployment := range c.eksResources {
		if err := yamlGo.UnmarshalStrict(deployment.Content, req); err != nil {
			return fmt.Errorf("Error parsing the cluster deployment file %s:%v", deployment.FileName, err)
		}
		for _, nodegroup := range req.NodeGroups {
			isRunning, err := c.nodeGroupCreated(*nodegroup.NodegroupName, *req.Cluster.Name)
			if err != nil {
				return fmt.Errorf("error fetching nodegroup info")
			}
			if !isRunning {
				return fmt.Errorf("nodepool not running name: %v", *nodegroup.NodegroupName)
			}
		}
	}
	return nil
}