Merge pull request #16 from ydb-platform/connection-timeout

add connection timeout

Author: KirillKurdyukov

dev-1/lesson-2.1/java/src/main/java/tech/ydb/app/Application.java

@@ -7,6 +7,8 @@
 import tech.ydb.query.tools.SessionRetryContext;
 import tech.ydb.table.result.ResultSetReader;
 
+import java.time.Duration;
+
 /*
  * @author Kirill Kurdyukov
  */
@@ -17,7 +19,10 @@ public class Application {
 
     public static void main(String[] args) {
         // Создаем драйвер для подключения к YDB через gRPC
-        try (GrpcTransport grpcTransport = GrpcTransport.forConnectionString(CONNECTION_STRING).build()) {
+        try (GrpcTransport grpcTransport = GrpcTransport
+                .forConnectionString(CONNECTION_STRING)
+                .withConnectTimeout(Duration.ofSeconds(10)
+                ).build()) {
             // Создаем клиент для выполнения SQL-запросов
             try (QueryClient queryClient = QueryClient.newClient(grpcTransport).build()) {
                 // Создаем контекст для автоматических повторных попыток выполнения запросов

dev-1/lesson-3.1/java/src/main/java/tech/ydb/app/Application.java

@@ -4,6 +4,8 @@
 import tech.ydb.query.QueryClient;
 import tech.ydb.query.tools.SessionRetryContext;
 
+import java.time.Duration;
+
 /*
  * @author Kirill Kurdyukov
  */
@@ -12,7 +14,10 @@ public class Application {
     private static final String CONNECTION_STRING = "grpc://localhost:2136/local";
 
     public static void main(String[] args) {
-        try (GrpcTransport grpcTransport = GrpcTransport.forConnectionString(CONNECTION_STRING).build()) {
+        try (GrpcTransport grpcTransport = GrpcTransport
+                .forConnectionString(CONNECTION_STRING)
+                .withConnectTimeout(Duration.ofSeconds(10)
+                ).build()) {
             try (QueryClient queryClient = QueryClient.newClient(grpcTransport).build()) {
                 var retryCtx = SessionRetryContext.create(queryClient).build();
 

dev-1/lesson-4.1/java/src/main/java/tech/ydb/app/Application.java

@@ -4,6 +4,8 @@
 import tech.ydb.query.QueryClient;
 import tech.ydb.query.tools.SessionRetryContext;
 
+import java.time.Duration;
+
 /*
  * Пример работы с транзакциями в YDB, урок - 4.1 Распределенные транзакции
  * @author Kirill Kurdyukov
@@ -14,7 +16,10 @@ public class Application {
     private static final String CONNECTION_STRING = "grpc://localhost:2136/local";
 
     public static void main(String[] args) {
-        try (GrpcTransport grpcTransport = GrpcTransport.forConnectionString(CONNECTION_STRING).build()) {
+        try (GrpcTransport grpcTransport = GrpcTransport
+                .forConnectionString(CONNECTION_STRING)
+                .withConnectTimeout(Duration.ofSeconds(10)
+                ).build()) {
             try (QueryClient queryClient = QueryClient.newClient(grpcTransport).build()) {
                 var retryCtx = SessionRetryContext.create(queryClient).build();
 

dev-1/lesson-5.1/java/src/main/java/tech/ydb/app/Application.java

@@ -4,6 +4,8 @@
 import tech.ydb.query.QueryClient;
 import tech.ydb.query.tools.SessionRetryContext;
 
+import java.time.Duration;
+
 /*
  * Пример работы с индексами в YDB: создание и использование вторичных индексов
  * @author Kirill Kurdyukov
@@ -14,7 +16,10 @@ public class Application {
     private static final String CONNECTION_STRING = "grpc://localhost:2136/local";
 
     public static void main(String[] args) {
-        try (GrpcTransport grpcTransport = GrpcTransport.forConnectionString(CONNECTION_STRING).build()) {
+        try (GrpcTransport grpcTransport = GrpcTransport
+                .forConnectionString(CONNECTION_STRING)
+                .withConnectTimeout(Duration.ofSeconds(10)
+                ).build()) {
             try (QueryClient queryClient = QueryClient.newClient(grpcTransport).build()) {
                 var retryCtx = SessionRetryContext.create(queryClient).build();
 

dev-1/lesson-6.1/java/src/main/java/tech/ydb/app/Application.java

@@ -5,6 +5,8 @@
 import tech.ydb.query.tools.SessionRetryContext;
 import tech.ydb.topic.TopicClient;
 
+import java.time.Duration;
+
 /*
  * Пример работы с топиками в YDB
  * @author Kirill Kurdyukov
@@ -14,7 +16,10 @@ public class Application {
     private static final String CONNECTION_STRING = "grpc://localhost:2136/local";
 
     public static void main(String[] args) throws InterruptedException {
-        try (GrpcTransport grpcTransport = GrpcTransport.forConnectionString(CONNECTION_STRING).build();
+        try (GrpcTransport grpcTransport = GrpcTransport
+                .forConnectionString(CONNECTION_STRING)
+                .withConnectTimeout(Duration.ofSeconds(10)
+                ).build();
              QueryClient queryClient = QueryClient.newClient(grpcTransport).build();
              TopicClient topicClient = TopicClient.newClient(grpcTransport).build()) {
             var retryCtx = SessionRetryContext.create(queryClient).build();

dev-1/lesson-6.2/java/src/main/java/tech/ydb/app/Application.java

@@ -4,6 +4,7 @@
 import java.nio.charset.StandardCharsets;
 import java.nio.file.Files;
 import java.nio.file.Path;
+import java.time.Duration;
 import java.util.List;
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.TimeUnit;
@@ -35,7 +36,10 @@ public class Application {
     private static final String CONNECTION_STRING = "grpc://localhost:2136/local";
 
     public static void main(String[] args) throws IOException, InterruptedException {
-        try (GrpcTransport grpcTransport = GrpcTransport.forConnectionString(CONNECTION_STRING).build();
+        try (GrpcTransport grpcTransport = GrpcTransport
+                .forConnectionString(CONNECTION_STRING)
+                .withConnectTimeout(Duration.ofSeconds(10)
+                ).build();
              QueryClient queryClient = QueryClient.newClient(grpcTransport).build();
              TopicClient topicClient = TopicClient.newClient(grpcTransport).build()) {
 

dev-1/lesson-6.3/java/src/main/java/tech/ydb/app/Application.java

@@ -4,6 +4,7 @@
 import java.nio.charset.StandardCharsets;
 import java.nio.file.Files;
 import java.nio.file.Path;
+import java.time.Duration;
 import java.util.List;
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.ExecutionException;
@@ -39,7 +40,10 @@ public class Application {
     private static final String CONNECTION_STRING = "grpc://localhost:2136/local";
 
     public static void main(String[] args) throws IOException, InterruptedException {
-        try (GrpcTransport grpcTransport = GrpcTransport.forConnectionString(CONNECTION_STRING).build();
+        try (GrpcTransport grpcTransport = GrpcTransport
+                .forConnectionString(CONNECTION_STRING)
+                .withConnectTimeout(Duration.ofSeconds(10)
+                ).build();
              QueryClient queryClient = QueryClient.newClient(grpcTransport).build();
              TopicClient topicClient = TopicClient.newClient(grpcTransport).build()) {
 

dev-1/lesson-7.1/java/src/main/java/tech/ydb/app/Application.java

@@ -1,5 +1,6 @@
 package tech.ydb.app;
 
+import java.time.Duration;
 import java.util.UUID;
 import tech.ydb.core.grpc.GrpcTransport;
 import tech.ydb.query.QueryClient;
@@ -15,7 +16,10 @@ public class Application {
     private static final String CONNECTION_STRING = "grpc://localhost:2136/local";
 
     public static void main(String[] args) throws InterruptedException {
-        try (GrpcTransport grpcTransport = GrpcTransport.forConnectionString(CONNECTION_STRING).build();
+        try (GrpcTransport grpcTransport = GrpcTransport
+                .forConnectionString(CONNECTION_STRING)
+                .withConnectTimeout(Duration.ofSeconds(10)
+                ).build();
              QueryClient queryClient = QueryClient.newClient(grpcTransport).build();
              TopicClient topicClient = TopicClient.newClient(grpcTransport).build()) {
             var retryCtx = SessionRetryContext.create(queryClient).build();

dev-1/lesson-8.1/java/src/main/java/tech/ydb/app/Application.java

@@ -1,5 +1,6 @@
 package tech.ydb.app;
 
+import java.time.Duration;
 import java.util.List;
 import tech.ydb.core.grpc.GrpcTransport;
 import tech.ydb.query.QueryClient;
@@ -13,7 +14,10 @@ public class Application {
     private static final String CONNECTION_STRING = "grpc://localhost:2136/local";
 
     public static void main(String[] args) {
-        try (GrpcTransport grpcTransport = GrpcTransport.forConnectionString(CONNECTION_STRING).build();
+        try (GrpcTransport grpcTransport = GrpcTransport
+                .forConnectionString(CONNECTION_STRING)
+                .withConnectTimeout(Duration.ofSeconds(10)
+                ).build();
              QueryClient queryClient = QueryClient.newClient(grpcTransport).build()) {
             var retryCtx = SessionRetryContext.create(queryClient).build();
 

dev-1/lesson-8.2/java/src/main/java/tech/ydb/app/Application.java

@@ -5,6 +5,7 @@
 import java.io.IOException;
 import java.nio.file.Files;
 import java.nio.file.Path;
+import java.time.Duration;
 import java.util.ArrayList;
 import java.util.List;
 import tech.ydb.core.grpc.GrpcTransport;
@@ -21,7 +22,10 @@ public class Application {
     private static final String CONNECTION_STRING = "grpc://localhost:2136/local";
 
     public static void main(String[] args) {
-        try (GrpcTransport grpcTransport = GrpcTransport.forConnectionString(CONNECTION_STRING).build();
+        try (GrpcTransport grpcTransport = GrpcTransport
+                .forConnectionString(CONNECTION_STRING)
+                .withConnectTimeout(Duration.ofSeconds(10)
+                ).build();
              TableClient tableClient = TableClient.newClient(grpcTransport).build();
              QueryClient queryClient = QueryClient.newClient(grpcTransport).build()) {
             var retryCtx = SessionRetryContext.create(queryClient).build();