@@ -1229,6 +1229,22 @@ func (cp *CloudProvider) UpdateLoadBalancer(ctx context.Context, clusterName str
1229
1229
return err
1230
1230
}
1231
1231
1232
+ var sslConfig * SSLConfig
1233
+ if requiresCertificate (service ) {
1234
+ ports , err := getSSLEnabledPorts (service )
1235
+ if err != nil {
1236
+ logger .With (zap .Error (err )).Error ("Failed to parse SSL port." )
1237
+ errorType = util .GetError (err )
1238
+ lbMetricDimension = util .GetMetricDimensionForComponent (errorType , util .LoadBalancerType )
1239
+ dimensionsMap [metrics .ComponentDimension ] = lbMetricDimension
1240
+ metrics .SendMetricData (cp .metricPusher , getMetric (loadBalancerType , Update ), time .Since (startTime ).Seconds (), dimensionsMap )
1241
+ return err
1242
+ }
1243
+ secretListenerString := service .Annotations [ServiceAnnotationLoadBalancerTLSSecret ]
1244
+ secretBackendSetString := service .Annotations [ServiceAnnotationLoadBalancerTLSBackendSetSecret ]
1245
+ sslConfig = NewSSLConfig (secretListenerString , secretBackendSetString , service , ports , cp )
1246
+ }
1247
+
1232
1248
subnets , err := cp .getLoadBalancerSubnets (ctx , logger , service )
1233
1249
if err != nil {
1234
1250
logger .With (zap .Error (err )).Error ("Failed to get Load balancer Subnets." )
@@ -1239,7 +1255,7 @@ func (cp *CloudProvider) UpdateLoadBalancer(ctx context.Context, clusterName str
1239
1255
return err
1240
1256
}
1241
1257
1242
- spec , err := NewLBSpec (logger , service , nodes , subnets , nil , cp .securityListManagerFactory , cp .config .Tags , lb )
1258
+ spec , err := NewLBSpec (logger , service , nodes , subnets , sslConfig , cp .securityListManagerFactory , cp .config .Tags , lb )
1243
1259
if err != nil {
1244
1260
logger .With (zap .Error (err )).Error ("Failed to derive LBSpec" )
1245
1261
errorType = util .GetError (err )
0 commit comments