PSKubectl

0.0.1

src/GetKubePodCmdlet.cs

                                using System;

using System.Collections.Generic;

using System.Linq;

using System.Management.Automation;

using System.Threading;

using System.Threading.Tasks;

using KubeClient;

using KubeClient.Models;

using KubeClient.ResourceClients;

using Microsoft.Extensions.Logging;

namespace Kubectl {

    [Cmdlet(VerbsCommon.Get, "KubePod")]

    [OutputType(new[] { typeof(PodV1) })]

    public sealed class GetKubePodCmdlet : KubeApiCmdlet {

        [Parameter()]

        public string Namespace { get; set; }

        [Parameter()]

        public string LabelSelector { get; set; }

        [Parameter(Position = 0, ValueFromPipeline = true, ValueFromPipelineByPropertyName = true)]

        [SupportsWildcards()]

        public string Name { get; set; }

        protected override async Task ProcessRecordAsync(CancellationToken cancellationToken) {

            await base.ProcessRecordAsync(cancellationToken);

            IEnumerable<PodV1> podList;

            if (String.IsNullOrEmpty(Name) || WildcardPattern.ContainsWildcardCharacters(Name)) {

                podList = await client.PodsV1().List(

                    kubeNamespace: Namespace,

                    labelSelector: LabelSelector,

                    cancellationToken: cancellationToken

                );

            } else {

                PodV1 pod = await client.PodsV1().Get(

                    name: Name,

                    kubeNamespace: Namespace,

                    cancellationToken: cancellationToken

                );

                podList = new[] { pod };

            }

            if (WildcardPattern.ContainsWildcardCharacters(Name)) {

                var pattern = new WildcardPattern(Name);

                podList = podList.Where(pod => pattern.IsMatch(pod.Metadata.Name));

            }

            WriteObject(podList, true);

        }

    }

}