NewUnmanagedNodeGroupTask returns tasks for creating self-managed nodegroups.
(ctx context.Context, nodeGroups []*api.NodeGroup, forceAddCNIPolicy, skipEgressRules, disableAccessEntryCreation bool, vpcImporter vpc.Importer, parallelism int)
| 74 | |
| 75 | // NewUnmanagedNodeGroupTask returns tasks for creating self-managed nodegroups. |
| 76 | func (c *StackCollection) NewUnmanagedNodeGroupTask(ctx context.Context, nodeGroups []*api.NodeGroup, forceAddCNIPolicy, skipEgressRules, disableAccessEntryCreation bool, vpcImporter vpc.Importer, parallelism int) *tasks.TaskTree { |
| 77 | task := &UnmanagedNodeGroupTask{ |
| 78 | ClusterConfig: c.spec, |
| 79 | NodeGroups: nodeGroups, |
| 80 | CreateNodeGroupResourceSet: func(options builder.NodeGroupOptions) NodeGroupResourceSet { |
| 81 | return builder.NewNodeGroupResourceSet(c.ec2API, c.iamAPI, options) |
| 82 | }, |
| 83 | NewBootstrapper: func(clusterConfig *api.ClusterConfig, ng *api.NodeGroup) (nodebootstrap.Bootstrapper, error) { |
| 84 | return nodebootstrap.NewBootstrapper(clusterConfig, ng) |
| 85 | }, |
| 86 | EKSAPI: c.eksAPI, |
| 87 | StackManager: c, |
| 88 | } |
| 89 | return task.Create(ctx, CreateNodeGroupOptions{ |
| 90 | ForceAddCNIPolicy: forceAddCNIPolicy, |
| 91 | SkipEgressRules: skipEgressRules, |
| 92 | DisableAccessEntryCreation: disableAccessEntryCreation, |
| 93 | VPCImporter: vpcImporter, |
| 94 | Parallelism: parallelism, |
| 95 | }) |
| 96 | } |
| 97 | |
| 98 | // NewManagedNodeGroupTask defines tasks required to create managed nodegroups |
| 99 | func (c *StackCollection) NewManagedNodeGroupTask(ctx context.Context, nodeGroups []*api.ManagedNodeGroup, forceAddCNIPolicy bool, vpcImporter vpc.Importer, nodeGroupParallelism int) *tasks.TaskTree { |
no test coverage detected