Fix sample to not timeout during watch

Author: macsux

examples/informers/ServiceCollectionKubernetesExtensions.cs

@@ -1,5 +1,6 @@
 using System;
 using System.Linq;
+using System.Threading;
 using k8s;
 using k8s.Informers;
 using k8s.Informers.Cache;
@@ -28,9 +29,13 @@ public static IServiceCollection AddKubernetes(this IServiceCollection services)
             services.AddSingleton<RetryDelegatingHandler>();
             services.AddHttpClient("DefaultName")
                 .AddTypedClient<IKubernetes>((httpClient, serviceProvider) =>
-                    new Kubernetes(
+                {
+                    httpClient.Timeout = Timeout.InfiniteTimeSpan;
+                    return new Kubernetes(
                         serviceProvider.GetRequiredService<KubernetesClientConfiguration>(),
-                        httpClient))
+                        httpClient);
+                })
+                .AddHttpMessageHandler(() => new TimeoutHandler(TimeSpan.FromSeconds(5)))
                 .AddHttpMessageHandler(() => new RetryDelegatingHandler()
                 {
                     RetryPolicy = new RetryPolicy<HttpStatusCodeErrorDetectionStrategy>(new ExponentialBackoffRetryStrategy())

examples/informers/TimeoutHandler.cs

@@ -0,0 +1,34 @@
+using System;
+using System.Linq;
+using System.Net.Http;
+using System.Threading;
+using System.Threading.Tasks;
+using Microsoft.AspNetCore.WebUtilities;
+
+namespace informers
+{
+    internal class TimeoutHandler : DelegatingHandler
+    {
+        private readonly TimeSpan _timeout;
+
+        public TimeoutHandler(TimeSpan timeout)
+        {
+            _timeout = timeout;
+        }
+
+        protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
+        {
+            var query = QueryHelpers.ParseQuery(request.RequestUri.Query);
+
+            if (!(query.TryGetValue("watch", out var values) && values.Any(v => v == "true")))
+            {
+                var cts = new CancellationTokenSource(_timeout);
+                cancellationToken = CancellationTokenSource.CreateLinkedTokenSource(cancellationToken, cts.Token).Token;
+            }
+            var originResponse = await base.SendAsync(request, cancellationToken).ConfigureAwait(false);
+
+            return originResponse;
+        }
+
+    }
+}