poc implementation of actuator (without delete)

Makefile

@@ -27,6 +27,7 @@ build: generate fmt vet $(BIN_FILENAME) ## Build manager binary
 .PHONY: generate
 generate: ## Generate e.g. CRD, RBAC etc.
 	go generate ./...
+	go run sigs.k8s.io/controller-tools/cmd/controller-gen object paths="./..."
 
 .PHONY: fmt
 fmt: ## Run go fmt against code

api/cloudscale/provider/v1beta1/cloudscaleprovider_types.go

@@ -0,0 +1,92 @@
+package v1beta1
+
+import (
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+)
+
+type InterfaceType string
+
+const (
+	// InterfaceTypePublic is a public network interface.
+	InterfaceTypePublic InterfaceType = "Public"
+	// InterfaceTypePrivate is a private network interface.
+	InterfaceTypePrivate InterfaceType = "Private"
+)
+
+// CloudscaleMachineProviderSpec is the type that will be embedded in a Machine.Spec.ProviderSpec field
+// for a Cloudscale virtual machine. It is used by the GCP machine actuator to create a single Machine.
+// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
+type CloudscaleMachineProviderSpec struct {
+	metav1.TypeMeta `json:",inline"`
+
+	// ObjectMeta is the standard object's metadata.
+	// More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#metadata
+	metav1.ObjectMeta `json:"metadata,omitempty"`
+
+	// Zone is the zone in which the machine will be created.
+	Zone string `json:"zone"`
+	// ServerGroups is a list of UUIDs identifying the server groups to which the new server will be added.
+	// Used for anti-affinity.
+	// https://www.cloudscale.ch/en/api/v1#server-groups
+	ServerGroups []string `json:"serverGroups,omitempty"`
+	// Tags is a map of tags to apply to the machine.
+	Tags map[string]string `json:"tags"`
+	// Flavor is the flavor of the machine.
+	Flavor string `json:"flavor"`
+	// Image is the base image to use for the machine.
+	// For images provided by cloudscale: the image’s slug.
+	// For custom images: the image’s slug prefixed with custom: (e.g. custom:ubuntu-foo), or its UUID.
+	// If multiple custom images with the same slug exist, the newest custom image will be used.
+	// https://www.cloudscale.ch/en/api/v1#images
+	Image string `json:"image"`
+	// RootVolumeSizeGB is the size of the root volume in GB.
+	RootVolumeSizeGB int `json:"volumeSizeGB"`
+	// SSHKeys is a list of SSH keys to add to the machine.
+	SSHKeys []string `json:"sshKeys"`
+	// UserData is the user data to pass to the machine.
+	// Can be used for ignition or cloud-init.
+	UserData string `json:"userData"`
+	// UseIPV6 is a flag to enable IPv6 on the machine.
+	// Defaults to true.
+	UseIPV6 *bool `json:"useIPV6,omitempty"`
+	// Interfaces is a list of network interfaces to add to the machine.
+	Interfaces []Interface `json:"interfaces"`
+}
+
+// Interface is a network interface to add to a machine.
+type Interface struct {
+	// Type is the type of the interface. Required.
+	Type InterfaceType `json:"type"`
+	// NetworkUUID is the UUID of the network to attach the interface to.
+	// Can only be set if type is private.
+	// Must be compatible with Addresses.SubnetUUID if both are specified.
+	NetworkUUID string `json:"networkUUID"`
+	// Addresses is an optional list of addresses to assign to the interface.
+	// Can only be set if type is private.
+	Addresses []Address `json:"addresses"`
+}
+
+// Address is an address to assign to a network interface.
+type Address struct {
+	// Address is an optional IP address to assign to the interface.
+	Address string `json:"address"`
+	// SubnetUUID is the UUID of the subnet to assign the address to.
+	// Must be compatible with Interface.NetworkUUID if both are specified.
+	SubnetUUID string `json:"subnetUUID"`
+}
+
+// CloudscaleMachineProviderStatus is the type that will be embedded in a Machine.Status.ProviderStatus field.
+// It contains cloudscale-specific status information.
+type CloudscaleMachineProviderStatus struct {
+	metav1.TypeMeta `json:",inline"`
+
+	// InstanceID is the ID of the instance in Cloudscale.
+	// +optional
+	InstanceID string `json:"instanceId,omitempty"`
+	// Status is the status of the instance in Cloudscale.
+	// Can be "changing", "running" or "stopped".
+	Status string `json:"status,omitempty"`
+	// Conditions is a set of conditions associated with the Machine to indicate
+	// errors or other status
+	Conditions []metav1.Condition `json:"conditions,omitempty"`
+}

