add log for loadbalancerid

kubernetes · Mar 16, 2022 · fcaddfb · fcaddfb
1 parent f821eff
commit fcaddfb
Show file tree

Hide file tree

Showing 2 changed files with 20 additions and 7 deletions.
diff --git a/pkg/provider/alibaba/slb/listener.go b/pkg/provider/alibaba/slb/listener.go
@@ -430,6 +430,7 @@ func setHTTPSListenerValue(req interface{}, listener *model.ListenerAttribute) {
 func loadTCPListener(config slb.TCPListenerConfig, listener *model.ListenerAttribute) {
 	persistenceTimeout := config.PersistenceTimeout
 	listener.PersistenceTimeout = &persistenceTimeout
+	listener.EstablishedTimeout = config.EstablishedTimeout
 	listener.ConnectionDrain = model.FlagType(config.ConnectionDrain)
 	listener.ConnectionDrainTimeout = config.ConnectionDrainTimeout
 	listener.HealthyThreshold = config.HealthyThreshold
@@ -458,6 +459,7 @@ func loadHTTPListener(config slb.HTTPListenerConfig, listener *model.ListenerAtt
 	listener.StickySessionType = config.StickySessionType
 	listener.CookieTimeout = config.CookieTimeout
 	listener.Cookie = config.Cookie
+	listener.RequestTimeout = config.RequestTimeout
 	listener.XForwardedForProto = model.FlagType(config.XForwardedForProto)
 	listener.IdleTimeout = config.IdleTimeout
 	listener.HealthCheck = model.FlagType(config.HealthCheck)
@@ -469,6 +471,7 @@ func loadHTTPListener(config slb.HTTPListenerConfig, listener *model.ListenerAtt
 	listener.HealthCheckInterval = config.HealthCheckInterval
 	listener.HealthCheckConnectPort = config.HealthCheckConnectPort
 	listener.HealthCheckHttpCode = config.HealthCheckHttpCode
+	listener.HealthCheckMethod = config.HealthCheckMethod
 	listener.ListenerForward = model.FlagType(config.ListenerForward)
 	listener.ForwardPort = config.ForwardPort
 }
@@ -478,6 +481,7 @@ func loadHTTPSListener(config slb.HTTPSListenerConfig, listener *model.ListenerA
 	listener.StickySessionType = config.StickySessionType
 	listener.CookieTimeout = config.CookieTimeout
 	listener.Cookie = config.Cookie
+	listener.RequestTimeout = config.RequestTimeout
 	listener.XForwardedForProto = model.FlagType(config.XForwardedForProto)
 	listener.IdleTimeout = config.IdleTimeout
 	listener.HealthCheck = model.FlagType(config.HealthCheck)
@@ -489,6 +493,7 @@ func loadHTTPSListener(config slb.HTTPSListenerConfig, listener *model.ListenerA
 	listener.HealthCheckInterval = config.HealthCheckInterval
 	listener.HealthCheckConnectPort = config.HealthCheckConnectPort
 	listener.HealthCheckHttpCode = config.HealthCheckHttpCode
+	listener.HealthCheckMethod = config.HealthCheckMethod
 	listener.CertId = config.ServerCertificateId
 	listener.EnableHttp2 = model.FlagType(config.EnableHttp2)
 }
diff --git a/pkg/provider/alibaba/slb/loadbalancer.go b/pkg/provider/alibaba/slb/loadbalancer.go
@@ -33,7 +33,7 @@ func (p SLBProvider) FindLoadBalancer(ctx context.Context, mdl *model.LoadBalanc
 
 	// 1. find by loadbalancer id
 	if mdl.LoadBalancerAttribute.LoadBalancerId != "" {
-		klog.Infof("[%s] try to find loadbalancer by id %s",
+		klog.Infof("[%s] find loadbalancer by id, LoadBalancerId [%s]",
 			mdl.NamespacedName, mdl.LoadBalancerAttribute.LoadBalancerId)
 		return p.DescribeLoadBalancer(ctx, mdl)
 	}
@@ -43,12 +43,24 @@ func (p SLBProvider) FindLoadBalancer(ctx context.Context, mdl *model.LoadBalanc
 	if err != nil {
 		return err
 	}
+	if mdl.LoadBalancerAttribute.LoadBalancerId != "" {
+		klog.Infof("[%s] find loadbalancer by tag, LoadBalancerId [%s]",
+			mdl.NamespacedName, mdl.LoadBalancerAttribute.LoadBalancerId)
+		return nil
+	}
 
 	// 3. find by loadbalancer name
-	if mdl.LoadBalancerAttribute.LoadBalancerId == "" {
-		return p.findLoadBalancerByName(mdl)
+	err = p.findLoadBalancerByName(mdl)
+	if err != nil {
+		return err
+	}
+	if mdl.LoadBalancerAttribute.LoadBalancerId != "" {
+		klog.Infof("[%s] find loadbalancer by name, LoadBalancerId [%s]",
+			mdl.NamespacedName, mdl.LoadBalancerAttribute.LoadBalancerId)
+		return nil
 	}
 
+	klog.Infof("[%s] find no loadbalancer", mdl.NamespacedName)
 	return nil
 }
 
@@ -82,8 +94,6 @@ func (p SLBProvider) findLoadBalancerByTag(mdl *model.LoadBalancer) error {
 	}
 
 	loadResponse(resp.LoadBalancers.LoadBalancer[0], mdl)
-	klog.Infof("[%s] find loadbalancer by tag, lbId [%s]", mdl.NamespacedName,
-		resp.LoadBalancers.LoadBalancer[0].LoadBalancerId)
 	return nil
 }
 
@@ -116,8 +126,6 @@ func (p SLBProvider) findLoadBalancerByName(mdl *model.LoadBalancer) error {
 	}
 
 	loadResponse(resp.LoadBalancers.LoadBalancer[0], mdl)
-	klog.Infof("[%s] find loadbalancer by name, lbId [%s]", mdl.NamespacedName,
-		mdl.LoadBalancerAttribute.LoadBalancerId)
 	return nil
 }