fix: add command to create cloud provider kind

cli/src/Vdk/Commands/CreateCloudProviderKindCommand.cs

@@ -0,0 +1,24 @@
+using System.CommandLine;
+using Vdk.Services;
+using IConsole = Vdk.Services.IConsole;
+
+namespace Vdk.Commands;
+
+public class CreateCloudProviderKindCommand: Command
+{
+    private readonly IConsole _console;
+    private readonly IHubClient _client;
+
+    public CreateCloudProviderKindCommand(IConsole console, IHubClient client): base("cloud-provider-kind", "Create Vega VDK Cloud Provider kind container registry")
+    {
+        _console = console;
+        _client = client;
+        this.SetHandler(InvokeAsync);
+    }
+
+    public Task InvokeAsync()
+    {
+        _client.CreateCloudProviderKind();
+        return Task.CompletedTask;
+    }
+}

cli/src/Vdk/Commands/CreateClusterCommand.cs

@@ -61,8 +61,8 @@ public async Task InvokeAsync(string name = Defaults.ClusterName, int controlPla
         // check if the hub and proxy are there
         if (!_reverseProxy.Exists())
             _reverseProxy.Create();
-        if (!_hub.Exists())
-            _hub.Create();
+        if (!_hub.ExistRegistry())
+            _hub.CreateRegistry();
 
         var map = await _kindVersionInfo.GetVersionInfoAsync();
         string? kindVersion = null;

cli/src/Vdk/Commands/CreateCommand.cs

@@ -4,11 +4,12 @@ namespace Vdk.Commands;
 
 public class CreateCommand: Command
 {
-    public CreateCommand(CreateClusterCommand createCluster, CreateRegistryCommand createRegistry, CreateProxyCommand createProxy) 
+    public CreateCommand(CreateClusterCommand createCluster, CreateRegistryCommand createRegistry, CreateProxyCommand createProxy, CreateCloudProviderKindCommand createCloudProviderKindCommand) 
         : base("create", "Create vega development resources")
     {
         AddCommand(createCluster);
         AddCommand(createRegistry);
         AddCommand(createProxy);
+        AddCommand(createCloudProviderKindCommand);
     }
 }

cli/src/Vdk/Commands/CreateRegistryCommand.cs

@@ -18,7 +18,7 @@ public CreateRegistryCommand(IConsole console, IHubClient client): base("registr
 
     public Task InvokeAsync()
     {
-        _client.Create();
+        _client.CreateRegistry();
         return Task.CompletedTask;
     }
 }

cli/src/Vdk/Commands/RemoveCloudProviderKindCommand.cs

@@ -0,0 +1,24 @@
+using System.CommandLine;
+using Vdk.Services;
+using IConsole = Vdk.Services.IConsole;
+
+namespace Vdk.Commands;
+
+public class RemoveCloudProviderKindCommand: Command
+{
+    private readonly IConsole _console;
+    private readonly IHubClient _client;
+
+    public RemoveCloudProviderKindCommand(IConsole console, IHubClient client) : base("cloud-provider-kind", "Remove Vega VDK Cloud Provider Kind")
+    {
+        _console = console;
+        _client = client;
+        this.SetHandler(InvokeAsync);
+    }
+
+    public Task InvokeAsync()
+    {
+        _client.DestroyCloudProviderKind();
+        return Task.CompletedTask;
+    }
+}

cli/src/Vdk/Commands/RemoveCommand.cs

@@ -4,11 +4,12 @@ namespace Vdk.Commands;
 
 public class RemoveCommand: Command
 {
-    public RemoveCommand(RemoveClusterCommand removeCluster, RemoveRegistryCommand removeRegistry, RemoveProxyCommand removeProxy) 
+    public RemoveCommand(RemoveClusterCommand removeCluster, RemoveRegistryCommand removeRegistry, RemoveProxyCommand removeProxy, RemoveCloudProviderKindCommand removeCloudProviderKindCommand) 
         : base("remove", "Remove Vega development resources")
     {
         AddCommand(removeCluster);
         AddCommand(removeRegistry);
         AddCommand(removeProxy);
+        AddCommand(removeCloudProviderKindCommand);
     }
 }

cli/src/Vdk/Commands/RemoveRegistryCommand.cs

@@ -18,7 +18,7 @@ public RemoveRegistryCommand(IConsole console, IHubClient client) : base("regist
 
     public Task InvokeAsync()
     {
-        _client.Destroy();
+        _client.DestroyRegistry();
         return Task.CompletedTask;
     }
 }

cli/src/Vdk/Constants/Containers.cs

@@ -8,4 +8,6 @@ public static class Containers
     public const int RegistryHostPort = 5000;
     public const string ProxyName = "vega-proxy";
     public const string ProxyImage = "nginx:latest";
+    public const string CloudProviderKindName = "cloud-provider-kind";
+    public const string CloudProviderKindImage = "registry.k8s.io/cloud-provider-kind/cloud-controller-manager:v0.6.0";
 }

