feat(operator): register kubernetes client as transient

Author: Christoph Bühler

src/KubeOps.Abstractions/Builder/IOperatorBuilder.cs

@@ -19,9 +19,15 @@ public interface IOperatorBuilder
     IServiceCollection Services { get; }
 
     /// <summary>
-    /// Add an entity with its metadata to the operator.
-    /// Metadata must be added for each entity to be used in
-    /// controllers and other elements.
+    /// <para>
+    /// Register an entity within the operator.
+    /// Entities must be registered to be used in controllers and other
+    /// elements like Kubernetes clients.
+    /// </para>
+    /// <para>
+    /// This method will also register a transient IKubernetesClient{TEntity} for
+    /// the entity.
+    /// </para>
     /// </summary>
     /// <param name="metadata">The metadata of the entity.</param>
     /// <typeparam name="TEntity">The type of the entity.</typeparam>

src/KubeOps.KubernetesClient/KubernetesClient.cs

@@ -10,7 +10,7 @@
 namespace KubeOps.KubernetesClient;
 
 /// <inheritdoc cref="IKubernetesClient{TEntity}"/>
-public class KubernetesClient<TEntity> : IKubernetesClient<TEntity>
+public class KubernetesClient<TEntity> : IKubernetesClient<TEntity>, IDisposable
     where TEntity : IKubernetesObject<V1ObjectMeta>
 {
     private const string DownwardApiNamespaceFile = "/var/run/secrets/kubernetes.io/serviceaccount/namespace";
@@ -57,12 +57,14 @@ public KubernetesClient(EntityMetadata metadata, KubernetesClientConfiguration c
             null => new GenericClient(
                 client,
                 metadata.Version,
-                metadata.PluralName),
+                metadata.PluralName,
+                false),
             _ => new GenericClient(
                 client,
                 metadata.Group,
                 metadata.Version,
-                metadata.PluralName),
+                metadata.PluralName,
+                false),
         };
     }
 
@@ -259,4 +261,21 @@ public Watcher<TEntity> Watch(
                 watch: true,
                 cancellationToken: cancellationToken),
         }).Watch(onEvent, onError, onClose);
+
+    public void Dispose()
+    {
+        Dispose(true);
+        GC.SuppressFinalize(this);
+    }
+
+    protected virtual void Dispose(bool disposing)
+    {
+        if (!disposing)
+        {
+            return;
+        }
+
+        _client.Dispose();
+        _genericClient.Dispose();
+    }
 }

src/KubeOps.Operator/Builder/OperatorBuilder.cs

@@ -23,7 +23,7 @@ public OperatorBuilder(IServiceCollection services)
     public IOperatorBuilder AddEntity<TEntity>(EntityMetadata metadata)
         where TEntity : IKubernetesObject<V1ObjectMeta>
     {
-        Services.AddSingleton<IKubernetesClient<TEntity>>(new KubernetesClient<TEntity>(metadata));
+        Services.AddTransient<IKubernetesClient<TEntity>>(_ => new KubernetesClient<TEntity>(metadata));
         return this;
     }