Fix client performance. (#20)

Signed-off-by: Yury-Fridlyand <yury.fridlyand@improving.com>

Author: Yury-Fridlyand

rust/src/lib.rs

@@ -136,6 +136,7 @@ pub unsafe extern "C-unwind" fn create_client(
     let request = unsafe { create_connection_request(config) };
     let runtime = Builder::new_multi_thread()
         .enable_all()
+        .worker_threads(10)
         .thread_name("GLIDE C# thread")
         .build()
         .unwrap();

tests/Valkey.Glide.IntegrationTests/TestConfiguration.cs

@@ -29,22 +29,6 @@ public static ClusterClientConfigurationBuilder DefaultClusterClientConfig() =>
             .WithProtocolVersion(ConnectionConfiguration.Protocol.RESP3)
             .WithTls(TLS);
 
-    public static GlideClient DefaultStandaloneClientWithExtraTimeout()
-        => GlideClient.CreateClient(
-                DefaultClientConfig()
-                .WithRequestTimeout(TimeSpan.FromSeconds(1))
-                .Build())
-            .GetAwaiter()
-            .GetResult();
-
-    public static GlideClusterClient DefaultClusterClientWithExtraTimeout()
-        => GlideClusterClient.CreateClient(
-                DefaultClusterClientConfig()
-                .WithRequestTimeout(TimeSpan.FromSeconds(1))
-                .Build())
-            .GetAwaiter()
-            .GetResult();
-
     public static GlideClient DefaultStandaloneClient()
         => GlideClient.CreateClient(DefaultClientConfig().Build()).GetAwaiter().GetResult();
 
@@ -73,14 +57,12 @@ public static TheoryData<GlideClient> TestStandaloneClients
             {
                 GlideClient resp2client = GlideClient.CreateClient(
                     DefaultClientConfig()
-                    .WithRequestTimeout(TimeSpan.FromSeconds(1))
                     .WithProtocolVersion(ConnectionConfiguration.Protocol.RESP2)
                     .Build()
                 ).GetAwaiter().GetResult();
                 resp2client.SetInfo("RESP2");
                 GlideClient resp3client = GlideClient.CreateClient(
                     DefaultClientConfig()
-                    .WithRequestTimeout(TimeSpan.FromSeconds(1))
                     .WithProtocolVersion(ConnectionConfiguration.Protocol.RESP3)
                     .Build()
                 ).GetAwaiter().GetResult();
@@ -101,14 +83,12 @@ public static TheoryData<GlideClusterClient> TestClusterClients
             {
                 GlideClusterClient resp2client = GlideClusterClient.CreateClient(
                     DefaultClusterClientConfig()
-                    .WithRequestTimeout(TimeSpan.FromSeconds(1))
                     .WithProtocolVersion(ConnectionConfiguration.Protocol.RESP2)
                     .Build()
                 ).GetAwaiter().GetResult();
                 resp2client.SetInfo("RESP2");
                 GlideClusterClient resp3client = GlideClusterClient.CreateClient(
                     DefaultClusterClientConfig()
-                    .WithRequestTimeout(TimeSpan.FromSeconds(1))
                     .WithProtocolVersion(ConnectionConfiguration.Protocol.RESP3)
                     .Build()
                 ).GetAwaiter().GetResult();
@@ -138,7 +118,6 @@ public static ConfigurationOptions DefaultCompatibleConfig()
         ConfigurationOptions config = new();
         config.EndPoints.Add(STANDALONE_HOSTS[0].host, STANDALONE_HOSTS[0].port);
         config.Ssl = TLS;
-        config.ResponseTimeout = 1000;
         return config;
     }
 
@@ -147,7 +126,6 @@ public static ConfigurationOptions DefaultCompatibleClusterConfig()
         ConfigurationOptions config = new();
         config.EndPoints.Add(CLUSTER_HOSTS[0].host, CLUSTER_HOSTS[0].port);
         config.Ssl = TLS;
-        config.ResponseTimeout = 1000;
         return config;
     }