test: add replication-test-go (#2496)

tests/integration/replication_test.go

@@ -423,6 +423,33 @@ var _ = Describe("should replication ", func() {
 			slaveWrite := clientSlave.Set(ctx, "foo", "bar", 0)
 			Expect(slaveWrite.Err()).To(MatchError("ERR Server in read-only"))
 
+			log.Println("Replication test 1 start")
+			err1 := clientMaster.SetEx(ctx, "key", "hello", 60*time.Second).Err()
+			Expect(err1).NotTo(HaveOccurred())
+			Eventually(func() error {
+				return clientMaster.Get(ctx, "key").Err()
+			}, "65s", "100ms").Should(Equal(redis.Nil))
+			Eventually(func() error {
+				return clientSlave.Get(ctx, "key").Err()
+			}, "65s", "100ms").Should(Equal(redis.Nil))
+			log.Println("Replication test 1 success")
+
+			log.Println("Replication test 2 start")
+			set := clientMaster.Set(ctx, "x", "y", 0)
+			Expect(set.Err()).NotTo(HaveOccurred())
+			Expect(set.Val()).To(Equal("OK"))
+			set1 := clientMaster.Set(ctx, "a", "b", 0)
+			Expect(set1.Err()).NotTo(HaveOccurred())
+			Expect(set1.Val()).To(Equal("OK"))
+			Expect(clientMaster.FlushDB(ctx).Err()).NotTo(HaveOccurred())
+			Eventually(func() error {
+				return clientMaster.Get(ctx, "x").Err()
+			}, "1s", "100ms").Should(Equal(redis.Nil))
+			Eventually(func() error {
+				return clientSlave.Get(ctx, "x").Err()
+			}, "1s", "100ms").Should(Equal(redis.Nil))
+			log.Println("Replication test 2 success")
+
 			log.Println("rpoplpush test start")
 			Expect(clientMaster.Del(ctx, "blist0", "blist1", "blist").Err()).NotTo(HaveOccurred())
 			execute(&ctx, clientMaster, 4, rpoplpushThread)