Rebase onto latest master

CONTRIBUTING.md

@@ -0,0 +1,22 @@
+# Contributing
+
+Thanks for taking the time to join our community and start contributing!
+
+Please remember to read and observe the [Code of Conduct](https://github.com/cncf/foundation/blob/master/code-of-conduct.md).
+
+This  project accepts contribution via github [pull requests](https://help.github.com/articles/about-pull-requests/). This document outlines the process to help get your contribution accepted. Please also read the [Kubernetes contributor guide](https://github.com/kubernetes/community/blob/master/contributors/guide/README.md) which provides detailed instructions on how to get your ideas and bug fixes seen and accepted.
+
+## Sign the Contributor License Agreement
+We'd love to accept your patches! Before we can accept them you need to sign Cloud Native Computing Foundation (CNCF) [CLA](https://github.com/kubernetes/community/blob/master/CLA.md).
+
+## Reporting an issue
+If you have any problem with the package or any suggestions, please file an [issue](https://github.com/kubernetes-client/csharp/issues).
+
+## Contributing a Patch
+1. Submit an issue describing your proposed change to the repo.
+2. Fork this repo, develop and test your code changes.
+3. Submit a pull request.
+4. The bot will automatically assigns someone to review your PR. Check the full list of bot commands [here](https://prow.k8s.io/command-help).
+
+### Contact
+You can reach the maintainers of this project at [SIG API Machinery](https://github.com/kubernetes/community/tree/master/sig-api-machinery) or on the [#kubernetes-client](https://kubernetes.slack.com/messages/kubernetes-client) channel on the Kubernetes slack.

README.md

@@ -79,3 +79,7 @@ cd csharp\tests
 dotnet restore
 dotnet test
 ```
+
+## Contributing
+
+Please see [CONTRIBUTING.md](CONTRIBUTING.md) for instructions on how to contribute.

SECURITY_CONTACTS

@@ -0,0 +1,13 @@
+# Defined below are the security contacts for this repo.
+#
+# They are the contact point for the Product Security Team to reach out
+# to for triaging and handling of incoming issues.
+#
+# The below names agree to abide by the
+# [Embargo Policy](https://github.com/kubernetes/sig-release/blob/master/security-release-process-documentation/security-release-process.md#embargo-policy)
+# and will be removed and replaced if they violate that agreement.
+#
+# DO NOT REPORT SECURITY VULNERABILITIES DIRECTLY TO THESE NAMES, FOLLOW THE
+# INSTRUCTIONS AT https://kubernetes.io/security/
+
+brendandburns 

csharp.settings

@@ -1,3 +1,3 @@
-export KUBERNETES_BRANCH=v1.10.0
+export KUBERNETES_BRANCH=v1.12.0
 export CLIENT_VERSION=0.0.1
 export PACKAGE_NAME=k8s

examples/attach/Attach.cs

@@ -23,7 +23,7 @@ private static async Task Main(string[] args)
 
         private async static Task AttachToPod(IKubernetes client, V1Pod pod) {
             var webSocket = await client.WebSocketNamespacedPodAttachAsync(pod.Metadata.Name, "default", pod.Spec.Containers[0].Name);
-            
+
             var demux = new StreamDemuxer(webSocket);
             demux.Start();
 

examples/labels/PodList.cs

@@ -1,44 +1,44 @@
-using System;
-using System.Collections.Generic;
-using k8s;
-
-namespace simple
-{
-    internal class PodList
-    {
-        private static void Main(string[] args)
-        {
-            var config = KubernetesClientConfiguration.BuildConfigFromConfigFile();
-            IKubernetes client = new Kubernetes(config);
-            Console.WriteLine("Starting Request!");
-
-            var list = client.ListNamespacedService("default");
-            foreach (var item in list.Items)
-            {
-                Console.WriteLine("Pods for service: " + item.Metadata.Name);
-                Console.WriteLine("=-=-=-=-=-=-=-=-=-=-=");
-                if (item.Spec == null || item.Spec.Selector == null)
-                {
-                    continue;
-                }
-                var labels = new List<string>();
-                foreach (var key in item.Spec.Selector)
-                {
-                    labels.Add(key.Key + "=" + key.Value);
-                }
-                var labelStr = string.Join(",", labels.ToArray());
-                Console.WriteLine(labelStr);
-                var podList = client.ListNamespacedPod("default", labelSelector: labelStr);
-                foreach (var pod in podList.Items)
-                {
-                    Console.WriteLine(pod.Metadata.Name);
-                }
-                if (podList.Items.Count == 0)
-                {
-                    Console.WriteLine("Empty!");
-                }
-                Console.WriteLine();
-            }
-        }
-    }
-}
+using System;
+using System.Collections.Generic;
+using k8s;
+
+namespace simple
+{
+    internal class PodList
+    {
+        private static void Main(string[] args)
+        {
+            var config = KubernetesClientConfiguration.BuildConfigFromConfigFile();
+            IKubernetes client = new Kubernetes(config);
+            Console.WriteLine("Starting Request!");
+
+            var list = client.ListNamespacedService("default");
+            foreach (var item in list.Items)
+            {
+                Console.WriteLine("Pods for service: " + item.Metadata.Name);
+                Console.WriteLine("=-=-=-=-=-=-=-=-=-=-=");
+                if (item.Spec == null || item.Spec.Selector == null)
+                {
+                    continue;
+                }
+                var labels = new List<string>();
+                foreach (var key in item.Spec.Selector)
+                {
+                    labels.Add(key.Key + "=" + key.Value);
+                }
+                var labelStr = string.Join(",", labels.ToArray());
+                Console.WriteLine(labelStr);
+                var podList = client.ListNamespacedPod("default", labelSelector: labelStr);
+                foreach (var pod in podList.Items)
+                {
+                    Console.WriteLine(pod.Metadata.Name);
+                }
+                if (podList.Items.Count == 0)
+                {
+                    Console.WriteLine("Empty!");
+                }
+                Console.WriteLine();
+            }
+        }
+    }
+}

examples/namespace/Namespace.cs

@@ -1,87 +1,87 @@
-using System;
-using System.Net;
-using System.Threading.Tasks;
-using k8s;
-using k8s.Models;
-
-namespace @namespace
-{
-    class NamespaceExample
-    {
-        static void ListNamespaces(IKubernetes client) {
-            var list = client.ListNamespace();
-            foreach (var item in list.Items) {
-                Console.WriteLine(item.Metadata.Name);
-            }
-            if (list.Items.Count == 0) {
-                Console.WriteLine("Empty!");
-            }
-        }
-
-        static async Task DeleteAsync(IKubernetes client, string name, int delayMillis) {
-            while (true) {
-                await Task.Delay(delayMillis);
-                try
-                {
+using System;
+using System.Net;
+using System.Threading.Tasks;
+using k8s;
+using k8s.Models;
+
+namespace @namespace
+{
+    class NamespaceExample
+    {
+        static void ListNamespaces(IKubernetes client) {
+            var list = client.ListNamespace();
+            foreach (var item in list.Items) {
+                Console.WriteLine(item.Metadata.Name);
+            }
+            if (list.Items.Count == 0) {
+                Console.WriteLine("Empty!");
+            }
+        }
+
+        static async Task DeleteAsync(IKubernetes client, string name, int delayMillis) {
+            while (true) {
+                await Task.Delay(delayMillis);
+                try
+                {
                     await client.ReadNamespaceAsync(name);
-                } catch (AggregateException ex) {
-                    foreach (var innerEx in ex.InnerExceptions) {
-                        if (innerEx is Microsoft.Rest.HttpOperationException) {
-                            var code = ((Microsoft.Rest.HttpOperationException)innerEx).Response.StatusCode;
-                            if (code == HttpStatusCode.NotFound) {
-                                return;
-                            }
-                            throw ex;
-                        }
-                    }
-                } catch (Microsoft.Rest.HttpOperationException ex) {
-                    if (ex.Response.StatusCode == HttpStatusCode.NotFound) {
-                        return;
-                    }
-                    throw ex;
-                }
-            }
-        }
-
-        static void Delete(IKubernetes client, string name, int delayMillis) {
-            DeleteAsync(client, name, delayMillis).Wait();
-        }
-
-        private static void Main(string[] args)
-        {
-            var k8SClientConfig = KubernetesClientConfiguration.BuildConfigFromConfigFile();
-            IKubernetes client = new Kubernetes(k8SClientConfig);
-            
-            ListNamespaces(client);
-
-            var ns = new V1Namespace
-            {
-                Metadata = new V1ObjectMeta
-                {
-                    Name = "test"
-                }
-            };
-
-            var result = client.CreateNamespace(ns);
-            Console.WriteLine(result);
-
-            ListNamespaces(client);
-
-            var status = client.DeleteNamespace(new V1DeleteOptions(), ns.Metadata.Name);
-
-            if (status.HasObject)
-            {
+                } catch (AggregateException ex) {
+                    foreach (var innerEx in ex.InnerExceptions) {
+                        if (innerEx is Microsoft.Rest.HttpOperationException) {
+                            var code = ((Microsoft.Rest.HttpOperationException)innerEx).Response.StatusCode;
+                            if (code == HttpStatusCode.NotFound) {
+                                return;
+                            }
+                            throw ex;
+                        }
+                    }
+                } catch (Microsoft.Rest.HttpOperationException ex) {
+                    if (ex.Response.StatusCode == HttpStatusCode.NotFound) {
+                        return;
+                    }
+                    throw ex;
+                }
+            }
+        }
+
+        static void Delete(IKubernetes client, string name, int delayMillis) {
+            DeleteAsync(client, name, delayMillis).Wait();
+        }
+
+        private static void Main(string[] args)
+        {
+            var k8SClientConfig = KubernetesClientConfiguration.BuildConfigFromConfigFile();
+            IKubernetes client = new Kubernetes(k8SClientConfig);
+
+            ListNamespaces(client);
+
+            var ns = new V1Namespace
+            {
+                Metadata = new V1ObjectMeta
+                {
+                    Name = "test"
+                }
+            };
+
+            var result = client.CreateNamespace(ns);
+            Console.WriteLine(result);
+
+            ListNamespaces(client);
+
+            var status = client.DeleteNamespace(new V1DeleteOptions(), ns.Metadata.Name);
+
+            if (status.HasObject)
+            {
                 var obj = status.ObjectView<V1Namespace>();
                 Console.WriteLine(obj.Status.Phase);
 
                 Delete(client, ns.Metadata.Name, 3 * 1000);
-            }
-            else
-            {
-                Console.WriteLine(status.Message);
+            }
+            else
+            {
+                Console.WriteLine(status.Message);
             }
 
-            ListNamespaces(client);
-        }
-    }
-}
+            ListNamespaces(client);
+        }
+    }
+}

examples/patch/Program.cs

@@ -0,0 +1,44 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using k8s;
+using k8s.Models;
+using Microsoft.AspNetCore.JsonPatch;
+
+namespace patch
+{
+    internal class Program
+    {
+        private static void Main(string[] args)
+        {
+            var config = KubernetesClientConfiguration.BuildConfigFromConfigFile();
+            IKubernetes client = new Kubernetes(config);
+            Console.WriteLine("Starting Request!");
+
+            var pod = client.ListNamespacedPod("default").Items.First();
+
+            var name = pod.Metadata.Name;
+            PrintLabels(pod);
+
+            var newlables = new Dictionary<string, string>(pod.Metadata.Labels)
+            {
+                ["test"] = "test"
+            };
+            var patch = new JsonPatchDocument<V1Pod>();
+            patch.Replace(e => e.Metadata.Labels, newlables);
+            client.PatchNamespacedPod(new V1Patch(patch), name, "default");
+
+            PrintLabels(client.ReadNamespacedPod(name, "default"));
+        }
+
+        private static void PrintLabels(V1Pod pod)
+        {
+            Console.WriteLine($"Lables: for {pod.Metadata.Name}");
+            foreach (var (k, v) in pod.Metadata.Labels)
+            {
+                Console.WriteLine($"{k} : {v}");
+            }
+            Console.WriteLine("=-=-=-=-=-=-=-=-=-=-=");
+        }
+    }
+}

examples/patch/patch.csproj

@@ -0,0 +1,12 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <OutputType>Exe</OutputType>
+    <TargetFramework>netcoreapp2.1</TargetFramework>
+  </PropertyGroup>
+
+    <ItemGroup>
+        <ProjectReference Include="..\..\src\KubernetesClient\KubernetesClient.csproj" />
+    </ItemGroup>
+
+</Project>