This is an automated email from the ASF dual-hosted git repository.
rustyrazorblade pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/cassandra-easy-stress.git
The following commit(s) were added to refs/heads/main by this push:
new 583dbe9 Fix --scl parameter parsing (#95)
583dbe9 is described below
commit 583dbe92ab48f31a26d7fcc16b72a178db61b6b5
Author: Stepan Nazarov <[email protected]>
AuthorDate: Thu May 7 22:43:54 2026 +0300
Fix --scl parameter parsing (#95)
Patch by Stepan Nazarov, Reviewed by Jon Haddad for #95
---
.../kotlin/org/apache/cassandra/easystress/commands/Run.kt | 6 +++++-
.../apache/cassandra/easystress/CommandLineParserTest.kt | 14 ++++++++++++++
2 files changed, 19 insertions(+), 1 deletion(-)
diff --git a/src/main/kotlin/org/apache/cassandra/easystress/commands/Run.kt
b/src/main/kotlin/org/apache/cassandra/easystress/commands/Run.kt
index 9de79dc..8b69696 100644
--- a/src/main/kotlin/org/apache/cassandra/easystress/commands/Run.kt
+++ b/src/main/kotlin/org/apache/cassandra/easystress/commands/Run.kt
@@ -241,7 +241,11 @@ class Run(
ConsistencyLevelConverter().convert(it)
} ?: ConsistencyLevel.LOCAL_ONE
- @Parameter(names = ["--scl"], description = "Serial consistency level")
+ @Parameter(
+ names = ["--scl"],
+ description = "Serial consistency level",
+ converter = ConsistencyLevelConverter::class,
+ )
@Serializable(with = ConsistencyLevelSerializer::class)
var serialConsistencyLevel =
System.getenv("CASSANDRA_EASY_STRESS_SERIAL_CONSISTENCY_LEVEL")?.let {
diff --git
a/src/test/kotlin/org/apache/cassandra/easystress/CommandLineParserTest.kt
b/src/test/kotlin/org/apache/cassandra/easystress/CommandLineParserTest.kt
index 29e777c..ca3be5e 100644
--- a/src/test/kotlin/org/apache/cassandra/easystress/CommandLineParserTest.kt
+++ b/src/test/kotlin/org/apache/cassandra/easystress/CommandLineParserTest.kt
@@ -17,6 +17,7 @@
*/
package org.apache.cassandra.easystress
+import com.datastax.oss.driver.api.core.ConsistencyLevel
import org.apache.cassandra.easystress.commands.Run
import org.assertj.core.api.Assertions.assertThat
import org.junit.jupiter.api.Test
@@ -29,4 +30,17 @@ internal class CommandLineParserTest {
assertThat(result.getParsedCommand()).isEqualToIgnoringCase("run")
assertThat(result.getCommandInstance()).isInstanceOf(Run::class.java)
}
+
+ @Test
+ fun testSerialConsistencyLevelParsing() {
+ val args = arrayOf("run", "BasicTimeSeries", "--cl", "QUORUM",
"--scl", "SERIAL")
+ val result = CommandLineParser.parse(args)
+
+ assertThat(result.getParsedCommand()).isEqualToIgnoringCase("run")
+ assertThat(result.getCommandInstance()).isInstanceOf(Run::class.java)
+
+ val runCommand = result.getCommandInstance() as Run
+
assertThat(runCommand.consistencyLevel).isEqualTo(ConsistencyLevel.QUORUM)
+
assertThat(runCommand.serialConsistencyLevel).isEqualTo(ConsistencyLevel.SERIAL)
+ }
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
