Refer to tsreload using more dsetool like language.

k8ssandra · Aug 29, 2024 · 7617ce8 · 7617ce8
1 parent d47d4a0
commit 7617ce8
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/apis/control/v1alpha1/cassandratask_types.go b/apis/control/v1alpha1/cassandratask_types.go
@@ -81,7 +81,7 @@ const (
 	CommandGarbageCollect  CassandraCommand = "garbagecollect"
 	CommandFlush           CassandraCommand = "flush"
 	CommandRefresh         CassandraCommand = "refresh"
-	CommandInodeTSReload   CassandraCommand = "inodetsreload"
+	CommandTSReload        CassandraCommand = "tsreload"
 )
 
 type CassandraJob struct {

diff --git a/internal/controllers/control/cassandratask_controller.go b/internal/controllers/control/cassandratask_controller.go
@@ -318,7 +318,7 @@ JobDefinition:
 			}
 			completed = taskConfig.Completed
 			break JobDefinition
-		case api.CommandInodeTSReload:
+		case api.CommandTSReload:
 			inodeTsReload(taskConfig)
 		default:
 			err = fmt.Errorf("unknown job command: %s", job.Command)

diff --git a/internal/controllers/control/cassandratask_controller_test.go b/internal/controllers/control/cassandratask_controller_test.go
@@ -639,7 +639,7 @@ var _ = Describe("CassandraTask controller tests", func() {
 			})
 			It("Runs a ts reload task against a pod and fails", func() {
 				By("Creating a task for tsreload")
-				taskKey, task := buildTask(api.CommandInodeTSReload, testNamespaceName)
+				taskKey, task := buildTask(api.CommandTSReload, testNamespaceName)
 				task.Spec.Jobs[0].Arguments.PodName = fmt.Sprintf("%s-%s-r0-sts-0", clusterName, testDatacenterName)
 				Expect(k8sClient.Create(context.Background(), task)).Should(Succeed())
 
@@ -665,7 +665,7 @@ var _ = Describe("CassandraTask controller tests", func() {
 			})
 			It("Runs a ts reload task against a pod", func() {
 				By("Creating a task for tsreload")
-				taskKey, task := buildTask(api.CommandInodeTSReload, testNamespaceName)
+				taskKey, task := buildTask(api.CommandTSReload, testNamespaceName)
 				task.Spec.Jobs[0].Arguments.PodName = fmt.Sprintf("%s-%s-r0-sts-0", clusterName, testDatacenterName)
 				Expect(k8sClient.Create(context.Background(), task)).Should(Succeed())