mirror of
https://github.com/openshift/installer.git
synced 2026-02-05 15:47:14 +01:00
3c047d265a
On AzureStack, we don't expect a user-assigned identity to be assigned to nodes. This updates the create identity helper function to reflect that.
89 lines
2.8 KiB
Go
89 lines
2.8 KiB
Go
package types
|
|
|
|
import (
|
|
"fmt"
|
|
"os"
|
|
|
|
"github.com/sirupsen/logrus"
|
|
capz "sigs.k8s.io/cluster-api-provider-azure/api/v1beta1"
|
|
|
|
configv1 "github.com/openshift/api/config/v1"
|
|
features "github.com/openshift/api/features"
|
|
"github.com/openshift/installer/pkg/types/azure"
|
|
)
|
|
|
|
// StringsToIPs is used to convert list of strings to list of IP addresses.
|
|
func StringsToIPs(ips []string) []configv1.IP {
|
|
res := []configv1.IP{}
|
|
|
|
if ips == nil {
|
|
return res
|
|
}
|
|
|
|
for _, ip := range ips {
|
|
res = append(res, configv1.IP(ip))
|
|
}
|
|
|
|
return res
|
|
}
|
|
|
|
// MachineNetworksToCIDRs is used to convert list of Machine Network Entries to
|
|
// list of CIDRs.
|
|
func MachineNetworksToCIDRs(nets []MachineNetworkEntry) []configv1.CIDR {
|
|
res := []configv1.CIDR{}
|
|
|
|
if nets == nil {
|
|
return res
|
|
}
|
|
|
|
for _, net := range nets {
|
|
res = append(res, configv1.CIDR(net.CIDR.String()))
|
|
}
|
|
|
|
return res
|
|
}
|
|
|
|
// GetClusterProfileName utility method to retrieve the cluster profile setting. This is used
|
|
// when dealing with openshift api to get FeatureSets.
|
|
func GetClusterProfileName() features.ClusterProfileName {
|
|
// Get cluster profile for new FeatureGate access. Blank is no longer an option, so default to
|
|
// SelfManaged.
|
|
clusterProfile := features.SelfManaged
|
|
if cp := os.Getenv("OPENSHIFT_INSTALL_EXPERIMENTAL_CLUSTER_PROFILE"); cp != "" {
|
|
logrus.Warnf("Found override for Cluster Profile: %q", cp)
|
|
// All profiles when getting FeatureSets need to have "include.release.openshift.io/" at the beginning.
|
|
// See vendor/openshift/api/config/v1/feature_gates.go for more info.
|
|
clusterProfile = features.ClusterProfileName(fmt.Sprintf("%s%s", "include.release.openshift.io/", cp))
|
|
}
|
|
return clusterProfile
|
|
}
|
|
|
|
// CreateAzureIdentity determines whether a user-assigned
|
|
// identity should be created by the installer, based on the
|
|
// install config values.
|
|
func (c *InstallConfig) CreateAzureIdentity() bool {
|
|
if c.Azure == nil || c.Azure.CloudName == azure.StackCloud {
|
|
return false
|
|
}
|
|
|
|
var defaultID *azure.VMIdentity
|
|
if dmp := c.Azure.DefaultMachinePlatform; dmp != nil {
|
|
defaultID = dmp.Identity
|
|
}
|
|
defaultNeedsID := defaultID == nil || (defaultID.Type == capz.VMIdentityUserAssigned && len(defaultID.UserAssignedIdentities) == 0)
|
|
|
|
var computeID *azure.VMIdentity
|
|
if comp := c.Compute; len(comp) > 0 && comp[0].Platform.Azure != nil {
|
|
computeID = comp[0].Platform.Azure.Identity
|
|
}
|
|
computeNeedsID := computeID == nil || (computeID.Type == capz.VMIdentityUserAssigned && len(computeID.UserAssignedIdentities) == 0)
|
|
|
|
var cpID *azure.VMIdentity
|
|
if cp := c.ControlPlane; cp != nil && cp.Platform.Azure != nil {
|
|
cpID = cp.Platform.Azure.Identity
|
|
}
|
|
cpNeedsID := cpID == nil || (cpID.Type == capz.VMIdentityUserAssigned && len(cpID.UserAssignedIdentities) == 0)
|
|
|
|
return defaultNeedsID && (computeNeedsID || cpNeedsID)
|
|
}
|