wait up to 30 seconds for root disk to resize (#212)

cloud/scope/client.go

@@ -28,6 +28,7 @@ type LinodeInstanceClient interface {
 	CreateInstanceDisk(ctx context.Context, linodeID int, opts linodego.InstanceDiskCreateOptions) (*linodego.InstanceDisk, error)
 	GetInstance(ctx context.Context, linodeID int) (*linodego.Instance, error)
 	DeleteInstance(ctx context.Context, linodeID int) error
+	WaitForInstanceDiskStatus(ctx context.Context, instanceID int, diskID int, status linodego.DiskStatus, timeoutSeconds int) (*linodego.InstanceDisk, error)
 }
 
 // LinodeVPCClient defines the methods that a Linode client must have to interact with Linode's VPC service.

controller/linodemachine_controller.go

@@ -50,7 +50,10 @@ import (
 )
 
 // default etcd Disk size in MB
-const defaultEtcdDiskSize = 10240
+const (
+	defaultEtcdDiskSize         = 10240
+	defaultResizeTimeoutSeconds = 30
+)
 
 var skippedMachinePhases = map[string]bool{
 	string(clusterv1.MachinePhasePending): true,
@@ -342,6 +345,13 @@ func (r *LinodeMachineReconciler) configureDisksControlPlane(
 
 		return err
 	}
+	// wait for the disk to resize
+	_, err = machineScope.LinodeClient.WaitForInstanceDiskStatus(ctx, linodeInstanceID, rootDiskID, linodego.DiskReady, defaultResizeTimeoutSeconds)
+	if err != nil {
+		logger.Error(err, fmt.Sprintf("Failed to resize root disk within resize timeout of %d seconds", defaultResizeTimeoutSeconds))
+
+		return err
+	}
 
 	// create the etcd disk
 	_, err = machineScope.LinodeClient.CreateInstanceDisk(