|
66 | 66 | Cluster: &initSidecarMysqlCluster, |
67 | 67 | } |
68 | 68 | defaultInitSidecarEnvs = []corev1.EnvVar{ |
| 69 | + { |
| 70 | + Name: "CONTAINER_TYPE", |
| 71 | + Value: utils.ContainerInitSidecarName, |
| 72 | + }, |
69 | 73 | { |
70 | 74 | Name: "POD_HOSTNAME", |
71 | 75 | ValueFrom: &corev1.EnvVarSource{ |
@@ -304,14 +308,80 @@ func TestGetInitSidecarEnvVar(t *testing.T) { |
304 | 308 | Cluster: &testToKuDBMysqlCluster, |
305 | 309 | } |
306 | 310 | tokudbCase := EnsureContainer("init-sidecar", &testTokuDBCluster) |
307 | | - testTokuDBEnv := make([]corev1.EnvVar, 18) |
| 311 | + testTokuDBEnv := make([]corev1.EnvVar, len(defaultInitSidecarEnvs)) |
308 | 312 | copy(testTokuDBEnv, defaultInitSidecarEnvs) |
309 | 313 | testTokuDBEnv = append(testTokuDBEnv, corev1.EnvVar{ |
310 | 314 | Name: "INIT_TOKUDB", |
311 | 315 | Value: "1", |
312 | 316 | }) |
313 | 317 | assert.Equal(t, testTokuDBEnv, tokudbCase.Env) |
314 | 318 | } |
| 319 | + // BackupSecretName not empty |
| 320 | + { |
| 321 | + testBackupMysqlCluster := initSidecarMysqlCluster |
| 322 | + testBackupMysqlCluster.Spec.BackupSecretName = "backup-secret" |
| 323 | + testBackupMysqlClusterWraper := cluster.Cluster{ |
| 324 | + Cluster: &testBackupMysqlCluster, |
| 325 | + } |
| 326 | + BackupCase := EnsureContainer("init-sidecar", &testBackupMysqlClusterWraper) |
| 327 | + testBackupEnv := make([]corev1.EnvVar, len(defaultInitSidecarEnvs)) |
| 328 | + copy(testBackupEnv, defaultInitSidecarEnvs) |
| 329 | + testBackupEnv = append(testBackupEnv, |
| 330 | + corev1.EnvVar{ |
| 331 | + Name: "S3_ENDPOINT", |
| 332 | + |
| 333 | + ValueFrom: &corev1.EnvVarSource{ |
| 334 | + SecretKeyRef: &corev1.SecretKeySelector{ |
| 335 | + LocalObjectReference: corev1.LocalObjectReference{ |
| 336 | + Name: testBackupMysqlClusterWraper.Spec.BackupSecretName, |
| 337 | + }, |
| 338 | + Key: "s3-endpoint", |
| 339 | + Optional: &optFalse, |
| 340 | + }, |
| 341 | + }, |
| 342 | + }, |
| 343 | + corev1.EnvVar{ |
| 344 | + Name: "S3_ACCESSKEY", |
| 345 | + |
| 346 | + ValueFrom: &corev1.EnvVarSource{ |
| 347 | + SecretKeyRef: &corev1.SecretKeySelector{ |
| 348 | + LocalObjectReference: corev1.LocalObjectReference{ |
| 349 | + Name: testBackupMysqlClusterWraper.Spec.BackupSecretName, |
| 350 | + }, |
| 351 | + Key: "s3-access-key", |
| 352 | + Optional: &optTrue, |
| 353 | + }, |
| 354 | + }, |
| 355 | + }, |
| 356 | + corev1.EnvVar{ |
| 357 | + Name: "S3_SECRETKEY", |
| 358 | + |
| 359 | + ValueFrom: &corev1.EnvVarSource{ |
| 360 | + SecretKeyRef: &corev1.SecretKeySelector{ |
| 361 | + LocalObjectReference: corev1.LocalObjectReference{ |
| 362 | + Name: testBackupMysqlClusterWraper.Spec.BackupSecretName, |
| 363 | + }, |
| 364 | + Key: "s3-secret-key", |
| 365 | + Optional: &optTrue, |
| 366 | + }, |
| 367 | + }, |
| 368 | + }, |
| 369 | + corev1.EnvVar{ |
| 370 | + Name: "S3_BUCKET", |
| 371 | + |
| 372 | + ValueFrom: &corev1.EnvVarSource{ |
| 373 | + SecretKeyRef: &corev1.SecretKeySelector{ |
| 374 | + LocalObjectReference: corev1.LocalObjectReference{ |
| 375 | + Name: testBackupMysqlClusterWraper.Spec.BackupSecretName, |
| 376 | + }, |
| 377 | + Key: "s3-bucket", |
| 378 | + Optional: &optTrue, |
| 379 | + }, |
| 380 | + }, |
| 381 | + }, |
| 382 | + ) |
| 383 | + assert.Equal(t, testBackupEnv, BackupCase.Env) |
| 384 | + } |
315 | 385 | } |
316 | 386 |
|
317 | 387 | func TestGetInitSidecarLifecycle(t *testing.T) { |
|
0 commit comments