|
3 | 3 | using System;
|
4 | 4 | using System.Threading.Tasks;
|
5 | 5 |
|
6 |
| -namespace attach |
7 |
| -{ |
8 |
| - internal class Attach |
9 |
| - { |
10 |
| - private static async Task Main(string[] args) |
11 |
| - { |
12 |
| - var config = KubernetesClientConfiguration.BuildConfigFromConfigFile(); |
13 |
| - IKubernetes client = new Kubernetes(config); |
14 |
| - Console.WriteLine("Starting Request!"); |
| 6 | +var config = KubernetesClientConfiguration.BuildConfigFromConfigFile(); |
| 7 | +IKubernetes client = new Kubernetes(config); |
| 8 | +Console.WriteLine("Starting Request!"); |
15 | 9 |
|
16 |
| - var list = client.CoreV1.ListNamespacedPod("default"); |
17 |
| - var pod = list.Items[0]; |
18 |
| - await AttachToPod(client, pod).ConfigureAwait(false); |
19 |
| - } |
| 10 | +var list = client.CoreV1.ListNamespacedPod("default"); |
| 11 | +var pod = list.Items[0]; |
| 12 | +await AttachToPod(client, pod).ConfigureAwait(false); |
20 | 13 |
|
21 |
| - private static async Task AttachToPod(IKubernetes client, V1Pod pod) |
22 |
| - { |
23 |
| - var webSocket = |
24 |
| - await client.WebSocketNamespacedPodAttachAsync(pod.Metadata.Name, "default", |
25 |
| - pod.Spec.Containers[0].Name).ConfigureAwait(false); |
| 14 | +async Task AttachToPod(IKubernetes client, V1Pod pod) |
| 15 | +{ |
| 16 | + var webSocket = |
| 17 | + await client.WebSocketNamespacedPodAttachAsync(pod.Metadata.Name, "default", |
| 18 | + pod.Spec.Containers[0].Name).ConfigureAwait(false); |
26 | 19 |
|
27 |
| - var demux = new StreamDemuxer(webSocket); |
28 |
| - demux.Start(); |
| 20 | + var demux = new StreamDemuxer(webSocket); |
| 21 | + demux.Start(); |
29 | 22 |
|
30 |
| - var buff = new byte[4096]; |
31 |
| - var stream = demux.GetStream(1, 1); |
32 |
| - while (true) |
33 |
| - { |
34 |
| - var read = stream.Read(buff, 0, 4096); |
35 |
| - var str = System.Text.Encoding.Default.GetString(buff); |
36 |
| - Console.WriteLine(str); |
37 |
| - } |
38 |
| - } |
| 23 | + var buff = new byte[4096]; |
| 24 | + var stream = demux.GetStream(1, 1); |
| 25 | + while (true) |
| 26 | + { |
| 27 | + var read = stream.Read(buff, 0, 4096); |
| 28 | + var str = System.Text.Encoding.Default.GetString(buff); |
| 29 | + Console.WriteLine(str); |
39 | 30 | }
|
40 | 31 | }
|
0 commit comments