@@ -146,13 +146,6 @@ func mysqlRootPassword(cluster *v1alpha1.Cluster) v1.EnvVar {
146
146
}
147
147
}
148
148
149
- func serviceNameEnvVar (serviceName string ) v1.EnvVar {
150
- return v1.EnvVar {
151
- Name : "MYSQL_CLUSTER_SERVICE_NAME" ,
152
- Value : serviceName ,
153
- }
154
- }
155
-
156
149
func getReplicationGroupSeeds (name string , members int ) string {
157
150
seeds := []string {}
158
151
for i := 0 ; i < members ; i ++ {
@@ -164,9 +157,7 @@ func getReplicationGroupSeeds(name string, members int) string {
164
157
// Builds the MySQL operator container for a cluster.
165
158
// The 'mysqlImage' parameter is the image name of the mysql server to use with
166
159
// no version information.. e.g. 'mysql/mysql-server'
167
- func mysqlServerContainer (cluster * v1alpha1.Cluster , mysqlServerImage string , rootPassword v1.EnvVar , serviceName string , members int , baseServerID uint32 ) v1.Container {
168
- replicationGroupSeeds := getReplicationGroupSeeds (cluster .Namespace , members )
169
-
160
+ func mysqlServerContainer (cluster * v1alpha1.Cluster , mysqlServerImage string , rootPassword v1.EnvVar , members int , baseServerID uint32 ) v1.Container {
170
161
args := []string {
171
162
"--server_id=$(expr $base + $index)" ,
172
163
"--datadir=/var/lib/mysql" ,
@@ -214,11 +205,6 @@ func mysqlServerContainer(cluster *v1alpha1.Cluster, mysqlServerImage string, ro
214
205
VolumeMounts : volumeMounts (cluster ),
215
206
Command : []string {"/bin/bash" , "-ecx" , cmd },
216
207
Env : []v1.EnvVar {
217
- clusterNameEnvVar (cluster ),
218
- namespaceEnvVar (),
219
- serviceNameEnvVar (serviceName ),
220
- replicationGroupSeedsEnvVar (replicationGroupSeeds ),
221
- multiMasterEnvVar (cluster .Spec .MultiMaster ),
222
208
rootPassword ,
223
209
{
224
210
Name : "MYSQL_ROOT_HOST" ,
@@ -232,7 +218,7 @@ func mysqlServerContainer(cluster *v1alpha1.Cluster, mysqlServerImage string, ro
232
218
}
233
219
}
234
220
235
- func mysqlAgentContainer (cluster * v1alpha1.Cluster , mysqlAgentImage string , rootPassword v1.EnvVar , serviceName string , members int ) v1.Container {
221
+ func mysqlAgentContainer (cluster * v1alpha1.Cluster , mysqlAgentImage string , rootPassword v1.EnvVar , members int ) v1.Container {
236
222
agentVersion := version .GetBuildVersion ()
237
223
if version := os .Getenv ("MYSQL_AGENT_VERSION" ); version != "" {
238
224
agentVersion = version
@@ -248,7 +234,6 @@ func mysqlAgentContainer(cluster *v1alpha1.Cluster, mysqlAgentImage string, root
248
234
Env : []v1.EnvVar {
249
235
clusterNameEnvVar (cluster ),
250
236
namespaceEnvVar (),
251
- serviceNameEnvVar (serviceName ),
252
237
replicationGroupSeedsEnvVar (replicationGroupSeeds ),
253
238
multiMasterEnvVar (cluster .Spec .MultiMaster ),
254
239
rootPassword ,
@@ -346,8 +331,8 @@ func NewForCluster(cluster *v1alpha1.Cluster, images operatoropts.Images, servic
346
331
}
347
332
348
333
containers := []v1.Container {
349
- mysqlServerContainer (cluster , images .MySQLServerImage , rootPassword , serviceName , members , baseServerID ),
350
- mysqlAgentContainer (cluster , images .MySQLAgentImage , rootPassword , serviceName , members )}
334
+ mysqlServerContainer (cluster , images .MySQLServerImage , rootPassword , members , baseServerID ),
335
+ mysqlAgentContainer (cluster , images .MySQLAgentImage , rootPassword , members )}
351
336
352
337
podLabels := map [string ]string {
353
338
constants .ClusterLabel : cluster .Name ,
0 commit comments