Use apply: Always for restart command (#725)

Signed-off-by: Tamal Saha <[email protected]>
kubedb · Oct 3, 2023 · ceb2bda · ceb2bda
1 parent f9be578
commit ceb2bda
Show file tree

Hide file tree

Showing 6 changed files with 6 additions and 0 deletions.
diff --git a/pkg/restarter/elasticsearch.go b/pkg/restarter/elasticsearch.go
@@ -73,6 +73,7 @@ func (e *ElasticsearchRestarter) Restart(name, namespace string) (string, error)
 				Name: name,
 			},
 			Restart: &v1alpha1.RestartSpec{},
+			Apply:   v1alpha1.ApplyOptionAlways,
 		},
 	}
 	_, err = e.opsClient.ElasticsearchOpsRequests(namespace).Create(context.TODO(), restartOpsRequest, metav1.CreateOptions{})

diff --git a/pkg/restarter/mariadb.go b/pkg/restarter/mariadb.go
@@ -73,6 +73,7 @@ func (e *MariaDBRestarter) Restart(name, namespace string) (string, error) {
 				Name: name,
 			},
 			Restart: &v1alpha1.RestartSpec{},
+			Apply:   v1alpha1.ApplyOptionAlways,
 		},
 	}
 	_, err = e.opsClient.MariaDBOpsRequests(namespace).Create(context.TODO(), restartOpsRequest, metav1.CreateOptions{})

diff --git a/pkg/restarter/mongodb.go b/pkg/restarter/mongodb.go
@@ -73,6 +73,7 @@ func (e *MongoDBRestarter) Restart(name, namespace string) (string, error) {
 				Name: name,
 			},
 			Restart: &v1alpha1.RestartSpec{},
+			Apply:   v1alpha1.ApplyOptionAlways,
 		},
 	}
 	_, err = e.opsClient.MongoDBOpsRequests(namespace).Create(context.TODO(), restartOpsRequest, metav1.CreateOptions{})

diff --git a/pkg/restarter/mysql.go b/pkg/restarter/mysql.go
@@ -74,6 +74,7 @@ func (e *MySQLRestarter) Restart(name, namespace string) (string, error) {
 				Name: name,
 			},
 			Restart: &v1alpha1.RestartSpec{},
+			Apply:   v1alpha1.ApplyOptionAlways,
 		},
 	}
 	_, err = e.opsClient.MySQLOpsRequests(namespace).Create(context.TODO(), restartOpsRequest, metav1.CreateOptions{})

diff --git a/pkg/restarter/postgres.go b/pkg/restarter/postgres.go
@@ -73,6 +73,7 @@ func (e *PostgresRestarter) Restart(name, namespace string) (string, error) {
 				Name: name,
 			},
 			Restart: &v1alpha1.RestartSpec{},
+			Apply:   v1alpha1.ApplyOptionAlways,
 		},
 	}
 	_, err = e.opsClient.PostgresOpsRequests(namespace).Create(context.TODO(), restartOpsRequest, metav1.CreateOptions{})

diff --git a/pkg/restarter/redis.go b/pkg/restarter/redis.go
@@ -73,6 +73,7 @@ func (e *RedisRestarter) Restart(name, namespace string) (string, error) {
 				Name: name,
 			},
 			Restart: &v1alpha1.RestartSpec{},
+			Apply:   v1alpha1.ApplyOptionAlways,
 		},
 	}
 	_, err = e.opsClient.RedisOpsRequests(namespace).Create(context.TODO(), restartOpsRequest, metav1.CreateOptions{})