cloud-disk.go

/*
Copyright 2018 The Kubernetes Authors.

Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
    http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/

package gcecloudprovider

import (
	"strings"

	"github.com/GoogleCloudPlatform/k8s-cloud-provider/pkg/cloud/meta"
	computebeta "google.golang.org/api/compute/v0.beta"
	computev1 "google.golang.org/api/compute/v1"
)

type CloudDisk struct {
	disk     *computev1.Disk
	betaDisk *computebeta.Disk
}

type CloudDiskType string

func CloudDiskFromV1(disk *computev1.Disk) *CloudDisk {
	return &CloudDisk{
		disk: disk,
	}
}

func CloudDiskFromBeta(disk *computebeta.Disk) *CloudDisk {
	return &CloudDisk{
		betaDisk: disk,
	}
}

func (d *CloudDisk) LocationType() meta.KeyType {
	var zone, region string
	switch {
	case d.disk != nil:
		zone = d.disk.Zone
		region = d.disk.Region
	case d.betaDisk != nil:
		zone = d.betaDisk.Zone
		region = d.betaDisk.Region
	}
	switch {
	case zone != "":
		return meta.Zonal
	case region != "":
		return meta.Regional
	default:
		return meta.Global
	}
}

func (d *CloudDisk) GetUsers() []string {
	switch {
	case d.disk != nil:
		return d.disk.Users
	case d.betaDisk != nil:
		return d.betaDisk.Users
	default:
		return nil
	}
}

func (d *CloudDisk) GetName() string {
	switch {
	case d.disk != nil:
		return d.disk.Name
	case d.betaDisk != nil:
		return d.betaDisk.Name
	default:
		return ""
	}
}

func (d *CloudDisk) GetKind() string {
	switch {
	case d.disk != nil:
		return d.disk.Kind
	case d.betaDisk != nil:
		return d.betaDisk.Kind
	default:
		return ""
	}
}

func (d *CloudDisk) GetStatus() string {
	switch {
	case d.disk != nil:
		return d.disk.Status
	case d.betaDisk != nil:
		return d.betaDisk.Status
	default:
		return "Unknown"
	}
}

// GetPDType returns the type of the PD, which is stored as a url like
// projects/project/zones/zone/diskTypes/pd-standard. The returned type is not
// validated, it is just passed verbatium from GCP.
func (d *CloudDisk) GetPDType() string {
	var pdType string
	switch {
	case d.disk != nil:
		pdType = d.disk.Type
	case d.betaDisk != nil:
		pdType = d.betaDisk.Type
	default:
		return ""
	}
	respType := strings.Split(pdType, "/")
	return strings.TrimSpace(respType[len(respType)-1])
}

func (d *CloudDisk) GetSelfLink() string {
	switch {
	case d.disk != nil:
		return d.disk.SelfLink
	case d.betaDisk != nil:
		return d.betaDisk.SelfLink
	default:
		return ""
	}
}

func (d *CloudDisk) GetSizeGb() int64 {
	switch {
	case d.disk != nil:
		return d.disk.SizeGb
	case d.betaDisk != nil:
		return d.betaDisk.SizeGb
	default:
		return -1
	}
}

// setSizeGb sets the size of the disk used ONLY
// for testing purposes.
func (d *CloudDisk) setSizeGb(size int64) {
	switch {
	case d.disk != nil:
		d.disk.SizeGb = size
	case d.betaDisk != nil:
		d.betaDisk.SizeGb = size
	}
}

func (d *CloudDisk) GetZone() string {
	switch {
	case d.disk != nil:
		return d.disk.Zone
	case d.betaDisk != nil:
		return d.betaDisk.Zone
	default:
		return ""
	}
}

func (d *CloudDisk) GetRegion() string {
	switch {
	case d.disk != nil:
		return d.disk.Region
	case d.betaDisk != nil:
		return d.betaDisk.Region
	default:
		return ""
	}
}

func (d *CloudDisk) GetSnapshotId() string {
	switch {
	case d.disk != nil:
		return d.disk.SourceSnapshotId
	case d.betaDisk != nil:
		return d.betaDisk.SourceSnapshotId
	default:
		return ""
	}
}

func (d *CloudDisk) GetSourceDiskId() string {
	switch {
	case d.disk != nil:
		return d.disk.SourceDiskId
	case d.betaDisk != nil:
		return d.betaDisk.SourceDiskId
	default:
		return ""
	}
}

func (d *CloudDisk) GetImageId() string {
	switch {
	case d.disk != nil:
		return d.disk.SourceImageId
	case d.betaDisk != nil:
		return d.betaDisk.SourceImageId
	default:
		return ""
	}
}

func (d *CloudDisk) GetKMSKeyName() string {
	switch {
	case d.disk != nil:
		if dek := d.disk.DiskEncryptionKey; dek != nil {
			return dek.KmsKeyName
		}
	case d.betaDisk != nil:
		if dek := d.betaDisk.DiskEncryptionKey; dek != nil {
			return dek.KmsKeyName
		}
	}
	return ""
}

func (d *CloudDisk) GetMultiWriter() bool {
	switch {
	case d.disk != nil:
		return false
	case d.betaDisk != nil:
		return d.betaDisk.MultiWriter
	default:
		return false
	}
}

func (d *CloudDisk) GetEnableConfidentialCompute() bool {
	switch {
	case d.disk != nil:
		return d.disk.EnableConfidentialCompute
	case d.betaDisk != nil:
		return d.betaDisk.EnableConfidentialCompute
	default:
		return false
	}
}

func (d *CloudDisk) GetEnableStoragePools() bool {
	switch {
	case d.disk != nil:
		return d.disk.StoragePool != ""
	case d.betaDisk != nil:
		return d.betaDisk.StoragePool != ""
	default:
		return false
	}
}

func (d *CloudDisk) GetLabels() map[string]string {
	switch {
	case d.disk != nil:
		return d.disk.Labels
	case d.betaDisk != nil:
		return d.betaDisk.Labels
	default:
		return nil
	}
}

func (d *CloudDisk) GetAccessMode() string {
	switch {
	case d.disk != nil:
		return d.disk.AccessMode
	case d.betaDisk != nil:
		return d.betaDisk.AccessMode
	default:
		return ""
	}
}

func (d *CloudDisk) GetProvisionedIops() int64 {
	switch {
	case d.disk != nil:
		return d.disk.ProvisionedIops
	case d.betaDisk != nil:
		return d.betaDisk.ProvisionedIops
	default:
		return 0
	}
}

func (d *CloudDisk) GetProvisionedThroughput() int64 {
	switch {
	case d.disk != nil:
		return d.disk.ProvisionedThroughput
	case d.betaDisk != nil:
		return d.betaDisk.ProvisionedThroughput
	default:
		return 0
	}
}