add default connection timeouts

Trendyol · Feb 15, 2023 · 909812d · 909812d
1 parent 09e5719
commit 909812d
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 2 deletions.
diff --git a/...earch/src/main/kotlin/com/trendyol/stove/testing/e2e/elasticsearch/ElasticsearchSystem.kt b/...earch/src/main/kotlin/com/trendyol/stove/testing/e2e/elasticsearch/ElasticsearchSystem.kt
@@ -27,15 +27,25 @@ import org.apache.http.HttpHost
 import org.apache.http.auth.AuthScope
 import org.apache.http.auth.UsernamePasswordCredentials
 import org.apache.http.client.CredentialsProvider
+import org.apache.http.client.config.RequestConfig
 import org.apache.http.impl.client.BasicCredentialsProvider
 import org.apache.http.impl.nio.client.HttpAsyncClientBuilder
 import org.elasticsearch.client.*
 import org.testcontainers.elasticsearch.ElasticsearchContainer
 import kotlin.reflect.KClass
+import kotlin.time.Duration.Companion.seconds
 
 data class ElasticClientConfigurer(
     val restClientBuilder: RestClientBuilder.() -> Unit = {},
-    val httpClientBuilder: HttpAsyncClientBuilder.() -> Unit = {},
+    val httpClientBuilder: HttpAsyncClientBuilder.() -> Unit = {
+        setDefaultRequestConfig(
+            RequestConfig.custom()
+                .setSocketTimeout(5.seconds.inWholeMilliseconds.toInt())
+                .setConnectTimeout(5.seconds.inWholeMilliseconds.toInt())
+                .setConnectionRequestTimeout(5.seconds.inWholeMilliseconds.toInt())
+                .build()
+        )
+    },
 )
 
 data class ElasticsearchSystemOptions(

diff --git a/.../test/kotlin/com/trendyol/stove/testing/e2e/elasticsearch/ElasticsearchTestSystemTests.kt b/.../test/kotlin/com/trendyol/stove/testing/e2e/elasticsearch/ElasticsearchTestSystemTests.kt
@@ -50,7 +50,7 @@ class NoOpApplication : ApplicationUnderTest<Unit> {
     }
 }
 
-class CouchbaseTestSystemTests : FunSpec({
+class ElasticsearchTestSystemTests : FunSpec({
 
     @JsonIgnoreProperties
     data class ExampleInstance(