Set environment variable for obagent to overwrite host ip config (#605)

Author: chris-sun-star

internal/const/obagent/obagent.go

@@ -12,6 +12,10 @@ See the Mulan PSL v2 for more details.
 
 package monitor
 
+const (
+	LocalHostAddress = "127.0.0.1"
+)
+
 const (
 	HttpPort  = 8088
 	PprofPort = 8089
@@ -42,6 +46,7 @@ const (
 	EnvMonitorUser     = "MONITOR_USER"
 	EnvMonitorPASSWORD = "MONITOR_PASSWORD"
 	EnvOBMonitorStatus = "OB_MONITOR_STATUS"
+	EnvHostIp          = "HOST_IP"
 )
 
 const (

internal/resource/observer/utils.go

@@ -395,6 +395,33 @@ func (m *OBServerManager) createMonitorContainer(obcluster *v1alpha1.OBCluster)
 			},
 		},
 	}
+
+	mode, modeAnnoExist := resourceutils.GetAnnotationField(m.OBServer, oceanbaseconst.AnnotationsMode)
+	if modeAnnoExist {
+		switch mode {
+		case oceanbaseconst.ModeStandalone:
+			envHostIp := corev1.EnvVar{
+				Name:  obagentconst.EnvHostIp,
+				Value: obagentconst.LocalHostAddress,
+			}
+			env = append(env, envHostIp)
+		case oceanbaseconst.ModeService:
+			svc, err := m.getSvc()
+			if err != nil {
+				if kubeerrors.IsNotFound(err) {
+					m.Logger.Info("Svc not found")
+				} else {
+					m.Logger.Error(err, "Failed to get svc")
+				}
+			} else {
+				envHostIp := corev1.EnvVar{
+					Name:  obagentconst.EnvHostIp,
+					Value: svc.Spec.ClusterIP,
+				}
+				env = append(env, envHostIp)
+			}
+		}
+	}
 	env = append(env, envOBModuleStatus)
 	env = append(env, envClusterName)
 	env = append(env, envClusterId)
@@ -540,7 +567,6 @@ func (m *OBServerManager) createOBServerContainer(obcluster *v1alpha1.OBCluster)
 		Name:  "ZONE_NAME",
 		Value: m.OBServer.Spec.Zone,
 	}
-
 	mode, modeAnnoExist := resourceutils.GetAnnotationField(m.OBServer, oceanbaseconst.AnnotationsMode)
 	if modeAnnoExist {
 		switch mode {
@@ -567,7 +593,6 @@ func (m *OBServerManager) createOBServerContainer(obcluster *v1alpha1.OBCluster)
 			}
 		}
 	}
-
 	startupParameters := make([]string, 0)
 	for _, parameter := range obcluster.Spec.Parameters {
 		reserved := false