kubernetes
/
kops
mirror of https://github.com/kubernetes/kops.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Set lifecycle on WarmPool task

This commit is contained in:
John Gardiner Myers 2021-05-28 00:04:24 -07:00
parent 26309f0016
commit 024b3653c0
3 changed files with 15 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
cloudmock/aws/mockautoscaling/warmpool.go
View File

@ -28,3 +28,7 @@ func (m *MockAutoscaling) DescribeWarmPool(input *autoscaling.DescribeWarmPoolIn
} }
return ret, nil return ret, nil
} }
func (m *MockAutoscaling) DeleteWarmPool(*autoscaling.DeleteWarmPoolInput) (*autoscaling.DeleteWarmPoolOutput, error) {
return &autoscaling.DeleteWarmPoolOutput{}, nil
}

1
pkg/model/awsmodel/autoscalinggroup.go
View File

@ -91,6 +91,7 @@ func (b *AutoscalingGroupModelBuilder) Build(c *fi.ModelBuilderContext) error {
enabled := fi.Bool(warmPool.IsEnabled()) enabled := fi.Bool(warmPool.IsEnabled())
warmPoolTask := &awstasks.WarmPool{ warmPoolTask := &awstasks.WarmPool{
Name: &name, Name: &name,
Lifecycle: b.Lifecycle,
Enabled: enabled, Enabled: enabled,
} }
if warmPool.IsEnabled() { if warmPool.IsEnabled() {

2
upup/pkg/fi/cloudup/awstasks/warmpool.go
View File

@ -60,12 +60,14 @@ func (e *WarmPool) Find(c *fi.Context) (*WarmPool, error) {
if warmPool.WarmPoolConfiguration == nil { if warmPool.WarmPoolConfiguration == nil {
return &WarmPool{ return &WarmPool{
Name: e.Name, Name: e.Name,
Lifecycle: e.Lifecycle,
Enabled: fi.Bool(false), Enabled: fi.Bool(false),
}, nil }, nil
} }
actual := &WarmPool{ actual := &WarmPool{
Name: e.Name, Name: e.Name,
Lifecycle: e.Lifecycle,
Enabled: fi.Bool(true), Enabled: fi.Bool(true),
MaxSize: warmPool.WarmPoolConfiguration.MaxGroupPreparedCapacity, MaxSize: warmPool.WarmPoolConfiguration.MaxGroupPreparedCapacity,
MinSize: fi.Int64Value(warmPool.WarmPoolConfiguration.MinSize), MinSize: fi.Int64Value(warmPool.WarmPoolConfiguration.MinSize),