Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
52 changes: 27 additions & 25 deletions go.mod
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,7 @@ require (
github.com/clarketm/json v1.14.1
github.com/containers/image v3.0.2+incompatible
github.com/coreos/ignition/v2 v2.9.0
github.com/coreos/stream-metadata-go v0.1.3
github.com/coreos/stream-metadata-go v0.1.8
github.com/ghodss/yaml v1.0.1-0.20190212211648-25d852aebe32
github.com/go-playground/validator/v10 v10.2.0
github.com/golang/mock v1.6.0
Expand Down Expand Up @@ -87,6 +87,32 @@ require (
sigs.k8s.io/controller-tools v0.8.0
)

require (
github.com/shurcooL/httpfs v0.0.0-20171119174359-809beceb2371 // indirect
github.com/spf13/pflag v1.0.5 // indirect
github.com/zclconf/go-cty v1.10.0 // indirect
go.mongodb.org/mongo-driver v1.8.3 // indirect
go.opencensus.io v0.23.0 // indirect
golang.org/x/mod v0.4.2 // indirect
golang.org/x/term v0.0.0-20210927222741-03fcf44c2211 // indirect
golang.org/x/text v0.3.7 // indirect
golang.org/x/time v0.0.0-20210723032227-1f47c861a9ac // indirect
golang.org/x/tools v0.1.6-0.20210820212750-d4cc65f0b2ff // indirect
golang.org/x/xerrors v0.0.0-20200804184101-5ec99f83aff1 // indirect
gomodules.xyz/jsonpatch/v2 v2.2.0 // indirect
google.golang.org/appengine v1.6.7 // indirect
google.golang.org/protobuf v1.27.1 // indirect
gopkg.in/go-playground/validator.v9 v9.31.0 // indirect
gopkg.in/inf.v0 v0.9.1 // indirect
gopkg.in/yaml.v3 v3.0.0-20210107192922-496545a6307b // indirect
k8s.io/component-base v0.23.0 // indirect
k8s.io/kube-openapi v0.0.0-20211115234752-e816edb12b65 // indirect
sigs.k8s.io/controller-runtime v0.11.0 // indirect
sigs.k8s.io/json v0.0.0-20211208200746-9f7c6b3444d2 // indirect
sigs.k8s.io/structured-merge-diff/v4 v4.2.0 // indirect
sigs.k8s.io/yaml v1.3.0 // indirect
)

require (
github.com/Azure/go-autorest v14.2.0+incompatible // indirect
github.com/Azure/go-autorest/autorest/adal v0.9.13 // indirect
Expand Down Expand Up @@ -129,7 +155,6 @@ require (
github.com/gogo/protobuf v1.3.2 // indirect
github.com/golang/groupcache v0.0.0-20210331224755-41bb18bfe9da // indirect
github.com/google/gofuzz v1.2.0 // indirect
github.com/google/renameio v1.0.0 // indirect
github.com/googleapis/gax-go/v2 v2.0.5 // indirect
github.com/googleapis/gnostic v0.5.5 // indirect
github.com/hashicorp/go-cleanhttp v0.5.2 // indirect
Expand Down Expand Up @@ -164,29 +189,6 @@ require (
github.com/prometheus/client_model v0.2.0 // indirect
github.com/prometheus/procfs v0.6.0 // indirect
github.com/satori/go.uuid v1.2.0 // indirect
github.com/shurcooL/httpfs v0.0.0-20171119174359-809beceb2371 // indirect
github.com/spf13/pflag v1.0.5 // indirect
github.com/zclconf/go-cty v1.10.0 // indirect
go.mongodb.org/mongo-driver v1.8.3 // indirect
go.opencensus.io v0.23.0 // indirect
golang.org/x/mod v0.4.2 // indirect
golang.org/x/term v0.0.0-20210927222741-03fcf44c2211 // indirect
golang.org/x/text v0.3.7 // indirect
golang.org/x/time v0.0.0-20210723032227-1f47c861a9ac // indirect
golang.org/x/tools v0.1.6-0.20210820212750-d4cc65f0b2ff // indirect
golang.org/x/xerrors v0.0.0-20200804184101-5ec99f83aff1 // indirect
gomodules.xyz/jsonpatch/v2 v2.2.0 // indirect
google.golang.org/appengine v1.6.7 // indirect
google.golang.org/protobuf v1.27.1 // indirect
gopkg.in/go-playground/validator.v9 v9.31.0 // indirect
gopkg.in/inf.v0 v0.9.1 // indirect
gopkg.in/yaml.v3 v3.0.0-20210107192922-496545a6307b // indirect
k8s.io/component-base v0.23.0 // indirect
k8s.io/kube-openapi v0.0.0-20211115234752-e816edb12b65 // indirect
sigs.k8s.io/controller-runtime v0.11.0 // indirect
sigs.k8s.io/json v0.0.0-20211208200746-9f7c6b3444d2 // indirect
sigs.k8s.io/structured-merge-diff/v4 v4.2.0 // indirect
sigs.k8s.io/yaml v1.3.0 // indirect
)

// OpenShift Forks
Expand Down
6 changes: 2 additions & 4 deletions go.sum
Original file line number Diff line number Diff line change
Expand Up @@ -308,8 +308,8 @@ github.com/coreos/ignition/v2 v2.9.0/go.mod h1:A5lFFzA2/zvZQPVEvI1lR5WPLWRb7KZ7Q
github.com/coreos/pkg v0.0.0-20160727233714-3ac0863d7acf/go.mod h1:E3G3o1h8I7cfcXa63jLwjI0eiQQMgzzUDFVpN/nH/eA=
github.com/coreos/pkg v0.0.0-20180108230652-97fdf19511ea/go.mod h1:E3G3o1h8I7cfcXa63jLwjI0eiQQMgzzUDFVpN/nH/eA=
github.com/coreos/pkg v0.0.0-20180928190104-399ea9e2e55f/go.mod h1:E3G3o1h8I7cfcXa63jLwjI0eiQQMgzzUDFVpN/nH/eA=
github.com/coreos/stream-metadata-go v0.1.3 h1:i/mUQBANlYirNAU4ybH6x/SCuc/Rh6uiopph6XZhROk=
github.com/coreos/stream-metadata-go v0.1.3/go.mod h1:zxVoWUDB0H8+tZRhTs0LeLeR/QdmBsuo7FN1oOBrWTE=
github.com/coreos/stream-metadata-go v0.1.8 h1:EbLlLia+Ekuqgh8nF4NNFs0jUqmhUbN4mWd1O8u8TQE=
github.com/coreos/stream-metadata-go v0.1.8/go.mod h1:RTjQyHgO/G37oJ3qnqYK6Z4TPZ5EsaabOtfMjVXmgko=
github.com/coreos/vcontext v0.0.0-20190529201340-22b159166068/go.mod h1:E+6hug9bFSe0KZ2ZAzr8M9F5JlArJjv5D1JS7KSkPKE=
github.com/coreos/vcontext v0.0.0-20191017033345-260217907eb5/go.mod h1:E+6hug9bFSe0KZ2ZAzr8M9F5JlArJjv5D1JS7KSkPKE=
github.com/coreos/vcontext v0.0.0-20201120045928-b0e13dab675c h1:jA28WeORitsxGFVWhyWB06sAG2HbLHPQuHwDydhU2CQ=
Expand Down Expand Up @@ -766,8 +766,6 @@ github.com/google/pprof v0.0.0-20201203190320-1bf35d6f28c2/go.mod h1:kpwsk12EmLe
github.com/google/pprof v0.0.0-20210122040257-d980be63207e/go.mod h1:kpwsk12EmLew5upagYY7GY0pfYCcupk39gWOCRROcvE=
github.com/google/pprof v0.0.0-20210226084205-cbba55b83ad5/go.mod h1:kpwsk12EmLew5upagYY7GY0pfYCcupk39gWOCRROcvE=
github.com/google/renameio v0.1.0/go.mod h1:KWCgfxg9yswjAJkECMjeO8J8rahYeXnNhOm40UhjYkI=
github.com/google/renameio v1.0.0 h1:xhp2CnJmgQmpJU4RY8chagahUq5mbPPAbiSQstKpVMA=
github.com/google/renameio v1.0.0/go.mod h1:t/HQoYBZSsWSNK35C6CO/TpPLDVWvxOHboWUAweKUpk=
github.com/google/shlex v0.0.0-20191202100458-e7afc7fbc510/go.mod h1:pupxD2MaaD3pAXIBCelhxNneeOaAeabZDe5s4K6zSpQ=
github.com/google/uuid v0.0.0-20170306145142-6a5e28554805/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
github.com/google/uuid v1.0.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
Expand Down
48 changes: 48 additions & 0 deletions pkg/asset/cluster/tfvars.go
Original file line number Diff line number Diff line change
Expand Up @@ -14,6 +14,7 @@ import (
libvirtprovider "github.com/openshift/cluster-api-provider-libvirt/pkg/apis/libvirtproviderconfig/v1beta1"
ovirtprovider "github.com/openshift/cluster-api-provider-ovirt/pkg/apis/ovirtprovider/v1beta1"
nutanixprovider "github.com/openshift/machine-api-provider-nutanix/pkg/apis/nutanixprovider/v1beta1"
powervsprovider "github.com/openshift/machine-api-provider-powervs/pkg/apis/powervsprovider/v1alpha1"
"github.com/pkg/errors"
"github.com/sirupsen/logrus"
awsprovider "sigs.k8s.io/cluster-api-provider-aws/pkg/apis/awsprovider/v1beta1"
Expand Down Expand Up @@ -47,6 +48,7 @@ import (
nutanixtfvars "github.com/openshift/installer/pkg/tfvars/nutanix"
openstacktfvars "github.com/openshift/installer/pkg/tfvars/openstack"
ovirttfvars "github.com/openshift/installer/pkg/tfvars/ovirt"
powervstfvars "github.com/openshift/installer/pkg/tfvars/powervs"
vspheretfvars "github.com/openshift/installer/pkg/tfvars/vsphere"
"github.com/openshift/installer/pkg/types"
"github.com/openshift/installer/pkg/types/alibabacloud"
Expand All @@ -60,6 +62,7 @@ import (
"github.com/openshift/installer/pkg/types/nutanix"
"github.com/openshift/installer/pkg/types/openstack"
"github.com/openshift/installer/pkg/types/ovirt"
"github.com/openshift/installer/pkg/types/powervs"
"github.com/openshift/installer/pkg/types/vsphere"
)

Expand Down Expand Up @@ -676,6 +679,51 @@ func (t *TerraformVariables) Generate(parents asset.Parents) error {
Filename: TfPlatformVarsFileName,
Data: data,
})
case powervs.Name:
client, err := installConfig.PowerVS.Client()
if err != nil {
return err
}

masters, err := mastersAsset.Machines()
if err != nil {
return err
}

// Get CISInstanceCRN from InstallConfig metadata
crn, err := installConfig.PowerVS.CISInstanceCRN(ctx)
if err != nil {
return err
}

masterConfigs := make([]*powervsprovider.PowerVSMachineProviderConfig, len(masters))
for i, m := range masters {
masterConfigs[i] = m.Spec.ProviderSpec.Value.Object.(*powervsprovider.PowerVSMachineProviderConfig)
}

data, err = powervstfvars.TFVars(
powervstfvars.TFVarsSources{
MasterConfigs: masterConfigs,
Region: installConfig.Config.Platform.PowerVS.Region,
Zone: installConfig.Config.Platform.PowerVS.Zone,
APIKey: client.APIKey,
SSHKey: installConfig.Config.SSHKey,
PowerVSResourceGroup: installConfig.Config.PowerVS.PowerVSResourceGroup,
ImageBucketFileName: string(*rhcosImage),
Comment thread
Prashanth684 marked this conversation as resolved.
Outdated
NetworkName: installConfig.Config.PowerVS.PVSNetworkName,
CISInstanceCRN: crn,
VPCSubnetName: installConfig.Config.PowerVS.Subnets[0],
VPCName: installConfig.Config.PowerVS.VPC,
},
)
if err != nil {
return errors.Wrapf(err, "failed to get %s Terraform variables", platform)
}
t.FileList = append(t.FileList, &asset.File{
Filename: TfPlatformVarsFileName,
Data: data,
})

case vsphere.Name:
controlPlanes, err := mastersAsset.Machines()
if err != nil {
Expand Down
9 changes: 6 additions & 3 deletions pkg/asset/installconfig/powervs/client.go
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,6 @@ package powervs
import (
"context"
"fmt"
"os"
"time"

"github.com/IBM/go-sdk-core/v5/core"
Expand Down Expand Up @@ -55,9 +54,13 @@ type DNSZoneResponse struct {

// NewClient initializes a client with a session.
func NewClient() (*Client, error) {
apiKey := os.Getenv("IC_API_KEY")
ssn, err := GetSession()
if err != nil {
return nil, err
}

client := &Client{
APIKey: apiKey,
APIKey: ssn.APIKey,
}

if err := client.loadSDKServices(); err != nil {
Expand Down
3 changes: 0 additions & 3 deletions pkg/asset/installconfig/powervs/session.go
Original file line number Diff line number Diff line change
Expand Up @@ -75,9 +75,6 @@ func getPISession() (*ibmpisession.IBMPISession, string, error) {
return nil, "", err
}

// This is needed by ibmcloud code to gather DNS information later.
os.Setenv("IC_API_KEY", pisv.APIKey)

piOpts := ibmpisession.IBMPIOptions{
Authenticator: &core.IamAuthenticator{
ApiKey: pisv.APIKey,
Expand Down
15 changes: 15 additions & 0 deletions pkg/asset/rhcos/image.go
Original file line number Diff line number Diff line change
Expand Up @@ -25,6 +25,7 @@ import (
"github.com/openshift/installer/pkg/types/nutanix"
"github.com/openshift/installer/pkg/types/openstack"
"github.com/openshift/installer/pkg/types/ovirt"
"github.com/openshift/installer/pkg/types/powervs"
"github.com/openshift/installer/pkg/types/vsphere"
)

Expand Down Expand Up @@ -163,6 +164,20 @@ func osImage(config *types.InstallConfig) (string, error) {
return "", err
}
return osimage, nil
case powervs.Name:
// Check for image URL override
if config.Platform.PowerVS.ClusterOSImage != "" {
return config.Platform.PowerVS.ClusterOSImage, nil
}

if streamArch.Images.PowerVS != nil {
vpcRegion := powervs.Regions[config.Platform.PowerVS.Region].VPCRegion
img := streamArch.Images.PowerVS.Regions[vpcRegion]
logrus.Debug("Power VS using image ", img.Object)
return img.Object, nil
}

return "", fmt.Errorf("%s: No Power VS build found", st.FormatPrefix(archName))
case none.Name:
return "", nil
case nutanix.Name:
Expand Down
4 changes: 4 additions & 0 deletions pkg/terraform/stages/platform/stages.go
Original file line number Diff line number Diff line change
Expand Up @@ -14,6 +14,7 @@ import (
"github.com/openshift/installer/pkg/terraform/stages/nutanix"
"github.com/openshift/installer/pkg/terraform/stages/openstack"
"github.com/openshift/installer/pkg/terraform/stages/ovirt"
"github.com/openshift/installer/pkg/terraform/stages/powervs"
"github.com/openshift/installer/pkg/terraform/stages/vsphere"
alibabacloudtypes "github.com/openshift/installer/pkg/types/alibabacloud"
awstypes "github.com/openshift/installer/pkg/types/aws"
Expand All @@ -25,6 +26,7 @@ import (
nutanixtypes "github.com/openshift/installer/pkg/types/nutanix"
openstacktypes "github.com/openshift/installer/pkg/types/openstack"
ovirttypes "github.com/openshift/installer/pkg/types/ovirt"
powervstypes "github.com/openshift/installer/pkg/types/powervs"
vspheretypes "github.com/openshift/installer/pkg/types/vsphere"
)

Expand All @@ -49,6 +51,8 @@ func StagesForPlatform(platform string) []terraform.Stage {
return libvirt.PlatformStages
case nutanixtypes.Name:
return nutanix.PlatformStages
case powervstypes.Name:
return powervs.PlatformStages
case openstacktypes.Name:
return openstack.PlatformStages
case ovirttypes.Name:
Expand Down
17 changes: 17 additions & 0 deletions pkg/terraform/stages/powervs/stages.go
Original file line number Diff line number Diff line change
@@ -0,0 +1,17 @@
package powervs

import (
"github.com/openshift/installer/pkg/terraform"
"github.com/openshift/installer/pkg/terraform/providers"
"github.com/openshift/installer/pkg/terraform/stages"
)

// PlatformStages are the stages to run to provision the infrastructure in PowerVS.
var PlatformStages = []terraform.Stage{
stages.NewStage("powervs",
"cluster",
[]providers.Provider{providers.IBM, providers.Ignition}),
stages.NewStage("powervs",
"post-install",
[]providers.Provider{providers.IBM}),
}
87 changes: 87 additions & 0 deletions pkg/tfvars/powervs/powervs.go
Original file line number Diff line number Diff line change
@@ -0,0 +1,87 @@
// Package powervs contains Power Virtual Servers-specific Terraform-variable logic.
package powervs

import (
"encoding/json"
"fmt"
"math/rand"
"time"

"github.com/openshift/installer/pkg/types/powervs"
"github.com/openshift/machine-api-provider-powervs/pkg/apis/powervsprovider/v1alpha1"
)

type config struct {
ServiceInstanceID string `json:"powervs_cloud_instance_id"`
APIKey string `json:"powervs_api_key"`
SSHKey string `json:"powervs_ssh_key"`
PowerVSRegion string `json:"powervs_region"`
PowerVSZone string `json:"powervs_zone"`
VPCRegion string `json:"powervs_vpc_region"`
VPCZone string `json:"powervs_vpc_zone"`
PowerVSResourceGroup string `json:"powervs_resource_group"`
CISInstanceCRN string `json:"powervs_cis_crn"`
ImageBucketFileName string `json:"powervs_image_bucket_file_name"`
NetworkName string `json:"powervs_network_name"`
VPCName string `json:"powervs_vpc_name"`
VPCSubnetName string `json:"powervs_vpc_subnet_name"`
BootstrapMemory string `json:"powervs_bootstrap_memory"`
BootstrapProcessors string `json:"powervs_bootstrap_processors"`
MasterMemory string `json:"powervs_master_memory"`
MasterProcessors string `json:"powervs_master_processors"`
ProcType string `json:"powervs_proc_type"`
SysType string `json:"powervs_sys_type"`
}

// TFVarsSources contains the parameters to be converted into Terraform variables
type TFVarsSources struct {
MasterConfigs []*v1alpha1.PowerVSMachineProviderConfig
APIKey string
SSHKey string
Region string
Zone string
ImageBucketFileName string
NetworkName string
PowerVSResourceGroup string
CISInstanceCRN string
VPCName string
VPCSubnetName string
}

// TFVars generates Power VS-specific Terraform variables launching the cluster.
func TFVars(sources TFVarsSources) ([]byte, error) {
masterConfig := sources.MasterConfigs[0]
// TODO(mjturek): Allow user to specify vpcRegion in install config like we're doing for vpcZone
vpcRegion := powervs.Regions[sources.Region].VPCRegion

// Randomly select a zone in the VPC region.
// @TODO: Align this with a region later.
rand.Seed(time.Now().UnixNano())
// All supported Regions are MZRs and have Zones named "region-[1-3]"
vpcZone := fmt.Sprintf("%s-%d", vpcRegion, rand.Intn(3))

//@TODO: Add resource group to platform
cfg := &config{
ServiceInstanceID: masterConfig.ServiceInstanceID,
APIKey: sources.APIKey,
SSHKey: sources.SSHKey,
PowerVSRegion: sources.Region,
PowerVSZone: sources.Zone,
VPCRegion: vpcRegion,
VPCZone: vpcZone,
PowerVSResourceGroup: sources.PowerVSResourceGroup,
CISInstanceCRN: sources.CISInstanceCRN,
ImageBucketFileName: sources.ImageBucketFileName,
NetworkName: *masterConfig.Network.Name,
VPCName: sources.VPCName,
VPCSubnetName: sources.VPCSubnetName,
BootstrapMemory: masterConfig.Memory,
BootstrapProcessors: masterConfig.Processors,
MasterMemory: masterConfig.Memory,
MasterProcessors: masterConfig.Processors,
ProcType: masterConfig.ProcType,
SysType: masterConfig.SysType,
}

return json.MarshalIndent(cfg, "", " ")
}
Loading