improve tagging

Author: yutpeng

pkg/cloudprovider/providers/oci/instances.go

@@ -97,31 +97,32 @@ func (cp *CloudProvider) extractNodeAddresses(ctx context.Context, instanceID st
 		}
 		addresses = append(addresses, api.NodeAddress{Type: api.NodeExternalIP, Address: ip.String()})
 	}
+	if cp.checkOpenShiftISCSIBootVolumeByInstance(ctx, instanceID) {
+		secondaryVnic, err := cp.client.Compute().GetSecondaryVNICForInstance(ctx, compartmentID, instanceID)
+		if err != nil {
+			return nil, errors.Wrap(err, "GetSecondaryVNICForInstance")
+		}
 
-	secondaryVnic, err := cp.client.Compute().GetSecondaryVNICForInstance(ctx, compartmentID, instanceID)
-	if err != nil {
-		return nil, errors.Wrap(err, "GetSecondaryVNICForInstance")
-	}
-
-	if secondaryVnic == nil {
-		return addresses, nil
-	}
+		if secondaryVnic == nil {
+			return addresses, nil
+		}
 
-	if cp.checkOpenShiftISCSIBootVolumeByVnic(ctx, secondaryVnic) {
-		if (secondaryVnic.IsPrimary == nil || !*secondaryVnic.IsPrimary) && secondaryVnic.PrivateIp != nil && *secondaryVnic.PrivateIp != "" {
-			ip := net.ParseIP(*secondaryVnic.PrivateIp)
-			if ip == nil {
-				return nil, fmt.Errorf("instance has invalid private address: %q", *secondaryVnic.PrivateIp)
+		if cp.checkOpenShiftISCSIBootVolumeByVnic(ctx, secondaryVnic) {
+			if (secondaryVnic.IsPrimary == nil || !*secondaryVnic.IsPrimary) && secondaryVnic.PrivateIp != nil && *secondaryVnic.PrivateIp != "" {
+				ip := net.ParseIP(*secondaryVnic.PrivateIp)
+				if ip == nil {
+					return nil, fmt.Errorf("instance has invalid private address: %q", *secondaryVnic.PrivateIp)
+				}
+				addresses = append(addresses, api.NodeAddress{Type: api.NodeInternalIP, Address: ip.String()})
 			}
-			addresses = append(addresses, api.NodeAddress{Type: api.NodeInternalIP, Address: ip.String()})
-		}
 
-		if (secondaryVnic.IsPrimary == nil || !*secondaryVnic.IsPrimary) && secondaryVnic.PublicIp != nil && *secondaryVnic.PublicIp != "" {
-			ip := net.ParseIP(*secondaryVnic.PublicIp)
-			if ip == nil {
-				return nil, errors.Errorf("instance has invalid public address: %q", *secondaryVnic.PublicIp)
+			if (secondaryVnic.IsPrimary == nil || !*secondaryVnic.IsPrimary) && secondaryVnic.PublicIp != nil && *secondaryVnic.PublicIp != "" {
+				ip := net.ParseIP(*secondaryVnic.PublicIp)
+				if ip == nil {
+					return nil, errors.Errorf("instance has invalid public address: %q", *secondaryVnic.PublicIp)
+				}
+				addresses = append(addresses, api.NodeAddress{Type: api.NodeExternalIP, Address: ip.String()})
 			}
-			addresses = append(addresses, api.NodeAddress{Type: api.NodeExternalIP, Address: ip.String()})
 		}
 	}
 	// Changing this can have wide reaching impact.
@@ -350,3 +351,18 @@ func (cp *CloudProvider) checkOpenShiftISCSIBootVolumeByVnic(ctx context.Context
 	}
 	return false
 }
+
+func (cp *CloudProvider) checkOpenShiftISCSIBootVolumeByInstance(ctx context.Context, instanceID string) bool {
+	instance, err := cp.client.Compute().GetInstance(ctx, instanceID)
+	if err != nil {
+		return false
+	}
+	for namespace := range instance.DefinedTags {
+		if strings.HasPrefix(namespace, "openshift") {
+			if bootVolume, exist := instance.DefinedTags[namespace]["boot-volume-type"]; exist && bootVolume == "ISCSI" {
+				return true
+			}
+		}
+	}
+	return false
+}

pkg/cloudprovider/providers/oci/node_info_controller.go

@@ -41,10 +41,9 @@ import (
 
 // metadata labeling for placement info
 const (
-	FaultDomainLabel             = "oci.oraclecloud.com/fault-domain"
-	CompartmentIDAnnotation      = "oci.oraclecloud.com/compartment-id"
-	OpenShiftNodeIdentifierLabel = "node.openshift.io/os_id"
-	timeout                      = 10 * time.Second
+	FaultDomainLabel        = "oci.oraclecloud.com/fault-domain"
+	CompartmentIDAnnotation = "oci.oraclecloud.com/compartment-id"
+	timeout                 = 10 * time.Second
 )
 
 // NodeInfoController helps compute workers in the cluster