cli/src/Vdk/Properties/launchSettings.json

@@ -14,7 +14,7 @@
     },
     "create-clutser": {
       "commandName": "Project",
-      "commandLineArgs": "create cluster"
+      "commandLineArgs": "create cloud-provider-kind"
     },
     "WSL": {
       "commandName": "WSL2",

cli/src/Vdk/ServiceProviderBuilder.cs

@@ -44,7 +44,9 @@ public static IServiceProvider Build()
             .AddSingleton<CreateProxyCommand>()
             .AddSingleton<RemoveProxyCommand>()
             .AddSingleton<CreateRegistryCommand>()
+            .AddSingleton<CreateCloudProviderKindCommand>()
             .AddSingleton<RemoveRegistryCommand>()
+            .AddSingleton<RemoveCloudProviderKindCommand>()
             .AddSingleton<UpdateCommand>()
             .AddSingleton<UpdateKindVersionInfoCommand>()
             .AddSingleton<IKindVersionInfoService, KindVersionInfoService>()

cli/src/Vdk/Services/DockerHubClient.cs

@@ -5,9 +5,9 @@ namespace Vdk.Services;
 
 public class DockerHubClient(IDockerEngine docker, IConsole console) : IHubClient
 {
-    public void Create()
+    public void CreateRegistry()
     {
-        if (Exists()) return;
+        if (ExistRegistry()) return;
         console.WriteLine("Creating Vega VDK Registry");
         console.WriteLine(" - This may take a few minutes...");
         docker.Run(Containers.RegistryImage,
@@ -18,16 +18,47 @@ public void Create()
             null);
     }
 
-    public void Destroy()
+    public void CreateCloudProviderKind()
     {
-        if (!Exists()) return;
+        if (ExistCloudProviderKind()) return;
+        console.WriteLine("Creating Cloud Provider Kind");
+        // docker run -d --name cloud-provider-kind --network kind -v /var/run/docker.sock:/var/run/docker.sock registry.k8s.io/cloud-provider-kind/cloud-controller-manager:v0.6.0
+        var volumes = new List<FileMapping>()
+        {
+            new()
+            {
+                Source = "/var/run/docker.sock",
+                Destination = "/var/run/docker.sock"
+            }
+        };
+        docker.Run(Containers.CloudProviderKindImage,
+            Containers.CloudProviderKindName,
+            null, null, volumes.ToArray(), null, "kind");
+    }
+
+
+    public void DestroyRegistry()
+    {
+        if (!ExistRegistry()) return;
         console.WriteWarning("Deleting Vega VDK Registry from Docker");
         console.WriteLine("You can recreate the registry using command 'vega create registry'");
         docker.Delete(Containers.RegistryName);
     }
 
-    public bool Exists()
+    public void DestroyCloudProviderKind()
+    {
+        if (!ExistCloudProviderKind()) return;
+        console.WriteWarning("Deleting Cloud Provider Kind from Docker");
+        docker.Delete(Containers.CloudProviderKindName);
+    }
+
+    public bool ExistRegistry()
     {
         return docker.Exists(Containers.RegistryName);
     }
+
+    public bool ExistCloudProviderKind()
+    {
+        return docker.Exists(Containers.CloudProviderKindName);
+    }
 }

cli/src/Vdk/Services/IDockerEngine.cs

@@ -4,7 +4,7 @@ namespace Vdk.Services;
 
 public interface IDockerEngine
 {
-    bool Run(string image, string name, PortMapping[]? ports, Dictionary<string, string>? envs, FileMapping[]? volumes, string[]? commands);
+    bool Run(string image, string name, PortMapping[]? ports, Dictionary<string, string>? envs, FileMapping[]? volumes, string[]? commands, string? network = null);
 
     bool Exists(string name,bool checkRunning = true);
 

cli/src/Vdk/Services/IHubClient.cs

@@ -2,9 +2,15 @@ namespace Vdk.Services;
 
 public interface IHubClient
 {
-    void Create();
+    void CreateRegistry();
 
-    void Destroy();
+    void CreateCloudProviderKind();
 
-    bool Exists();
+    void DestroyRegistry();
+
+    void DestroyCloudProviderKind();
+
+    bool ExistRegistry();
+
+    bool ExistCloudProviderKind();
 }

cli/src/Vdk/Services/LocalDockerClient.cs

@@ -12,7 +12,7 @@ public LocalDockerClient(Docker.DotNet.IDockerClient dockerClient)
         _dockerClient = dockerClient;
     }
 
-    public bool Run(string image, string name, PortMapping[]? ports, Dictionary<string, string>? envs, FileMapping[]? volumes, string[]? commands)
+    public bool Run(string image, string name, PortMapping[]? ports, Dictionary<string, string>? envs, FileMapping[]? volumes, string[]? commands, string? network = null)
     {
         _dockerClient.Images.CreateImageAsync(
           new ImagesCreateParameters
@@ -27,7 +27,8 @@ public bool Run(string image, string name, PortMapping[]? ports, Dictionary<stri
             {
                 Image = image,
                 Name = name,
-
+
+
                 Labels = new Dictionary<string, string> { { "vega-component", name } },
                 ExposedPorts = ports?.ToDictionary(x => $"{x.ContainerPort}/tcp", y => default(EmptyStruct)),
                 Volumes = volumes?.ToDictionary(x => x.Destination, y => new EmptyStruct()),
@@ -43,6 +44,34 @@ public bool Run(string image, string name, PortMapping[]? ports, Dictionary<stri
 
                 }
             }).GetAwaiter().GetResult();
+        // Connect to custom Docker network if specified
+        if (!string.IsNullOrWhiteSpace(network))
+        {
+            var networkList = _dockerClient.Networks
+                .ListNetworksAsync(new NetworksListParameters
+                {
+                    Filters = new Dictionary<string, IDictionary<string, bool>>
+                    {
+                        { "name", new Dictionary<string, bool> { { network, true } } }
+                    }
+                })
+                .GetAwaiter()
+                .GetResult();
+
+            var dockerNetwork = networkList?.FirstOrDefault();
+            if (dockerNetwork == null)
+            {
+                throw new Exception($"Docker network '{network}' not found.");
+            }
+
+            _dockerClient.Networks
+                .ConnectNetworkAsync(dockerNetwork.ID, new NetworkConnectParameters
+                {
+                    Container = response.ID
+                })
+                .GetAwaiter()
+                .GetResult();
+        }
 
         return _dockerClient.Containers.StartContainerAsync(response.ID, new ContainerStartParameters() { }).GetAwaiter().GetResult();
     }

docs/usage/command-reference.md

@@ -39,3 +39,10 @@ Gets the kubeconfig path for a cluster.
 **Flags:**
 
 *   `--name string`: Name of the cluster (default: `kind`)
+
+# `vdk create cloud-provider-kind`
+
+Creates a cloud Provider KIND docker image which runs as a standalone binary in the local machine 
+and will connect to the Kind cluster and provision new Load balancer containers for the services.
+
+