Implement KubectlGet functionality with tests

Co-authored-by: brendandburns <[email protected]>

Author: Copilot

src/KubernetesClient.Kubectl/Beta/AsyncKubectl.Get.cs

@@ -0,0 +1,88 @@
+using k8s.Models;
+
+namespace k8s.kubectl.beta;
+
+public partial class AsyncKubectl
+{
+    /// <summary>
+    /// Get a pod by name in a namespace.
+    /// </summary>
+    /// <param name="name">The name of the pod.</param>
+    /// <param name="namespace">The namespace of the pod. Defaults to "default".</param>
+    /// <param name="cancellationToken">Cancellation token.</param>
+    /// <returns>The pod.</returns>
+    public async Task<V1Pod> GetPodAsync(string name, string @namespace = "default", CancellationToken cancellationToken = default)
+    {
+        return await client.CoreV1.ReadNamespacedPodAsync(name, @namespace, cancellationToken: cancellationToken).ConfigureAwait(false);
+    }
+
+    /// <summary>
+    /// Get a deployment by name in a namespace.
+    /// </summary>
+    /// <param name="name">The name of the deployment.</param>
+    /// <param name="namespace">The namespace of the deployment. Defaults to "default".</param>
+    /// <param name="cancellationToken">Cancellation token.</param>
+    /// <returns>The deployment.</returns>
+    public async Task<V1Deployment> GetDeploymentAsync(string name, string @namespace = "default", CancellationToken cancellationToken = default)
+    {
+        return await client.AppsV1.ReadNamespacedDeploymentAsync(name, @namespace, cancellationToken: cancellationToken).ConfigureAwait(false);
+    }
+
+    /// <summary>
+    /// Get a service by name in a namespace.
+    /// </summary>
+    /// <param name="name">The name of the service.</param>
+    /// <param name="namespace">The namespace of the service. Defaults to "default".</param>
+    /// <param name="cancellationToken">Cancellation token.</param>
+    /// <returns>The service.</returns>
+    public async Task<V1Service> GetServiceAsync(string name, string @namespace = "default", CancellationToken cancellationToken = default)
+    {
+        return await client.CoreV1.ReadNamespacedServiceAsync(name, @namespace, cancellationToken: cancellationToken).ConfigureAwait(false);
+    }
+
+    /// <summary>
+    /// Get a namespace by name.
+    /// </summary>
+    /// <param name="name">The name of the namespace.</param>
+    /// <param name="cancellationToken">Cancellation token.</param>
+    /// <returns>The namespace.</returns>
+    public async Task<V1Namespace> GetNamespaceAsync(string name, CancellationToken cancellationToken = default)
+    {
+        return await client.CoreV1.ReadNamespaceAsync(name, cancellationToken: cancellationToken).ConfigureAwait(false);
+    }
+
+    /// <summary>
+    /// Get a node by name.
+    /// </summary>
+    /// <param name="name">The name of the node.</param>
+    /// <param name="cancellationToken">Cancellation token.</param>
+    /// <returns>The node.</returns>
+    public async Task<V1Node> GetNodeAsync(string name, CancellationToken cancellationToken = default)
+    {
+        return await client.CoreV1.ReadNodeAsync(name, cancellationToken: cancellationToken).ConfigureAwait(false);
+    }
+
+    /// <summary>
+    /// Get a config map by name in a namespace.
+    /// </summary>
+    /// <param name="name">The name of the config map.</param>
+    /// <param name="namespace">The namespace of the config map. Defaults to "default".</param>
+    /// <param name="cancellationToken">Cancellation token.</param>
+    /// <returns>The config map.</returns>
+    public async Task<V1ConfigMap> GetConfigMapAsync(string name, string @namespace = "default", CancellationToken cancellationToken = default)
+    {
+        return await client.CoreV1.ReadNamespacedConfigMapAsync(name, @namespace, cancellationToken: cancellationToken).ConfigureAwait(false);
+    }
+
+    /// <summary>
+    /// Get a secret by name in a namespace.
+    /// </summary>
+    /// <param name="name">The name of the secret.</param>
+    /// <param name="namespace">The namespace of the secret. Defaults to "default".</param>
+    /// <param name="cancellationToken">Cancellation token.</param>
+    /// <returns>The secret.</returns>
+    public async Task<V1Secret> GetSecretAsync(string name, string @namespace = "default", CancellationToken cancellationToken = default)
+    {
+        return await client.CoreV1.ReadNamespacedSecretAsync(name, @namespace, cancellationToken: cancellationToken).ConfigureAwait(false);
+    }
+}

