Implement ScalewayMachine

Author: Tomy2e

.golangci.yml

@@ -39,6 +39,8 @@ linters:
           alias: apierrors
         - pkg: k8s.io/apimachinery/pkg/util/errors
           alias: utilerrors
+        - pkg: github.com/scaleway/cluster-api-provider-scaleway/internal/service/scaleway/lb/util
+          alias: lbutil
   exclusions:
     generated: lax
     rules:

api/v1alpha1/scalewaymachine_types.go

@@ -2,28 +2,100 @@ package v1alpha1
 
 import (
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	clusterv1 "sigs.k8s.io/cluster-api/api/v1beta1"
 )
 
-// EDIT THIS FILE!  THIS IS SCAFFOLDING FOR YOU TO OWN!
-// NOTE: json tags are required.  Any new fields you add must have json tags for the fields to be serialized.
+const MachineFinalizer = "scalewaycluster.infrastructure.cluster.x-k8s.io/sm-protection"
 
 // ScalewayMachineSpec defines the desired state of ScalewayMachine.
+// +kubebuilder:validation:XValidation:rule="has(self.rootVolume) == has(oldSelf.rootVolume)",message="rootVolume cannot be added or removed"
+// +kubebuilder:validation:XValidation:rule="has(self.publicNetwork) == has(oldSelf.publicNetwork)",message="publicNetwork cannot be added or removed"
 type ScalewayMachineSpec struct {
-	// INSERT ADDITIONAL SPEC FIELDS - desired state of cluster
-	// Important: Run "make" to regenerate code after modifying this file
+	// ProviderID must match the provider ID as seen on the node object corresponding to this machine.
+	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable"
+	// +optional
+	ProviderID *string `json:"providerID,omitempty"`
 
-	// Foo is an example field of ScalewayMachine. Edit scalewaymachine_types.go to remove/update
-	Foo string `json:"foo,omitempty"`
+	// CommercialType of instance (e.g. PRO2-S).
+	// +kubebuilder:default="PRO2-S"
+	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable"
+	CommercialType string `json:"commercialType"`
+
+	// Image ID, Name or Label to use to create the instance.
+	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable"
+	Image ImageSpec `json:"image"`
+
+	// RootVolume defines the characteristics of the system (root) volume.
+	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable"
+	// +optional
+	RootVolume *RootVolumeSpec `json:"rootVolume,omitempty"`
+
+	// PublicNetwork allows attaching public IPs to the instance.
+	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable"
+	// +optional
+	PublicNetwork *PublicNetworkSpec `json:"publicNetwork,omitempty"`
+}
+
+// RootVolumeSpec defines the characteristics of the system (root) volume.
+type RootVolumeSpec struct {
+	// Size of the root volume in GB. Defaults to 20 GB.
+	// +kubebuilder:default=20
+	// +kubebuilder:validation:Minimum=8
+	// +optional
+	Size *int64 `json:"size,omitempty"`
+
+	// Type of the root volume. Can be local or block. Note that not all types
+	// of instances support local volumes.
+	// +kubebuilder:validation:Enum=local;block
+	// +kubebuilder:default="block"
+	// +optional
+	Type *string `json:"type,omitempty"`
+
+	// IOPS is the number of IOPS requested for the disk. This is only applicable for block volumes.
+	// +optional
+	IOPS *int64 `json:"iops,omitempty"`
+}
+
+// PublicNetworkSpec allows enabling the attachment of public IPs to the instance.
+type PublicNetworkSpec struct {
+	// EnableIPv4 defines whether server has IPv4 address enabled.
+	// +optional
+	EnableIPv4 *bool `json:"enableIPv4,omitempty"`
+	// EnableIPv6 defines whether server has IPv6 addresses enabled.
+	// +optional
+	EnableIPv6 *bool `json:"enableIPv6,omitempty"`
+}
+
+// ImageSpec contains an ID, Name or Label to use to create the instance.
+// +kubebuilder:validation:XValidation:rule="(has(self.id) ? 1 : 0) + (has(self.name) ? 1 : 0) + (has(self.label) ? 1 : 0) == 1",message="exactly one of id, name or label must be set"
+type ImageSpec struct {
+	// ID of the image.
+	ID *string `json:"id,omitempty"`
+	// Name of the image.
+	Name *string `json:"name,omitempty"`
+	// Label of the image.
+	Label *string `json:"label,omitempty"`
 }
 
 // ScalewayMachineStatus defines the observed state of ScalewayMachine.
 type ScalewayMachineStatus struct {
-	// INSERT ADDITIONAL STATUS FIELD - define observed state of cluster
-	// Important: Run "make" to regenerate code after modifying this file
+	// Addresses contains the associated addresses for the machine.
+	// +optional
+	Addresses []clusterv1.MachineAddress `json:"addresses,omitempty"`
+
+	// Ready denotes that the Scaleway machine infrastructure is fully provisioned.
+	// NOTE: this field is part of the Cluster API contract and it is used to orchestrate provisioning.
+	// The value of this field is never updated after provisioning is completed. Please use conditions
+	// to check the operational state of the infra machine.
+	// +optional
+	Ready bool `json:"ready"`
 }
 
 // +kubebuilder:object:root=true
 // +kubebuilder:subresource:status
+// +kubebuilder:printcolumn:name="CommercialType",type="string",JSONPath=".spec.commercialType",description="Instance commercial type"
+// +kubebuilder:printcolumn:name="ProviderID",type="string",JSONPath=".spec.providerID",description="Node provider ID"
+// +kubebuilder:printcolumn:name="Ready",type="boolean",JSONPath=".status.ready",description="Indicates whether the Scaleway machine is ready"
 // +kubebuilder:resource:path=scalewaymachines,scope=Namespaced,categories=cluster-api,shortName=sm
 // +kubebuilder:storageversion
 
@@ -32,6 +104,7 @@ type ScalewayMachine struct {
 	metav1.TypeMeta   `json:",inline"`
 	metav1.ObjectMeta `json:"metadata,omitempty"`
 
+	// +kubebuilder:validation:Required
 	Spec   ScalewayMachineSpec   `json:"spec,omitempty"`
 	Status ScalewayMachineStatus `json:"status,omitempty"`
 }

api/v1alpha1/zz_generated.deepcopy.go

@@ -192,10 +192,7 @@ func main() {
 		setupLog.Error(err, "unable to create controller", "controller", "ScalewayCluster")
 		os.Exit(1)
 	}
-	if err = (&controller.ScalewayMachineReconciler{
-		Client: mgr.GetClient(),
-		Scheme: mgr.GetScheme(),
-	}).SetupWithManager(mgr); err != nil {
+	if err = controller.NewScalewayMachineReconciler(mgr.GetClient()).SetupWithManager(mgr); err != nil {
 		setupLog.Error(err, "unable to create controller", "controller", "ScalewayMachine")
 		os.Exit(1)
 	}