Skip to content

Commit d00d364

Browse files
M00nF1shTimothy-Dougherty
authored andcommitted
make coip drift check a warning instead of error (kubernetes-sigs#2329)
1 parent e43f546 commit d00d364

File tree

2 files changed

+10
-7
lines changed

2 files changed

+10
-7
lines changed

pkg/deploy/elbv2/load_balancer_manager.go

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,6 @@ import (
66
awssdk "github.com/aws/aws-sdk-go/aws"
77
elbv2sdk "github.com/aws/aws-sdk-go/service/elbv2"
88
"github.com/go-logr/logr"
9-
"github.com/pkg/errors"
109
"k8s.io/apimachinery/pkg/util/sets"
1110
"sigs.k8s.io/aws-load-balancer-controller/pkg/aws/services"
1211
"sigs.k8s.io/aws-load-balancer-controller/pkg/deploy/tracking"
@@ -214,7 +213,9 @@ func (m *defaultLoadBalancerManager) updateSDKLoadBalancerWithSecurityGroups(ctx
214213

215214
func (m *defaultLoadBalancerManager) checkSDKLoadBalancerWithCOIPv4Pool(_ context.Context, resLB *elbv2model.LoadBalancer, sdkLB LoadBalancerWithTags) error {
216215
if awssdk.StringValue(resLB.Spec.CustomerOwnedIPv4Pool) != awssdk.StringValue(sdkLB.LoadBalancer.CustomerOwnedIpv4Pool) {
217-
return errors.New("loadBalancer has drifted CustomerOwnedIPv4Pool setting")
216+
m.logger.Info("loadBalancer has drifted CustomerOwnedIPv4Pool setting",
217+
"desired", awssdk.StringValue(resLB.Spec.CustomerOwnedIPv4Pool),
218+
"current", awssdk.StringValue(sdkLB.LoadBalancer.CustomerOwnedIpv4Pool))
218219
}
219220
return nil
220221
}

pkg/deploy/elbv2/load_balancer_manager_test.go

Lines changed: 7 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -2,12 +2,12 @@ package elbv2
22

33
import (
44
"context"
5-
"errors"
65
awssdk "github.com/aws/aws-sdk-go/aws"
76
elbv2sdk "github.com/aws/aws-sdk-go/service/elbv2"
87
"github.com/stretchr/testify/assert"
98
coremodel "sigs.k8s.io/aws-load-balancer-controller/pkg/model/core"
109
elbv2model "sigs.k8s.io/aws-load-balancer-controller/pkg/model/elbv2"
10+
"sigs.k8s.io/controller-runtime/pkg/log"
1111
"testing"
1212
)
1313

@@ -363,7 +363,7 @@ func Test_defaultLoadBalancerManager_checkSDKLoadBalancerWithCOIPv4Pool(t *testi
363363
},
364364
},
365365
},
366-
wantErr: errors.New("loadBalancer has drifted CustomerOwnedIPv4Pool setting"),
366+
wantErr: nil,
367367
},
368368
{
369369
name: "only resLB have CustomerOwnedIPv4Pool setting",
@@ -379,7 +379,7 @@ func Test_defaultLoadBalancerManager_checkSDKLoadBalancerWithCOIPv4Pool(t *testi
379379
},
380380
},
381381
},
382-
wantErr: errors.New("loadBalancer has drifted CustomerOwnedIPv4Pool setting"),
382+
wantErr: nil,
383383
},
384384
{
385385
name: "only sdkLB have CustomerOwnedIPv4Pool setting",
@@ -395,12 +395,14 @@ func Test_defaultLoadBalancerManager_checkSDKLoadBalancerWithCOIPv4Pool(t *testi
395395
},
396396
},
397397
},
398-
wantErr: errors.New("loadBalancer has drifted CustomerOwnedIPv4Pool setting"),
398+
wantErr: nil,
399399
},
400400
}
401401
for _, tt := range tests {
402402
t.Run(tt.name, func(t *testing.T) {
403-
m := &defaultLoadBalancerManager{}
403+
m := &defaultLoadBalancerManager{
404+
logger: &log.NullLogger{},
405+
}
404406
err := m.checkSDKLoadBalancerWithCOIPv4Pool(context.Background(), tt.args.resLB, tt.args.sdkLB)
405407
if tt.wantErr != nil {
406408
assert.EqualError(t, err, tt.wantErr.Error())

0 commit comments

Comments
 (0)