@@ -31,7 +31,7 @@ type NetworkIface interface {
31
31
ResolveNetwork (* capcv1.CloudStackCluster , * capcv1.Network ) error
32
32
CreateIsolatedNetwork (* capcv1.CloudStackCluster ) error
33
33
OpenFirewallRules (* capcv1.CloudStackCluster ) error
34
- ResolvePublicIPDetails (* capcv1.CloudStackCluster ) (* cloudstack.PublicIpAddress , error )
34
+ FetchPublicIP (* capcv1.CloudStackCluster ) (* cloudstack.PublicIpAddress , error )
35
35
ResolveLoadBalancerRuleDetails (* capcv1.CloudStackCluster ) error
36
36
GetOrCreateLoadBalancerRule (* capcv1.CloudStackCluster ) error
37
37
GetOrCreateIsolatedNetwork (* capcv1.CloudStackCluster ) error
@@ -134,19 +134,17 @@ func (c *client) CreateIsolatedNetwork(csCluster *capcv1.CloudStackCluster) (ret
134
134
if err != nil {
135
135
return err
136
136
}
137
- if err := c .AddClusterTag (ResourceTypeNetwork , zoneStatus .Network .ID , csCluster ); err != nil {
138
- return err
139
- }
140
- if err := c .AddCreatedByCAPCTag (ResourceTypeNetwork , zoneStatus .Network .ID ); err != nil {
141
- return err
142
- }
143
137
144
138
// Update Zone/Network status accordingly.
145
139
netStatus .ID = resp .Id
146
140
netStatus .Type = resp .Type
147
141
zoneStatus .Network = netStatus
148
142
csCluster .Status .Zones [zoneStatus .Name ] = zoneStatus
149
143
144
+ if err := c .AddCreatedByCAPCTag (ResourceTypeNetwork , zoneStatus .Network .ID ); err != nil {
145
+ return err
146
+ }
147
+
150
148
return nil
151
149
}
152
150
@@ -201,7 +199,7 @@ func (c *client) DeleteNetworkIfNotInUse(csCluster *capcv1.CloudStackCluster, ne
201
199
return nil
202
200
}
203
201
204
- func (c * client ) ResolvePublicIPDetails (csCluster * capcv1.CloudStackCluster ) (* cloudstack.PublicIpAddress , error ) {
202
+ func (c * client ) FetchPublicIP (csCluster * capcv1.CloudStackCluster ) (* cloudstack.PublicIpAddress , error ) {
205
203
ip := csCluster .Spec .ControlPlaneEndpoint .Host
206
204
207
205
zoneStatus := csCluster .Status .Zones .GetOne ()
@@ -234,7 +232,7 @@ func (c *client) ResolvePublicIPDetails(csCluster *capcv1.CloudStackCluster) (*c
234
232
235
233
// AssociatePublicIPAddress Gets a PublicIP and associates it.
236
234
func (c * client ) AssociatePublicIPAddress (csCluster * capcv1.CloudStackCluster ) (retErr error ) {
237
- publicAddress , err := c .ResolvePublicIPDetails (csCluster )
235
+ publicAddress , err := c .FetchPublicIP (csCluster )
238
236
if err != nil {
239
237
return err
240
238
}
@@ -379,11 +377,19 @@ func (c *client) GetOrCreateIsolatedNetwork(csCluster *capcv1.CloudStackCluster)
379
377
return err
380
378
}
381
379
}
380
+ networkID := csCluster .Status .Zones .GetOne ().Network .ID
381
+ if err := c .AddClusterTag (ResourceTypeNetwork , networkID , csCluster ); err != nil {
382
+ return err
383
+ }
382
384
383
385
if csCluster .Status .PublicIPID == "" { // Don't try to get public IP again it's already been fetched.
384
386
if err := c .AssociatePublicIPAddress (csCluster ); err != nil {
385
387
return err
386
388
}
389
+ // Add created by CAPC tag to public IP.
390
+ if err := c .AddCreatedByCAPCTag (ResourceTypeIPAddress , csCluster .Status .PublicIPID ); err != nil {
391
+ return err
392
+ }
387
393
}
388
394
if err := c .GetOrCreateLoadBalancerRule (csCluster ); err != nil {
389
395
return err
0 commit comments