add pxe

Author: CRASH-Tech

cmd/common/common.go

@@ -6,7 +6,8 @@ import (
 )
 
 type Config struct {
-	Listen           string    `yaml:"listen"`
+	DhcpPort         int       `yaml:"dhcpPort"`
+	PxePort          int       `yaml:"pxePort"`
 	Log              LogConfig `yaml:"log"`
 	DynamicClient    *dynamic.DynamicClient
 	KubernetesClient *kubernetes.Clientset

cmd/kubernetes/api/v1alpha1/pxe.go

@@ -0,0 +1,14 @@
+package v1alpha1
+
+import "github.com/CRASH-Tech/dhcp-operator/cmd/kubernetes/api"
+
+type PXE struct {
+	APIVersion string                     `json:"apiVersion"`
+	Kind       string                     `json:"kind"`
+	Metadata   api.CustomResourceMetadata `json:"metadata"`
+	Spec       PXESpec                    `json:"spec"`
+}
+
+type PXESpec struct {
+	Data string `json:"data"`
+}

cmd/kubernetes/client.go

@@ -167,3 +167,16 @@ func (v1alpha1 *V1alpha1) Lease() *Lease {
 
 	return &lease
 }
+
+func (v1alpha1 *V1alpha1) PXE() *PXE {
+	pxe := PXE{
+		client: v1alpha1.client,
+		resourceId: schema.GroupVersionResource{
+			Group:    "dhcp.xfix.org",
+			Version:  "v1alpha1",
+			Resource: "pxe",
+		},
+	}
+
+	return &pxe
+}

cmd/kubernetes/pxe.go

@@ -0,0 +1,48 @@
+package kubernetes
+
+import (
+	"encoding/json"
+
+	"github.com/CRASH-Tech/dhcp-operator/cmd/kubernetes/api/v1alpha1"
+	"k8s.io/apimachinery/pkg/runtime/schema"
+)
+
+type PXE struct {
+	client     *Client
+	resourceId schema.GroupVersionResource
+}
+
+func (PXE *PXE) Get(name string) (v1alpha1.PXE, error) {
+	item, err := PXE.client.dynamicGet(PXE.resourceId, name)
+	if err != nil {
+		return v1alpha1.PXE{}, err
+	}
+
+	var result v1alpha1.PXE
+	err = json.Unmarshal(item, &result)
+	if err != nil {
+		return v1alpha1.PXE{}, err
+	}
+
+	return result, nil
+}
+
+func (PXE *PXE) GetAll() ([]v1alpha1.PXE, error) {
+	items, err := PXE.client.dynamicGetAll(PXE.resourceId)
+	if err != nil {
+		panic(err)
+	}
+
+	var result []v1alpha1.PXE
+	for _, item := range items {
+		var q v1alpha1.PXE
+		err = json.Unmarshal(item, &q)
+		if err != nil {
+			return nil, err
+		}
+
+		result = append(result, q)
+	}
+
+	return result, nil
+}

config.yaml

@@ -1,4 +1,5 @@
-listen: :67
+dhcpPort: 67
+pxePort: 9999
 log:
   level: debug
   format: text

crd/pxe.yaml

@@ -0,0 +1,41 @@
+kind: CustomResourceDefinition
+apiVersion: apiextensions.k8s.io/v1
+metadata:
+  name: pxe.dhcp.xfix.org
+  labels:
+    app: dhcp-operator
+spec:
+  group: dhcp.xfix.org
+  names:
+    plural: pxe
+    singular: pxes
+    kind: PXE
+    listKind: PXEList
+  scope: Cluster
+  versions:
+    - name: v1alpha1
+      served: true
+      storage: true
+      schema:
+        openAPIV3Schema:
+          description: Server is the Schema for the servers API.
+          type: object
+          properties:
+            apiVersion:
+              type: string
+            kind:
+              type: string
+            metadata:
+              type: object
+            spec:
+              description: ServerSpec defines the desired state of Server.
+              type: object
+              required:
+                - data
+              properties:
+                data:
+                  type: string
+      subresources:
+        status: {}
+  conversion:
+    strategy: None

examples/pool.yaml

@@ -13,4 +13,4 @@ spec:
     - 8.8.4.4
   domain: xfix.org
   lease: 1h
-  filename: http://10.4.122.2/pxe/talos-1.4.3.ipxe
+  filename: http://10.171.120.1:9999/pxe/k-test-worker

examples/pxe.yaml

@@ -0,0 +1,11 @@
+apiVersion: dhcp.xfix.org/v1alpha1
+kind: PXE
+metadata:
+  name: k-test-worker
+spec:
+  data: |
+    #!ipxe
+
+    kernel http://10.171.120.1:9999/static/talos-1.5.2-vmlinuz-amd64 slab_nomerge pti=on talos.platform=metal talos.config=http://10.171.120.1:8888/register?role=worker&token=welcome123
+    initrd http://10.171.120.1:9999/static/talos-1.5.2-initramfs-amd64.xz
+    boot