Non-blocking standard output stream parsing

Author: avin3sh

src/KubernetesClient/KubernetesClientConfiguration.ConfigFile.cs

@@ -5,6 +5,7 @@
 using System.Net;
 using System.Runtime.InteropServices;
 using System.Security.Cryptography.X509Certificates;
+using System.Text;
 
 namespace k8s
 {
@@ -537,13 +538,23 @@ public static ExecCredentialResponse ExecuteExternalCommand(ExternalExecution co
 
             try
             {
-                var responseObject = KubernetesJson.Deserialize<ExecCredentialResponse>(process.StandardOutput.ReadToEnd());
+                var output = new StringBuilder();
+                process.OutputDataReceived += (_, args) =>
+                {
+                    if (args.Data != null)
+                    {
+                        output.Append(args.Data);
+                    }
+                };
+                process.BeginOutputReadLine();
 
                 if (!process.WaitForExit((int)ExecTimeout.TotalMilliseconds))
                 {
                     throw new KubeConfigException("external exec failed due to timeout");
                 }
 
+                var responseObject = KubernetesJson.Deserialize<ExecCredentialResponse>(output.ToString());
+
                 if (responseObject == null || responseObject.ApiVersion != config.ApiVersion)
                 {
                     throw new KubeConfigException(
@@ -554,10 +565,8 @@ public static ExecCredentialResponse ExecuteExternalCommand(ExternalExecution co
                 {
                     return responseObject;
                 }
-                else
-                {
-                    throw new KubeConfigException($"external exec failed missing token or clientCertificateData field in plugin output");
-                }
+
+                throw new KubeConfigException($"external exec failed missing token or clientCertificateData field in plugin output");
             }
             catch (JsonException ex)
             {