api/cloudscale/provider/v1beta1/conversions.go

@@ -0,0 +1,80 @@
+package v1beta1
+
+import (
+	"encoding/json"
+	"fmt"
+
+	"k8s.io/apimachinery/pkg/runtime"
+	"k8s.io/klog/v2"
+	"sigs.k8s.io/yaml"
+)
+
+// RawExtensionFromProviderSpec marshals the machine provider spec.
+func RawExtensionFromProviderSpec(spec *CloudscaleMachineProviderSpec) (*runtime.RawExtension, error) {
+	if spec == nil {
+		return &runtime.RawExtension{}, nil
+	}
+
+	s := spec.DeepCopy()
+	s.APIVersion = GroupVersion.String()
+
+	var rawBytes []byte
+	var err error
+	if rawBytes, err = json.Marshal(s); err != nil {
+		return nil, fmt.Errorf("error marshalling providerSpec: %v", err)
+	}
+
+	return &runtime.RawExtension{
+		Raw: rawBytes,
+	}, nil
+}
+
+// RawExtensionFromProviderStatus marshals the provider status
+func RawExtensionFromProviderStatus(status *CloudscaleMachineProviderStatus) (*runtime.RawExtension, error) {
+	if status == nil {
+		return &runtime.RawExtension{}, nil
+	}
+
+	s := status.DeepCopy()
+	s.APIVersion = GroupVersion.String()
+
+	var rawBytes []byte
+	var err error
+	if rawBytes, err = json.Marshal(s); err != nil {
+		return nil, fmt.Errorf("error marshalling providerStatus: %v", err)
+	}
+
+	return &runtime.RawExtension{
+		Raw: rawBytes,
+	}, nil
+}
+
+// ProviderSpecFromRawExtension unmarshals the JSON-encoded spec
+func ProviderSpecFromRawExtension(rawExtension *runtime.RawExtension) (*CloudscaleMachineProviderSpec, error) {
+	if rawExtension == nil {
+		return &CloudscaleMachineProviderSpec{}, nil
+	}
+
+	spec := new(CloudscaleMachineProviderSpec)
+	if err := yaml.Unmarshal(rawExtension.Raw, &spec); err != nil {
+		return nil, fmt.Errorf("error unmarshalling providerSpec: %v", err)
+	}
+
+	klog.V(5).Infof("Got provider spec from raw extension: %+v", spec)
+	return spec, nil
+}
+
+// ProviderStatusFromRawExtension unmarshals a raw extension into a GCPMachineProviderStatus type
+func ProviderStatusFromRawExtension(rawExtension *runtime.RawExtension) (*CloudscaleMachineProviderStatus, error) {
+	if rawExtension == nil {
+		return &CloudscaleMachineProviderStatus{}, nil
+	}
+
+	providerStatus := new(CloudscaleMachineProviderStatus)
+	if err := yaml.Unmarshal(rawExtension.Raw, providerStatus); err != nil {
+		return nil, fmt.Errorf("error unmarshalling providerStatus: %v", err)
+	}
+
+	klog.V(5).Infof("Got provider Status from raw extension: %+v", providerStatus)
+	return providerStatus, nil
+}

api/cloudscale/provider/v1beta1/doc.go

@@ -0,0 +1,12 @@
+package v1beta1
+
+import "k8s.io/apimachinery/pkg/runtime/schema"
+
+// +k8s:deepcopy-gen=package
+// +k8s:defaulter-gen=TypeMeta
+// +k8s:openapi-gen=true
+
+var (
+	GroupName    = "machine.appuio.io"
+	GroupVersion = schema.GroupVersion{Group: GroupName, Version: "v1beta1"}
+)