virtual-kubelet controller integration

.github/workflows/release.yml

@@ -40,14 +40,23 @@ jobs:
         username: ${{ env.DOCKER_USERNAME }}
         password: ${{ env.DOCKER_PASSWORD }}
 
-    - name: Build container image
+    - name: Build controller image
       uses: docker/build-push-action@v5
       with:
         context: .
         push: true
         tags: rancher/k3k:${{ github.ref_name }}
         file: package/Dockerfile
         platforms: linux/amd64
+
+    - name: Build Virtual Kubelet image
+      uses: docker/build-push-action@v5
+      with:
+        context: .
+        push: true
+        tags: rancher/k3k:k3k-kubelet
+        file: package/Dockerfile.kubelet
+        platforms: linux/amd64
 
 
 

charts/k3k/crds/k3k.io_clusters.yaml

@@ -135,6 +135,15 @@ spec:
                 description: NodeSelector is the node selector that will be applied
                   to all server/agent pods
                 type: object
+              mode:
+                description: Mode is the cluster provisioning mode which can be either
+                  "virtual" or "shared". Defaults to "shared"
+                type: string
+                x-kubernetes-validations:
+                - message: mode is immutable
+                  rule: self == oldSelf
+                - message: invalid value for mode
+                  rule: self == "virtual" || self == "shared"
               persistence:
                 description: |-
                   Persistence contains options controlling how the etcd data of the virtual cluster is persisted. By default, no data
@@ -191,6 +200,7 @@ spec:
                 type: string
             required:
             - agents
+            - mode
             - servers
             - token
             - version

k3k-kubelet/config.go

@@ -0,0 +1,72 @@
+package main
+
+import (
+	"errors"
+	"os"
+
+	"gopkg.in/yaml.v2"
+)
+
+// Config has all virtual-kubelet startup options
+type config struct {
+	clusterName       string `yaml:"clusterName"`
+	clusterNamespace  string `yaml:"clusterNamespace"`
+	hostConfigPath    string `yaml:"hostConfigPath"`
+	virtualConfigPath string `yaml:"virtualConfigPath"`
+	kubeletPort       string `yaml:"kubeletPort"`
+	nodeName          string `yaml:"nodeName"`
+	agentPodIP        string `yaml:"agentPodIP"`
+	token             string `yaml:"token"`
+}
+
+func (t *config) UnmarshalYAML(data []byte) error {
+	var c config
+	if err := yaml.Unmarshal(data, &c); err != nil {
+		return err
+	}
+	if t.clusterName == "" {
+		t.clusterName = c.clusterName
+	}
+	if t.clusterNamespace == "" {
+		t.clusterNamespace = c.clusterNamespace
+	}
+	if t.hostConfigPath == "" {
+		t.hostConfigPath = c.hostConfigPath
+	}
+	if t.virtualConfigPath == "" {
+		t.virtualConfigPath = c.virtualConfigPath
+	}
+	if t.kubeletPort == "" {
+		t.kubeletPort = c.kubeletPort
+	}
+	if t.nodeName == "" {
+		t.nodeName = c.nodeName
+	}
+
+	return nil
+}
+
+func (t *config) Validate() error {
+	if t.clusterName == "" {
+		return errors.New("cluster name is not provided")
+	}
+	if t.clusterNamespace == "" {
+		return errors.New("cluster namespace is not provided")
+	}
+	if t.agentPodIP == "" {
+		return errors.New("agent POD IP is not provided")
+	}
+	return nil
+}
+
+func (t *config) Parse(path string) error {
+	if _, err := os.Stat(path); os.IsNotExist(err) {
+		return nil
+	}
+
+	configFileBytes, err := os.ReadFile(path)
+	if err != nil {
+		return err
+	}
+	return t.UnmarshalYAML(configFileBytes)
+}