Create and delete machines via controller (#36)

* Create and delete machines via controller * Update cloud/scope/cluster.go Co-authored-by: Alex Vest <[email protected]> --------- Co-authored-by: Richard Kovacs <[email protected]> Co-authored-by: Alex Vest <[email protected]>
linode · Dec 18, 2023 · 74848ed · 74848ed
1 parent e3d5889
commit 74848ed
Show file tree

Hide file tree

Showing 20 changed files with 1,114 additions and 82 deletions.
diff --git a/Makefile b/Makefile
@@ -127,8 +127,9 @@ undeploy: ## Undeploy controller from the K8s cluster specified in ~/.kube/confi
 
 .PHONY: tilt-cluster
 tilt-cluster: ctlptl tilt clusterctl
-	ctlptl apply -f ctlptl-config.yaml
-	tilt up
+	@echo -n "LINODE_TOKEN=$(LINODE_TOKEN)" > config/default/.env.linode
+	$(CTLPTL) apply -f ctlptl-config.yaml
+	$(TILT) up
 
 ##@ Build Dependencies
 

diff --git a/README.md b/README.md
@@ -6,7 +6,7 @@ A [Cluster API](https://cluster-api.sigs.k8s.io/) implementation for the [Linode
 For local development execute the following `make` target:
 
 ```bash
-make tilt-cluster
+LINODE_TOKEN=<YOUR LINODE TOKEN> make tilt-cluster
 ```
 
 This command creates a Kind cluster, and deploys resources via Tilt. You can freely change the code and wait for Tilt to update provider.
diff --git a/api/v1alpha1/linodemachine_types.go b/api/v1alpha1/linodemachine_types.go
@@ -17,25 +17,137 @@ limitations under the License.
 package v1alpha1
 
 import (
+	"github.com/linode/linodego"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	clusterv1 "sigs.k8s.io/cluster-api/api/v1beta1"
+	"sigs.k8s.io/cluster-api/errors"
 )
 
 // 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.
 
 // LinodeMachineSpec defines the desired state of LinodeMachine
 type LinodeMachineSpec struct {
-	// INSERT ADDITIONAL SPEC FIELDS - desired state of cluster
-	// Important: Run "make" to regenerate code after modifying this file
+	// ProviderID is the unique identifier as specified by the cloud provider.
+	ProviderID *string `json:"providerID,omitempty"`
+	// InstanceID is the Linode instance ID for this machine.
+	InstanceID *int `json:"instanceID,omitempty"`
 
-	// Foo is an example field of LinodeMachine. Edit linodemachine_types.go to remove/update
-	Foo string `json:"foo,omitempty"`
+	// +kubebuilder:validation:Required
+	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable"
+	Region string `json:"region"`
+	// +kubebuilder:validation:Required
+	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable"
+	Type string `json:"type"`
+	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable"
+	Label string `json:"label,omitempty"`
+	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable"
+	Group string `json:"group,omitempty"`
+	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable"
+	RootPass string `json:"rootPass,omitempty"`
+	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable"
+	AuthorizedKeys []string `json:"authorizedKeys,omitempty"`
+	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable"
+	AuthorizedUsers []string `json:"authorizedUsers,omitempty"`
+	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable"
+	StackScriptID int `json:"stackscriptId,omitempty"`
+	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable"
+	StackScriptData map[string]string `json:"stackscriptData,omitempty"`
+	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable"
+	BackupID int `json:"backupId,omitempty"`
+	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable"
+	Image string `json:"image,omitempty"`
+	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable"
+	Interfaces []InstanceConfigInterfaceCreateOptions `json:"interfaces,omitempty"`
+	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable"
+	BackupsEnabled bool `json:"backupsEnabled,omitempty"`
+	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable"
+	PrivateIP bool `json:"privateIp,omitempty"`
+	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable"
+	Tags []string `json:"tags,omitempty"`
+	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable"
+	Metadata *InstanceMetadataOptions `json:"metadata,omitempty"`
+	// +kubebuilder:validation:XValidation:rule="self == oldSelf",message="Value is immutable"
+	FirewallID int `json:"firewallId,omitempty"`
+}
+
+// InstanceMetadataOptions defines metadata of instance
+type InstanceMetadataOptions struct {
+	// UserData expects a Base64-encoded string
+	UserData string `json:"userData,omitempty"`
+}
+
+// InstanceConfigInterfaceCreateOptions defines network interface config
+type InstanceConfigInterfaceCreateOptions struct {
+	IPAMAddress string                          `json:"ipamAddress,omitempty"`
+	Label       string                          `json:"label,omitempty"`
+	Purpose     linodego.ConfigInterfacePurpose `json:"purpose,omitempty"`
+	Primary     bool                            `json:"primary,omitempty"`
+	SubnetID    *int                            `json:"subnetId,omitempty"`
+	IPv4        *VPCIPv4                        `json:"ipv4,omitempty"`
+	IPRanges    []string                        `json:"ipRanges,omitempty"`
+}
+
+// VPCIPv4 defines VPC IPV4 settings
+type VPCIPv4 struct {
+	VPC     string `json:"vpc,omitempty"`
+	NAT1To1 string `json:"nat1to1,omitempty"`
 }
 
 // LinodeMachineStatus defines the observed state of LinodeMachine
 type LinodeMachineStatus struct {
-	// INSERT ADDITIONAL STATUS FIELD - define observed state of cluster
-	// Important: Run "make" to regenerate code after modifying this file
+	// Ready is true when the provider resource is ready.
+	// +optional
+	Ready bool `json:"ready"`
+
+	// Addresses contains the Linode instance associated addresses.
+	Addresses []clusterv1.MachineAddress `json:"addresses,omitempty"`
+
+	// InstanceState is the state of the Linode instance for this machine.
+	// +optional
+	InstanceState *linodego.InstanceStatus `json:"instanceState,omitempty"`
+
+	// FailureReason will be set in the event that there is a terminal problem
+	// reconciling the Machine and will contain a succinct value suitable
+	// for machine interpretation.
+	//
+	// This field should not be set for transitive errors that a controller
+	// faces that are expected to be fixed automatically over
+	// time (like service outages), but instead indicate that something is
+	// fundamentally wrong with the Machine's spec or the configuration of
+	// the controller, and that manual intervention is required. Examples
+	// of terminal errors would be invalid combinations of settings in the
+	// spec, values that are unsupported by the controller, or the
+	// responsible controller itself being critically misconfigured.
+	//
+	// Any transient errors that occur during the reconciliation of Machines
+	// can be added as events to the Machine object and/or logged in the
+	// controller's output.
+	// +optional
+	FailureReason *errors.MachineStatusError `json:"failureReason,omitempty"`
+
+	// FailureMessage will be set in the event that there is a terminal problem
+	// reconciling the Machine and will contain a more verbose string suitable
+	// for logging and human consumption.
+	//
+	// This field should not be set for transitive errors that a controller
+	// faces that are expected to be fixed automatically over
+	// time (like service outages), but instead indicate that something is
+	// fundamentally wrong with the Machine's spec or the configuration of
+	// the controller, and that manual intervention is required. Examples
+	// of terminal errors would be invalid combinations of settings in the
+	// spec, values that are unsupported by the controller, or the
+	// responsible controller itself being critically misconfigured.
+	//
+	// Any transient errors that occur during the reconciliation of Machines
+	// can be added as events to the Machine object and/or logged in the
+	// controller's output.
+	// +optional
+	FailureMessage *string `json:"failureMessage,omitempty"`
+
+	// Conditions defines current service state of the LinodeMachine.
+	// +optional
+	Conditions clusterv1.Conditions `json:"conditions,omitempty"`
 }
 
 //+kubebuilder:object:root=true
@@ -50,6 +162,14 @@ type LinodeMachine struct {
 	Status LinodeMachineStatus `json:"status,omitempty"`
 }
 
+func (lm *LinodeMachine) GetConditions() clusterv1.Conditions {
+	return lm.Status.Conditions
+}
+
+func (lm *LinodeMachine) SetConditions(conditions clusterv1.Conditions) {
+	lm.Status.Conditions = conditions
+}
+
 //+kubebuilder:object:root=true
 
 // LinodeMachineList contains a list of LinodeMachine

diff --git a/api/v1alpha1/zz_generated.deepcopy.go b/api/v1alpha1/zz_generated.deepcopy.go