Move ports management outside of instances

Author: EmilienM

api/v1alpha5/conversion_test.go

@@ -79,7 +79,7 @@ func TestConvertFrom(t *testing.T) {
 				Spec: OpenStackMachineSpec{},
 				ObjectMeta: metav1.ObjectMeta{
 					Annotations: map[string]string{
-						"cluster.x-k8s.io/conversion-data": "{\"spec\":{\"cloudName\":\"\",\"flavor\":\"\",\"image\":{}},\"status\":{\"ready\":false,\"referencedResources\":{}}}",
+						"cluster.x-k8s.io/conversion-data": "{\"spec\":{\"cloudName\":\"\",\"flavor\":\"\",\"image\":{}},\"status\":{\"dependentResources\":{},\"ready\":false,\"referencedResources\":{}}}",
 					},
 				},
 			},

api/v1alpha5/zz_generated.conversion.go

@@ -110,6 +110,10 @@ func restorev1alpha8ClusterStatus(previous *infrav1.OpenStackClusterStatus, dst
 	if previous.Bastion != nil {
 		dst.Bastion.ReferencedResources = previous.Bastion.ReferencedResources
 	}
+
+	if previous.Bastion != nil && previous.Bastion.DependentResources.PortsStatus != nil {
+		dst.Bastion.DependentResources.PortsStatus = previous.Bastion.DependentResources.PortsStatus
+	}
 }
 
 func restorev1alpha6ClusterSpec(previous *OpenStackClusterSpec, dst *OpenStackClusterSpec) {
@@ -328,7 +332,11 @@ var v1alpha8OpenStackMachineRestorer = conversion.RestorerFor[*infrav1.OpenStack
 		},
 		restorev1alpha8MachineSpec,
 	),
-
+	"depresources": conversion.UnconditionalFieldRestorer(
+		func(c *infrav1.OpenStackMachine) *infrav1.DependentMachineResources {
+			return &c.Status.DependentResources
+		},
+	),
 	// No equivalent in v1alpha6
 	"refresources": conversion.UnconditionalFieldRestorer(
 		func(c *infrav1.OpenStackMachine) *infrav1.ReferencedMachineResources {

api/v1alpha6/conversion.go

@@ -84,15 +84,11 @@ var v1alpha8OpenStackClusterRestorer = conversion.RestorerFor[*infrav1.OpenStack
 			},
 		),
 	),
-
-	// No equivalent in v1alpha7
-	"bastionrefresources": conversion.UnconditionalFieldRestorer(
-		func(c *infrav1.OpenStackCluster) *infrav1.ReferencedMachineResources {
-			if c.Status.Bastion == nil {
-				return nil
-			}
-			return &c.Status.Bastion.ReferencedResources
+	"status": conversion.HashedFieldRestorer(
+		func(c *infrav1.OpenStackCluster) *infrav1.OpenStackClusterStatus {
+			return &c.Status
 		},
+		restorev1alpha8ClusterStatus,
 	),
 }
 
@@ -167,6 +163,16 @@ func restorev1alpha8ClusterSpec(previous *infrav1.OpenStackClusterSpec, dst *inf
 	dst.ManagedSubnets = previous.ManagedSubnets
 }
 
+func restorev1alpha8ClusterStatus(previous *infrav1.OpenStackClusterStatus, dst *infrav1.OpenStackClusterStatus) {
+	if previous.Bastion != nil {
+		dst.Bastion.ReferencedResources = previous.Bastion.ReferencedResources
+	}
+
+	if previous.Bastion != nil && previous.Bastion.DependentResources.PortsStatus != nil {
+		dst.Bastion.DependentResources.PortsStatus = previous.Bastion.DependentResources.PortsStatus
+	}
+}
+
 func (r *OpenStackCluster) ConvertTo(dstRaw ctrlconversion.Hub) error {
 	dst := dstRaw.(*infrav1.OpenStackCluster)
 
@@ -269,6 +275,11 @@ var v1alpha8OpenStackMachineRestorer = conversion.RestorerFor[*infrav1.OpenStack
 		},
 		restorev1alpha8MachineSpec,
 	),
+	"depresources": conversion.UnconditionalFieldRestorer(
+		func(c *infrav1.OpenStackMachine) *infrav1.DependentMachineResources {
+			return &c.Status.DependentResources
+		},
+	),
 
 	// No equivalent in v1alpha7
 	"refresources": conversion.UnconditionalFieldRestorer(
@@ -535,3 +546,12 @@ func Convert_v1alpha8_OpenStackClusterSpec_To_v1alpha7_OpenStackClusterSpec(in *
 
 	return nil
 }
+
+func Convert_v1alpha8_OpenStackClusterStatus_To_v1alpha7_OpenStackClusterStatus(in *infrav1.OpenStackClusterStatus, out *OpenStackClusterStatus, s apiconversion.Scope) error {
+	err := autoConvert_v1alpha8_OpenStackClusterStatus_To_v1alpha7_OpenStackClusterStatus(in, out, s)
+	if err != nil {
+		return err
+	}
+
+	return nil
+}

api/v1alpha6/zz_generated.conversion.go

@@ -119,6 +119,9 @@ type OpenStackMachineStatus struct {
 	// ReferencedResources contains resolved references to resources that the machine depends on.
 	ReferencedResources ReferencedMachineResources `json:"referencedResources,omitempty"`
 
+	// DependentResources contains resolved dependent resources that were created by the machine.
+	DependentResources DependentMachineResources `json:"dependentResources,omitempty"`
+
 	FailureReason *errors.MachineStatusError `json:"failureReason,omitempty"`
 
 	// FailureMessage will be set in the event that there is a terminal problem

api/v1alpha7/conversion.go

@@ -147,6 +147,12 @@ type PortOpts struct {
 	ValueSpecs []ValueSpec `json:"valueSpecs,omitempty"`
 }
 
+type PortStatus struct {
+	// ID is the unique identifier of the port.
+	// +required
+	ID string `json:"id"`
+}
+
 type BindingProfile struct {
 	// OVSHWOffload enables or disables the OVS hardware offload feature.
 	OVSHWOffload bool `json:"ovsHWOffload,omitempty"`
@@ -175,6 +181,7 @@ type BastionStatus struct {
 	IP                  string                     `json:"ip,omitempty"`
 	FloatingIP          string                     `json:"floatingIP,omitempty"`
 	ReferencedResources ReferencedMachineResources `json:"referencedResources,omitempty"`
+	DependentResources  DependentMachineResources  `json:"dependentResources,omitempty"`
 }
 
 type RootVolume struct {
@@ -399,6 +406,16 @@ type ReferencedMachineResources struct {
 	// ImageID is the ID of the image to use for the machine and is calculated based on ImageFilter.
 	// +optional
 	ImageID string `json:"imageID,omitempty"`
+
+	// portsOpts is the list of ports options to create for the machine.
+	// +optional
+	PortsOpts []PortOpts `json:"portsOpts,omitempty"`
+}
+
+type DependentMachineResources struct {
+	// PortsStatus is the status of the ports created for the machine.
+	// +optional
+	PortsStatus []PortStatus `json:"portsStatus,omitempty"`
 }
 
 // ValueSpec represents a single value_spec key-value pair.