Skip to content

Commit a1ba0f8

Browse files
committed
Fix CertDiscovery logic for Service NLBs
1 parent 16274a4 commit a1ba0f8

File tree

3 files changed

+13
-2
lines changed

3 files changed

+13
-2
lines changed

controllers/service/service_controller.go

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -4,6 +4,8 @@ import (
44
"context"
55
"fmt"
66

7+
"sigs.k8s.io/aws-load-balancer-controller/pkg/ingress"
8+
79
"github.com/go-logr/logr"
810
"github.com/pkg/errors"
911
corev1 "k8s.io/api/core/v1"
@@ -43,10 +45,16 @@ func NewServiceReconciler(cloud aws.Cloud, k8sClient client.Client, eventRecorde
4345
annotationParser := annotations.NewSuffixAnnotationParser(serviceAnnotationPrefix)
4446
trackingProvider := tracking.NewDefaultProvider(serviceTagPrefix, controllerConfig.ClusterName)
4547
serviceUtils := service.NewServiceUtils(annotationParser, serviceFinalizer, controllerConfig.ServiceConfig.LoadBalancerClass, controllerConfig.FeatureGates)
48+
certDiscovery := ingress.NewACMCertDiscovery(cloud.ACM(), logger)
4649
modelBuilder := service.NewDefaultModelBuilder(annotationParser, subnetsResolver, vpcInfoProvider, cloud.VpcID(), trackingProvider,
50+
<<<<<<< HEAD
4751
elbv2TaggingManager, cloud.EC2(), controllerConfig.FeatureGates, controllerConfig.ClusterName, controllerConfig.DefaultTags, controllerConfig.ExternalManagedTags,
4852
controllerConfig.DefaultSSLPolicy, controllerConfig.DefaultTargetType, controllerConfig.FeatureGates.Enabled(config.EnableIPTargetType), serviceUtils,
4953
backendSGProvider, sgResolver, controllerConfig.EnableBackendSecurityGroup, controllerConfig.DisableRestrictedSGRules, logger)
54+
=======
55+
elbv2TaggingManager, controllerConfig.FeatureGates, controllerConfig.ClusterName, controllerConfig.DefaultTags, controllerConfig.ExternalManagedTags,
56+
controllerConfig.DefaultSSLPolicy, controllerConfig.DefaultTargetType, controllerConfig.FeatureGates.Enabled(config.EnableIPTargetType), serviceUtils, certDiscovery, logger)
57+
>>>>>>> 9a9e052 (Fix CertDiscovery logic for Service NLBs)
5058
stackMarshaller := deploy.NewDefaultStackMarshaller()
5159
stackDeployer := deploy.NewDefaultStackDeployer(cloud, k8sClient, networkingSGManager, networkingSGReconciler, elbv2TaggingManager, controllerConfig, serviceTagPrefix, logger)
5260
return &serviceReconciler{

pkg/service/model_builder.go

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,6 @@ import (
66
"sync"
77

88
"github.com/go-logr/logr"
9-
"sigs.k8s.io/aws-load-balancer-controller/pkg/aws/services"
109
"sigs.k8s.io/aws-load-balancer-controller/pkg/ingress"
1110

1211
"github.com/aws/aws-sdk-go/service/ec2"

pkg/service/model_builder_test.go

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,9 @@ import (
55
"testing"
66
"time"
77

8+
"github.com/go-logr/logr"
9+
"sigs.k8s.io/aws-load-balancer-controller/pkg/ingress"
10+
811
"github.com/aws/aws-sdk-go/aws"
912
"github.com/aws/aws-sdk-go/service/ec2"
1013
elbv2sdk "github.com/aws/aws-sdk-go/service/elbv2"
@@ -6459,9 +6462,10 @@ func Test_defaultModelBuilderTask_Build(t *testing.T) {
64596462
} else {
64606463
enableIPTargetType = *tt.enableIPTargetType
64616464
}
6465+
certDiscovery := ingress.NewMockCertDiscovery(ctrl)
64626466
builder := NewDefaultModelBuilder(annotationParser, subnetsResolver, vpcInfoProvider, "vpc-xxx", trackingProvider, elbv2TaggingManager, ec2Client, featureGates,
64636467
"my-cluster", nil, nil, "ELBSecurityPolicy-2016-08", defaultTargetType, enableIPTargetType, serviceUtils,
6464-
backendSGProvider, sgResolver, tt.enableBackendSG, tt.disableRestrictedSGRules, logr.New(&log.NullLogSink{}))
6468+
backendSGProvider, sgResolver, tt.enableBackendSG, tt.disableRestrictedSGRules, certDiscovery, logr.New(&log.NullLogSink{}))
64656469
ctx := context.Background()
64666470
stack, _, _, err := builder.Build(ctx, tt.svc)
64676471
if tt.wantError {

0 commit comments

Comments
 (0)