src/KubernetesClient.Kubectl/Beta/Kubectl.Get.cs

@@ -0,0 +1,81 @@
+using k8s.Models;
+
+namespace k8s.kubectl.beta;
+
+public partial class Kubectl
+{
+    /// <summary>
+    /// Get a pod by name in a namespace.
+    /// </summary>
+    /// <param name="name">The name of the pod.</param>
+    /// <param name="namespace">The namespace of the pod. Defaults to "default".</param>
+    /// <returns>The pod.</returns>
+    public V1Pod GetPod(string name, string @namespace = "default")
+    {
+        return client.GetPodAsync(name, @namespace).GetAwaiter().GetResult();
+    }
+
+    /// <summary>
+    /// Get a deployment by name in a namespace.
+    /// </summary>
+    /// <param name="name">The name of the deployment.</param>
+    /// <param name="namespace">The namespace of the deployment. Defaults to "default".</param>
+    /// <returns>The deployment.</returns>
+    public V1Deployment GetDeployment(string name, string @namespace = "default")
+    {
+        return client.GetDeploymentAsync(name, @namespace).GetAwaiter().GetResult();
+    }
+
+    /// <summary>
+    /// Get a service by name in a namespace.
+    /// </summary>
+    /// <param name="name">The name of the service.</param>
+    /// <param name="namespace">The namespace of the service. Defaults to "default".</param>
+    /// <returns>The service.</returns>
+    public V1Service GetService(string name, string @namespace = "default")
+    {
+        return client.GetServiceAsync(name, @namespace).GetAwaiter().GetResult();
+    }
+
+    /// <summary>
+    /// Get a namespace by name.
+    /// </summary>
+    /// <param name="name">The name of the namespace.</param>
+    /// <returns>The namespace.</returns>
+    public V1Namespace GetNamespace(string name)
+    {
+        return client.GetNamespaceAsync(name).GetAwaiter().GetResult();
+    }
+
+    /// <summary>
+    /// Get a node by name.
+    /// </summary>
+    /// <param name="name">The name of the node.</param>
+    /// <returns>The node.</returns>
+    public V1Node GetNode(string name)
+    {
+        return client.GetNodeAsync(name).GetAwaiter().GetResult();
+    }
+
+    /// <summary>
+    /// Get a config map by name in a namespace.
+    /// </summary>
+    /// <param name="name">The name of the config map.</param>
+    /// <param name="namespace">The namespace of the config map. Defaults to "default".</param>
+    /// <returns>The config map.</returns>
+    public V1ConfigMap GetConfigMap(string name, string @namespace = "default")
+    {
+        return client.GetConfigMapAsync(name, @namespace).GetAwaiter().GetResult();
+    }
+
+    /// <summary>
+    /// Get a secret by name in a namespace.
+    /// </summary>
+    /// <param name="name">The name of the secret.</param>
+    /// <param name="namespace">The namespace of the secret. Defaults to "default".</param>
+    /// <returns>The secret.</returns>
+    public V1Secret GetSecret(string name, string @namespace = "default")
+    {
+        return client.GetSecretAsync(name, @namespace).GetAwaiter().GetResult();
+    }
+}

tests/Kubectl.Tests/KubectlTests.Get.cs

