(ctx context.Context, errorCh chan error, ng *api.ManagedNodeGroup, forceAddCNIPolicy bool, vpcImporter vpc.Importer)
| 177 | } |
| 178 | |
| 179 | func (c *StackCollection) createManagedNodeGroupTask(ctx context.Context, errorCh chan error, ng *api.ManagedNodeGroup, forceAddCNIPolicy bool, vpcImporter vpc.Importer) error { |
| 180 | name := c.makeNodeGroupStackName(ng.Name) |
| 181 | cluster, err := c.DescribeClusterStackIfExists(ctx) |
| 182 | if err != nil { |
| 183 | return err |
| 184 | } |
| 185 | if cluster == nil && c.spec.IPv6Enabled() { |
| 186 | return errors.New("managed nodegroups cannot be created on IPv6 unowned clusters") |
| 187 | } |
| 188 | logger.Info("building managed nodegroup stack %q", name) |
| 189 | bootstrapper, err := nodebootstrap.NewManagedBootstrapper(c.spec, ng) |
| 190 | if err != nil { |
| 191 | return err |
| 192 | } |
| 193 | stack := builder.NewManagedNodeGroup(c.ec2API, c.spec, ng, builder.NewLaunchTemplateFetcher(c.ec2API), bootstrapper, forceAddCNIPolicy, vpcImporter) |
| 194 | if err := stack.AddAllResources(ctx); err != nil { |
| 195 | return err |
| 196 | } |
| 197 | |
| 198 | return c.CreateStack(ctx, name, stack, ng.Tags, nil, errorCh) |
| 199 | } |
| 200 | |
| 201 | func (c *StackCollection) propagateManagedNodeGroupTagsToASGTask(ctx context.Context, errorCh chan error, ng *api.ManagedNodeGroup, |
| 202 | propagateFunc func(string, map[string]string, []string, chan error) error) error { |
no test coverage detected