add watch test with restart delay

jetcd-core/src/test/java/io/etcd/jetcd/impl/KVTest.java

@@ -308,7 +308,10 @@ public void testKVClientCanRetryPutOnEtcdRestart() throws InterruptedException {
             });
 
             // restart the cluster while uploading
-            executor.schedule(() -> cluster.restart(), 100, TimeUnit.MILLISECONDS);
+            executor.schedule(
+                () -> cluster.restart(0, TimeUnit.MILLISECONDS),
+                100,
+                TimeUnit.MILLISECONDS);
 
             executor.shutdown();
             assertThat(executor.awaitTermination(30, TimeUnit.SECONDS)).isTrue();

jetcd-core/src/test/java/io/etcd/jetcd/impl/WatchResumeTest.java

@@ -19,9 +19,10 @@
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicReference;
 
-import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.Timeout;
 import org.junit.jupiter.api.extension.RegisterExtension;
+import org.junit.jupiter.params.ParameterizedTest;
+import org.junit.jupiter.params.provider.ValueSource;
 
 import io.etcd.jetcd.ByteSequence;
 import io.etcd.jetcd.Client;
@@ -35,16 +36,17 @@
 import static org.assertj.core.api.Assertions.assertThat;
 import static org.awaitility.Awaitility.await;
 
-@Timeout(value = 30, unit = TimeUnit.SECONDS)
+@Timeout(value = 180, unit = TimeUnit.SECONDS)
 public class WatchResumeTest {
 
     @RegisterExtension
     public static final EtcdClusterExtension cluster = EtcdClusterExtension.builder()
         .withNodes(3)
         .build();
 
-    @Test
-    public void testWatchOnPut() throws Exception {
+    @ParameterizedTest
+    @ValueSource(ints = { 0, 10, 30, 50, 60 })
+    public void testWatchOnPut(int delaySec) throws Exception {
         try (Client client = TestUtil.client(cluster).build()) {
             Watch watchClient = client.getWatchClient();
             KV kvClient = client.getKVClient();
@@ -54,7 +56,7 @@ public void testWatchOnPut() throws Exception {
             final AtomicReference<WatchResponse> ref = new AtomicReference<>();
 
             try (Watcher watcher = watchClient.watch(key, ref::set)) {
-                cluster.restart();
+                cluster.restart(delaySec, TimeUnit.SECONDS);
 
                 kvClient.put(key, value).get();
 

jetcd-core/src/test/java/io/etcd/jetcd/impl/WatchTest.java

@@ -262,7 +262,7 @@ public void testWatchFutureRevisionIsNotOverwrittenOnCreation(final Client clien
 
         try (Watcher watcher = client.getWatchClient().watch(key, watchOption, events::add)) {
 
-            cluster.restart(); // resumes (recreates) the watch
+            cluster.restart(0, TimeUnit.MILLISECONDS); // resumes (recreates) the watch
 
             Thread.sleep(2000); // await().duration() would be better but it's broken
             assertThat(events.isEmpty()).as("verify that received events list is empty").isTrue();

jetcd-launcher/src/main/java/io/etcd/jetcd/launcher/EtcdCluster.java

@@ -18,13 +18,19 @@
 
 import java.net.URI;
 import java.util.List;
+import java.util.concurrent.TimeUnit;
 
 import org.testcontainers.lifecycle.Startable;
 
 public interface EtcdCluster extends Startable {
 
-    default void restart() {
+    default void restart(long delay, TimeUnit unit) throws InterruptedException {
         stop();
+
+        if (delay > 0) {
+            unit.sleep(delay);
+        }
+
         start();
     }
 

jetcd-test/src/main/java/io/etcd/jetcd/test/EtcdClusterExtension.java

@@ -21,6 +21,7 @@
 import java.util.List;
 import java.util.Map;
 import java.util.concurrent.ConcurrentHashMap;
+import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicBoolean;
 
 import org.junit.jupiter.api.extension.AfterAllCallback;
@@ -52,8 +53,12 @@ public EtcdCluster cluster() {
         return this.cluster;
     }
 
-    public void restart() {
-        this.cluster.restart();
+    public void restart(long delay, TimeUnit unit) {
+        try {
+            this.cluster.restart(delay, unit);
+        } catch (InterruptedException e) {
+            throw new RuntimeException(e);
+        }
     }
 
     public String clusterName() {