mirror of https://github.com/k3s-io/k3s
82 lines
3.0 KiB
Go
82 lines
3.0 KiB
Go
|
/*
|
||
|
|
Copyright 2017 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 azure
|
||
|
|
|
||
|
|
import (
|
||
|
|
"time"
|
||
|
|
|
||
|
|
"github.com/Azure/azure-sdk-for-go/arm/compute"
|
||
|
|
|
||
|
|
"k8s.io/apimachinery/pkg/types"
|
||
|
|
kwait "k8s.io/apimachinery/pkg/util/wait"
|
||
|
|
)
|
||
|
|
|
||
|
|
const (
|
||
|
|
storageAccountNameTemplate = "pvc%s"
|
||
|
|
|
||
|
|
// for limits check https://docs.microsoft.com/en-us/azure/azure-subscription-service-limits#storage-limits
|
||
|
|
maxStorageAccounts = 100 // max # is 200 (250 with special request). this allows 100 for everything else including stand alone disks
|
||
|
|
maxDisksPerStorageAccounts = 60
|
||
|
|
storageAccountUtilizationBeforeGrowing = 0.5
|
||
|
|
|
||
|
|
maxLUN = 64 // max number of LUNs per VM
|
||
|
|
errLeaseFailed = "AcquireDiskLeaseFailed"
|
||
|
|
errLeaseIDMissing = "LeaseIdMissing"
|
||
|
|
errContainerNotFound = "ContainerNotFound"
|
||
|
|
errDiskBlobNotFound = "DiskBlobNotFound"
|
||
|
|
)
|
||
|
|
|
||
|
|
var defaultBackOff = kwait.Backoff{
|
||
|
|
Steps: 20,
|
||
|
|
Duration: 2 * time.Second,
|
||
|
|
Factor: 1.5,
|
||
|
|
Jitter: 0.0,
|
||
|
|
}
|
||
|
|
|
||
|
|
type controllerCommon struct {
|
||
|
|
subscriptionID string
|
||
|
|
location string
|
||
|
|
storageEndpointSuffix string
|
||
|
|
resourceGroup string
|
||
|
|
cloud *Cloud
|
||
|
|
}
|
||
|
|
|
||
|
|
// AttachDisk attaches a vhd to vm. The vhd must exist, can be identified by diskName, diskURI, and lun.
|
||
|
|
func (c *controllerCommon) AttachDisk(isManagedDisk bool, diskName, diskURI string, nodeName types.NodeName, lun int32, cachingMode compute.CachingTypes) error {
|
||
|
|
return c.cloud.vmSet.AttachDisk(isManagedDisk, diskName, diskURI, nodeName, lun, cachingMode)
|
||
|
|
}
|
||
|
|
|
||
|
|
// DetachDiskByName detaches a vhd from host. The vhd can be identified by diskName or diskURI.
|
||
|
|
func (c *controllerCommon) DetachDiskByName(diskName, diskURI string, nodeName types.NodeName) error {
|
||
|
|
return c.cloud.vmSet.DetachDiskByName(diskName, diskURI, nodeName)
|
||
|
|
}
|
||
|
|
|
||
|
|
// GetDiskLun finds the lun on the host that the vhd is attached to, given a vhd's diskName and diskURI.
|
||
|
|
func (c *controllerCommon) GetDiskLun(diskName, diskURI string, nodeName types.NodeName) (int32, error) {
|
||
|
|
return c.cloud.vmSet.GetDiskLun(diskName, diskURI, nodeName)
|
||
|
|
}
|
||
|
|
|
||
|
|
// GetNextDiskLun searches all vhd attachment on the host and find unused lun. Return -1 if all luns are used.
|
||
|
|
func (c *controllerCommon) GetNextDiskLun(nodeName types.NodeName) (int32, error) {
|
||
|
|
return c.cloud.vmSet.GetNextDiskLun(nodeName)
|
||
|
|
}
|
||
|
|
|
||
|
|
// DisksAreAttached checks if a list of volumes are attached to the node with the specified NodeName.
|
||
|
|
func (c *controllerCommon) DisksAreAttached(diskNames []string, nodeName types.NodeName) (map[string]bool, error) {
|
||
|
|
return c.cloud.vmSet.DisksAreAttached(diskNames, nodeName)
|
||
|
|
}
|