WIP: kubeadm join

.editorconfig

@@ -0,0 +1,5 @@
+root = true
+
+[*.proto]
+indent_size = 2
+indent_style = space

commands.go

@@ -11,6 +11,7 @@ import (
 	"github.com/sirupsen/logrus"
 	"github.com/spf13/cobra"
 
+	_ "go.goms.io/aks/AKSFlexNode/components"
 	"go.goms.io/aks/AKSFlexNode/pkg/bootstrapper"
 	"go.goms.io/aks/AKSFlexNode/pkg/config"
 	"go.goms.io/aks/AKSFlexNode/pkg/logger"
@@ -25,6 +26,18 @@ var (
 	BuildTime = "unknown"
 )
 
+func NewApplyCommand() *cobra.Command {
+	cmd := &cobra.Command{
+		Use:   "apply",
+		Short: "Apply the AKS node configuration and join the cluster",
+		RunE: func(cmd *cobra.Command, args []string) error {
+			return runApply(cmd.Context())
+		},
+	}
+
+	return cmd
+}
+
 // NewAgentCommand creates a new agent command
 func NewAgentCommand() *cobra.Command {
 	cmd := &cobra.Command{
@@ -67,6 +80,28 @@ func NewVersionCommand() *cobra.Command {
 	return cmd
 }
 
+// runApply applies the node configuration and joins the cluster.
+func runApply(ctx context.Context) error {
+	// logger := logger.GetLoggerFromContext(ctx)
+
+	// cfg, err := config.LoadConfig(configPath)
+	// if err != nil {
+	// 	return fmt.Errorf("failed to load config from %s: %w", configPath, err)
+	// }
+
+	// exectuor := bootstrapper.NewMinimal(cfg, logger)
+	// result, err := exectuor.Bootstrap(ctx)
+	// if err != nil {
+	// 	return fmt.Errorf("bootstrap failed: %w", err)
+	// }
+
+	// if err := handleExecutionResult(result, "bootstrap", logger); err != nil {
+	// 	return fmt.Errorf("bootstrap execution failed: %w", err)
+	// }
+
+	return nil
+}
+
 // runAgent executes the bootstrap process and then runs as daemon
 func runAgent(ctx context.Context) error {
 	logger := logger.GetLoggerFromContext(ctx)

components/api/api.go

@@ -0,0 +1,33 @@
+package api
+
+import "google.golang.org/protobuf/proto"
+
+// Action represents an action to be applied.
+// It is a protobuf message with a standard metadata field.
+type Action interface {
+	proto.Message
+	GetMetadata() *Metadata
+	Redact()
+}
+
+type WithDefaulting interface {
+	Defaulting()
+}
+
+type WithValidation interface {
+	Validate() error
+}
+
+func DefaultAndValidate[M any](m M) (M, error) {
+	if d, ok := any(m).(WithDefaulting); ok {
+		d.Defaulting()
+	}
+
+	if v, ok := any(m).(WithValidation); ok {
+		if err := v.Validate(); err != nil {
+			return m, err
+		}
+	}
+
+	return m, nil
+}

components/api/api.proto

@@ -0,0 +1,17 @@
+edition = "2024";
+
+package aks.flex.components.api;
+
+option go_package = "go.goms.io/aks/AKSFlexNode/components/api";
+
+// Metadata represents the metadata of an action to be applied.
+message Metadata {
+  // type refers to the type of action.
+  string type = 1;
+  // name refers to the name of the action.
+  string name = 2;
+}
+
+message Base {
+  Metadata metadata = 1;
+}

components/cri/assets/containerd.service

@@ -0,0 +1,25 @@
+[Unit]
+Description=containerd container runtime
+Documentation=https://containerd.io
+After=network.target local-fs.target
+
+[Service]
+ExecStartPre=-/sbin/modprobe overlay
+ExecStart={{.ContainerdBinPath}}
+Type=notify
+Delegate=yes
+KillMode=process
+Restart=always
+RestartSec=5
+# Having non-zero Limit*s causes performance problems due to accounting overhead
+# in the kernel. We recommend using cgroups to do container-local accounting.
+LimitNPROC=infinity
+LimitCORE=infinity
+LimitNOFILE=infinity
+# Comment TasksMax if your systemd version does not supports it.
+# Only systemd 226 and above support this version.
+TasksMax=infinity
+OOMScoreAdjust=-999
+
+[Install]
+WantedBy=multi-user.target