test: Added replicate-ds test

redis · Jul 18, 2023 · a110e70 · a110e70
1 parent 46976ea
commit a110e70
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 2 deletions.
diff --git a/plugins/riot/src/test/java/com/redis/riot/cli/AbstractIntegrationTests.java b/plugins/riot/src/test/java/com/redis/riot/cli/AbstractIntegrationTests.java
@@ -692,7 +692,7 @@ void generateTypes() throws Exception {
 	}
 
 	@Test
-	void replicateKeyDumps() throws Throwable {
+	void replicate() throws Throwable {
 		String filename = "replicate";
 		generate(filename);
 		Assertions.assertTrue(connection.sync().dbsize() > 0);
@@ -809,10 +809,20 @@ void replicateLiveKeySlot() throws Exception {
 	}
 
 	@Test
-	void replicateLiveDataStructures() throws Exception {
+	void replicateDsLive() throws Exception {
 		runLiveReplication("replicate-ds-live");
 	}
 
+	@Test
+	void replicateDs() throws Throwable {
+		String filename = "replicate-ds";
+		GeneratorItemReader generator = generator();
+		generator.setMaxItemCount(100000);
+		generate(filename, DEFAULT_BATCH_SIZE, generator);
+		Assertions.assertTrue(connection.sync().dbsize() > 0);
+		execute(filename);
+	}
+
 	protected void runLiveReplication(String filename) throws Exception {
 		connection.sync().configSet("notify-keyspace-events", "AK");
 		generate(filename, DEFAULT_BATCH_SIZE, generator(3000));

diff --git a/plugins/riot/src/test/resources/replicate-ds b/plugins/riot/src/test/resources/replicate-ds
@@ -0,0 +1 @@
+riot -h source -p 6379 replicate --type ds -h target -p 6380
Original file line number	Diff line number	Diff line change
		@@ -0,0 +1 @@
		riot -h source -p 6379 replicate --type ds -h target -p 6380