@@ -0,0 +1,168 @@
+using k8s.E2E;
+using k8s.kubectl.beta;
+using k8s.Models;
+using Xunit;
+
+namespace k8s.kubectl.Tests;
+
+public partial class KubectlTests
+{
+    [MinikubeFact]
+    public void GetNamespace()
+    {
+        using var kubernetes = MinikubeTests.CreateClient();
+        var client = new Kubectl(kubernetes);
+
+        // Get the default namespace
+        var ns = client.GetNamespace("default");
+
+        Assert.NotNull(ns);
+        Assert.Equal("default", ns.Metadata.Name);
+        Assert.Equal("v1", ns.ApiVersion);
+        Assert.Equal("Namespace", ns.Kind);
+    }
+
+    [MinikubeFact]
+    public void GetPod()
+    {
+        using var kubernetes = MinikubeTests.CreateClient();
+        var client = new Kubectl(kubernetes);
+        var namespaceParameter = "default";
+        var podName = "k8scsharp-e2e-get-pod";
+
+        // Cleanup any existing pod
+        try
+        {
+            kubernetes.CoreV1.DeleteNamespacedPod(podName, namespaceParameter);
+            System.Threading.Thread.Sleep(2000);
+        }
+        catch
+        {
+            // Ignore if pod doesn't exist
+        }
+
+        // Create a test pod
+        var pod = new V1Pod
+        {
+            Metadata = new V1ObjectMeta
+            {
+                Name = podName,
+                NamespaceProperty = namespaceParameter,
+            },
+            Spec = new V1PodSpec
+            {
+                Containers = new[]
+                {
+                    new V1Container
+                    {
+                        Name = "test",
+                        Image = "nginx:latest",
+                    },
+                },
+            },
+        };
+
+        kubernetes.CoreV1.CreateNamespacedPod(pod, namespaceParameter);
+
+        try
+        {
+            // Wait a moment for the pod to be created
+            System.Threading.Thread.Sleep(1000);
+
+            // Get the pod using kubectl
+            var retrievedPod = client.GetPod(podName, namespaceParameter);
+
+            Assert.NotNull(retrievedPod);
+            Assert.Equal(podName, retrievedPod.Metadata.Name);
+            Assert.Equal(namespaceParameter, retrievedPod.Metadata.NamespaceProperty);
+            Assert.Equal("Pod", retrievedPod.Kind);
+            Assert.Equal("v1", retrievedPod.ApiVersion);
+        }
+        finally
+        {
+            // Cleanup
+            try
+            {
+                kubernetes.CoreV1.DeleteNamespacedPod(podName, namespaceParameter);
+            }
+            catch
+            {
+                // Ignore cleanup errors
+            }
+        }
+    }
+
+    [MinikubeFact]
+    public void GetService()
+    {
+        using var kubernetes = MinikubeTests.CreateClient();
+        var client = new Kubectl(kubernetes);
+        var namespaceParameter = "default";
+        var serviceName = "k8scsharp-e2e-get-service";
+
+        // Cleanup any existing service
+        try
+        {
+            kubernetes.CoreV1.DeleteNamespacedService(serviceName, namespaceParameter);
+            System.Threading.Thread.Sleep(1000);
+        }
+        catch
+        {
+            // Ignore if service doesn't exist
+        }
+
+        // Create a test service
+        var service = new V1Service
+        {
+            Metadata = new V1ObjectMeta
+            {
+                Name = serviceName,
+                NamespaceProperty = namespaceParameter,
+            },
+            Spec = new V1ServiceSpec
+            {
+                Ports = new[]
+                {
+                    new V1ServicePort
+                    {
+                        Port = 80,
+                        TargetPort = 80,
+                    },
+                },
+                Selector = new Dictionary<string, string>
+                {
+                    { "app", "test" },
+                },
+            },
+        };
+
+        kubernetes.CoreV1.CreateNamespacedService(service, namespaceParameter);
+
+        try
+        {
+            // Wait a moment for the service to be created
+            System.Threading.Thread.Sleep(1000);
+
+            // Get the service using kubectl
+            var retrievedService = client.GetService(serviceName, namespaceParameter);
+
+            Assert.NotNull(retrievedService);
+            Assert.Equal(serviceName, retrievedService.Metadata.Name);
+            Assert.Equal(namespaceParameter, retrievedService.Metadata.NamespaceProperty);
+            Assert.Equal("Service", retrievedService.Kind);
+            Assert.Equal("v1", retrievedService.ApiVersion);
+        }
+        finally
+        {
+            // Cleanup
+            try
+            {
+                kubernetes.CoreV1.DeleteNamespacedService(serviceName, namespaceParameter);
+            }
+            catch
+            {
+                // Ignore cleanup errors
+            }
+        }
+    }
+}