diff --git a/Client.Core/Client.Core.csproj b/Client.Core/Client.Core.csproj index 606ad4e4e..c200c5d97 100644 --- a/Client.Core/Client.Core.csproj +++ b/Client.Core/Client.Core.csproj @@ -40,7 +40,7 @@ - + diff --git a/Client.Legacy/FluxClient.cs b/Client.Legacy/FluxClient.cs index e5bfe6f0e..ea83c3903 100644 --- a/Client.Legacy/FluxClient.cs +++ b/Client.Legacy/FluxClient.cs @@ -165,7 +165,7 @@ public FluxClient(FluxConnectionOptions options) : base(new FluxResultMapper()) var version = AssemblyHelper.GetVersion(typeof(FluxClient)); var restClientOptions = new RestClientOptions(options.Url) { - MaxTimeout = (int)options.Timeout.TotalMilliseconds, + Timeout = options.Timeout, UserAgent = $"influxdb-client-csharp/{version}", Proxy = options.WebProxy }; diff --git a/Client.Test/InfluxDbClientFactoryTest.cs b/Client.Test/InfluxDbClientFactoryTest.cs index 3bb3dfcef..8c2562dea 100644 --- a/Client.Test/InfluxDbClientFactoryTest.cs +++ b/Client.Test/InfluxDbClientFactoryTest.cs @@ -140,7 +140,7 @@ public void LoadFromConnectionString() Assert.AreEqual(LogLevel.Headers, _client.GetLogLevel()); var apiClient = GetDeclaredField(_client.GetType(), _client, "_apiClient"); - Assert.AreEqual(1_000, apiClient.RestClientOptions.MaxTimeout); + Assert.AreEqual(1_000, apiClient.RestClientOptions.Timeout?.TotalMilliseconds); } [Test] @@ -160,7 +160,7 @@ public void LoadFromConnectionStringFactory() Assert.AreEqual(LogLevel.Headers, _client.GetLogLevel()); var apiClient = GetDeclaredField(_client.GetType(), _client, "_apiClient"); - Assert.AreEqual(1_000, apiClient.RestClientOptions.MaxTimeout); + Assert.AreEqual(1_000, apiClient.RestClientOptions.Timeout?.TotalMilliseconds); } [Test] @@ -178,7 +178,7 @@ public void LoadFromConnectionStringUnitsMillisecondsSeconds() Assert.AreEqual(LogLevel.Headers, _client.GetLogLevel()); var apiClient = GetDeclaredField(_client.GetType(), _client, "_apiClient"); - Assert.AreEqual(1, apiClient.RestClientOptions.MaxTimeout); + Assert.AreEqual(1, apiClient.RestClientOptions.Timeout?.TotalMilliseconds); } [Test] @@ -197,7 +197,7 @@ public void LoadFromConnectionStringUnitsMillisecondsSecondsFactory() Assert.AreEqual(LogLevel.Headers, _client.GetLogLevel()); var apiClient = GetDeclaredField(_client.GetType(), _client, "_apiClient"); - Assert.AreEqual(1, apiClient.RestClientOptions.MaxTimeout); + Assert.AreEqual(1, apiClient.RestClientOptions.Timeout?.TotalMilliseconds); } [Test] @@ -215,7 +215,7 @@ public void LoadFromConnectionStringUnitsMinutes() Assert.AreEqual(LogLevel.Headers, _client.GetLogLevel()); var apiClient = GetDeclaredField(_client.GetType(), _client, "_apiClient"); - Assert.AreEqual(1, apiClient.RestClientOptions.MaxTimeout); + Assert.AreEqual(1, apiClient.RestClientOptions.Timeout?.TotalMilliseconds); } [Test] @@ -234,7 +234,7 @@ public void LoadFromConnectionStringUnitsMinutesFactory() Assert.AreEqual(LogLevel.Headers, _client.GetLogLevel()); var apiClient = GetDeclaredField(_client.GetType(), _client, "_apiClient"); - Assert.AreEqual(1, apiClient.RestClientOptions.MaxTimeout); + Assert.AreEqual(1, apiClient.RestClientOptions.Timeout?.TotalMilliseconds); } [Test] @@ -297,7 +297,7 @@ public void LoadFromConfiguration() Assert.AreEqual(LogLevel.Body, _client.GetLogLevel()); var apiClient = GetDeclaredField(_client.GetType(), _client, "_apiClient"); - Assert.AreEqual(10_000, apiClient.RestClientOptions.MaxTimeout); + Assert.AreEqual(10_000, apiClient.RestClientOptions.Timeout?.TotalMilliseconds); var defaultTags = GetDeclaredField>(options.PointSettings.GetType(), options.PointSettings, "_defaultTags"); @@ -324,7 +324,7 @@ public void LoadFromConfigurationOptions() Assert.AreEqual(LogLevel.Body, _client.GetLogLevel()); var apiClient = GetDeclaredField(_client.GetType(), _client, "_apiClient"); - Assert.AreEqual(10_000, apiClient.RestClientOptions.MaxTimeout); + Assert.AreEqual(10_000, apiClient.RestClientOptions.Timeout?.TotalMilliseconds); var defaultTags = GetDeclaredField>(options.PointSettings.GetType(), options.PointSettings, "_defaultTags"); @@ -416,7 +416,7 @@ public void Timeout() _client = new InfluxDBClient(options); var apiClient = GetDeclaredField(_client.GetType(), _client, "_apiClient"); - Assert.AreEqual(20_000, apiClient.RestClientOptions.MaxTimeout); + Assert.AreEqual(20_000, apiClient.RestClientOptions.Timeout?.TotalMilliseconds); } [Test] @@ -432,7 +432,7 @@ public void TimeoutFactory() _client = InfluxDBClientFactory.Create(options); var apiClient = GetDeclaredField(_client.GetType(), _client, "_apiClient"); - Assert.AreEqual(20_000, apiClient.RestClientOptions.MaxTimeout); + Assert.AreEqual(20_000, apiClient.RestClientOptions.Timeout?.TotalMilliseconds); } [Test] diff --git a/Client/Internal/ApiClient.cs b/Client/Internal/ApiClient.cs index a072a2e33..6130b9d2f 100644 --- a/Client/Internal/ApiClient.cs +++ b/Client/Internal/ApiClient.cs @@ -38,7 +38,7 @@ public ApiClient(InfluxDBClientOptions options, LoggingHandler loggingHandler, G var version = AssemblyHelper.GetVersion(typeof(InfluxDBClient)); RestClientOptions = new RestClientOptions(options.Url) { - MaxTimeout = (int)options.Timeout.TotalMilliseconds, + Timeout = options.Timeout, UserAgent = $"influxdb-client-csharp/{version}", Proxy = options.WebProxy, FollowRedirects = options.AllowHttpRedirects,