azure_dd

Documentation

Index

• Constants
• func ConvertTagsToMap(tags string) (map[string]string, error)
• func ProbeVolumePlugins() []volume.VolumePlugin
• type DiskController

Constants

const (
	TagsDelimiter        = ","
	TagKeyValueDelimiter = "="
)

Functions

func ConvertTagsToMap

func ConvertTagsToMap(tags string) (map[string]string, error)

ConvertTagsToMap convert the tags from string to map the valid tags fomat is "key1=value1,key2=value2", which could be converted to {"key1": "value1", "key2": "value2"}

func ProbeVolumePlugins

func ProbeVolumePlugins() []volume.VolumePlugin

Types

type DiskController

type DiskController interface {
	CreateBlobDisk(dataDiskName string, storageAccountType storage.SkuName, sizeGB int) (string, error)
	DeleteBlobDisk(diskUri string) error

	CreateManagedDisk(options *azure.ManagedDiskOptions) (string, error)
	DeleteManagedDisk(diskURI string) error

	// Attaches the disk to the host machine.
	AttachDisk(isManagedDisk bool, diskName, diskUri string, nodeName types.NodeName, cachingMode compute.CachingTypes) (int32, error)
	// Detaches the disk, identified by disk name or uri, from the host machine.
	DetachDisk(diskName, diskUri string, nodeName types.NodeName) error

	// Check if a list of volumes are attached to the node with the specified NodeName
	DisksAreAttached(diskNames []string, nodeName types.NodeName) (map[string]bool, error)

	// Get the LUN number of the disk that is attached to the host
	GetDiskLun(diskName, diskUri string, nodeName types.NodeName) (int32, error)
	// Get the next available LUN number to attach a new VHD
	GetNextDiskLun(nodeName types.NodeName) (int32, error)

	// Create a VHD blob
	CreateVolume(name, storageAccount, storageAccountType, location string, requestGB int) (string, string, int, error)
	// Delete a VHD blob
	DeleteVolume(diskURI string) error

	// Expand the disk to new size
	ResizeDisk(diskURI string, oldSize resource.Quantity, newSize resource.Quantity) (resource.Quantity, error)

	// GetAzureDiskLabels gets availability zone labels for Azuredisk.
	GetAzureDiskLabels(diskURI string) (map[string]string, error)

	// GetActiveZones returns all the zones in which k8s nodes are currently running.
	GetActiveZones() (sets.String, error)

	// GetLocation returns the location in which k8s cluster is currently running.
	GetLocation() string
}

DiskController interface exposed by the cloud provider implementing Disk functionality