Support for in-cluster lb

loxilb-io · Jul 27, 2023 · 78c6e7e · 78c6e7e
1 parent 884a787
commit 78c6e7e
Showing 1 changed file with 26 additions and 24 deletions.
diff --git a/pkg/agent/manager/loadbalancer/loadbalancer.go b/pkg/agent/manager/loadbalancer/loadbalancer.go
@@ -1324,33 +1324,35 @@ loop:
 					}
 				}
 
-				for _, bgpPeerURL := range m.networkConfig.ExtBGPPeers {
-					bgpPeer := strings.Split(bgpPeerURL, ":")
-					if len(bgpPeer) > 2 {
-						continue
-					}
+				if !aliveClient.PeeringOnly {
+					for _, bgpPeerURL := range m.networkConfig.ExtBGPPeers {
+						bgpPeer := strings.Split(bgpPeerURL, ":")
+						if len(bgpPeer) > 2 {
+							continue
+						}
 
-					bgpRemoteIP := net.ParseIP(bgpPeer[0])
-					if bgpRemoteIP == nil {
-						continue
-					}
+						bgpRemoteIP := net.ParseIP(bgpPeer[0])
+						if bgpRemoteIP == nil {
+							continue
+						}
 
-					asid, err := strconv.ParseInt(bgpPeer[1], 10, 0)
-					if err != nil || asid == 0 {
-						continue
-					}
+						asid, err := strconv.ParseInt(bgpPeer[1], 10, 0)
+						if err != nil || asid == 0 {
+							continue
+						}
 
-					bgpNeighCfg, _ := m.makeLoxiLBBGNeighModel(int(asid), bgpRemoteIP.String())
-					if err := aliveClient.BGP().CreateNeigh(context.Background(), &bgpNeighCfg); err == nil {
-						klog.Infof("set-ebgp-neigh(%s:%v) cfg success", bgpRemoteIP.String(), asid)
-					} else {
-						klog.Infof("set-ebgp-neigh(%s:%v) cfg - failed (%s)", bgpRemoteIP.String(), asid, err)
-						if strings.Contains(err.Error(), "connection refused") {
-							klog.Infof("set-ebgp-neigh(%s:%v) cfg - failed", bgpRemoteIP.String(), asid)
-							time.Sleep(2 * time.Second)
-							if !aliveClient.DoBGPCfg {
-								loxiAliveCh <- aliveClient
-								aliveClient.DoBGPCfg = true
+						bgpNeighCfg, _ := m.makeLoxiLBBGNeighModel(int(asid), bgpRemoteIP.String())
+						if err := aliveClient.BGP().CreateNeigh(context.Background(), &bgpNeighCfg); err == nil {
+							klog.Infof("set-ebgp-neigh(%s:%v) cfg success", bgpRemoteIP.String(), asid)
+						} else {
+							klog.Infof("set-ebgp-neigh(%s:%v) cfg - failed (%s)", bgpRemoteIP.String(), asid, err)
+							if strings.Contains(err.Error(), "connection refused") {
+								klog.Infof("set-ebgp-neigh(%s:%v) cfg - failed", bgpRemoteIP.String(), asid)
+								time.Sleep(2 * time.Second)
+								if !aliveClient.DoBGPCfg {
+									loxiAliveCh <- aliveClient
+									aliveClient.DoBGPCfg = true
+								}
 							}
 						}
 					}