Versions in this module Expand all Collapse all v1 v1.24.10 Oct 24, 2017 v1.24.9 Oct 24, 2017 Changes in this version + const CloudProviderName + const ServiceAnnotationLoadBalancerInternal + const ServiceAnnotationLoadBalancerInternalSubnet + func ExtractDiskData(diskData interface{}) (provisioningState string, diskState string, err error) + func ExtractVMData(vmData map[string]interface{}) (dataDisks []interface{}, storageProfile map[string]interface{}, ...) + func GetServicePrincipalToken(config *Config, env *azure.Environment) (*adal.ServicePrincipalToken, error) + func MakeCRC32(str string) string + func NewCloud(configReader io.Reader) (cloudprovider.Interface, error) + type BlobDiskController struct + func (c *BlobDiskController) CreateBlobDisk(dataDiskName string, storageAccountType storage.SkuName, sizeGB int, ...) (string, error) + func (c *BlobDiskController) CreateVolume(name, storageAccount string, storageAccountType storage.SkuName, ...) (string, string, int, error) + func (c *BlobDiskController) DeleteBlobDisk(diskURI string, wasForced bool) error + func (c *BlobDiskController) DeleteVolume(diskURI string) error + type Cloud struct + DisksClient disk.DisksClient + Environment azure.Environment + InterfacesClient network.InterfacesClient + LoadBalancerClient network.LoadBalancersClient + PublicIPAddressesClient network.PublicIPAddressesClient + RouteTablesClient network.RouteTablesClient + RoutesClient network.RoutesClient + SecurityGroupsClient network.SecurityGroupsClient + StorageAccountClient storage.AccountsClient + SubnetsClient network.SubnetsClient + VirtualMachinesClient compute.VirtualMachinesClient + func (az *Cloud) AddSSHKeyToAllInstances(user string, keyData []byte) error + func (az *Cloud) Clusters() (cloudprovider.Clusters, bool) + func (az *Cloud) CreateFileShare(name, storageAccount, storageType, location string, requestGB int) (string, string, error) + func (az *Cloud) CreateOrUpdateInterfaceWithRetry(nic network.Interface) error + func (az *Cloud) CreateOrUpdateLBWithRetry(lb network.LoadBalancer) error + func (az *Cloud) CreateOrUpdatePIPWithRetry(pip network.PublicIPAddress) error + func (az *Cloud) CreateOrUpdateRouteTableWithRetry(routeTable network.RouteTable) error + func (az *Cloud) CreateOrUpdateRouteWithRetry(route network.Route) error + func (az *Cloud) CreateOrUpdateSGWithRetry(sg network.SecurityGroup) error + func (az *Cloud) CreateOrUpdateVMWithRetry(vmName string, newVM compute.VirtualMachine) error + func (az *Cloud) CreateRoute(clusterName string, nameHint string, kubeRoute *cloudprovider.Route) error + func (az *Cloud) CurrentNodeName(hostname string) (types.NodeName, error) + func (az *Cloud) DeleteFileShare(accountName, key, name string) error + func (az *Cloud) DeleteLBWithRetry(lbName string) error + func (az *Cloud) DeletePublicIPWithRetry(pipName string) error + func (az *Cloud) DeleteRoute(clusterName string, kubeRoute *cloudprovider.Route) error + func (az *Cloud) DeleteRouteWithRetry(routeName string) error + func (az *Cloud) EnsureLoadBalancer(clusterName string, service *v1.Service, nodes []*v1.Node) (*v1.LoadBalancerStatus, error) + func (az *Cloud) EnsureLoadBalancerDeleted(clusterName string, service *v1.Service) error + func (az *Cloud) ExternalID(name types.NodeName) (string, error) + func (az *Cloud) GetIPForMachineWithRetry(name types.NodeName) (string, error) + func (az *Cloud) GetLoadBalancer(clusterName string, service *v1.Service) (status *v1.LoadBalancerStatus, exists bool, err error) + func (az *Cloud) GetVirtualMachineWithRetry(name types.NodeName) (compute.VirtualMachine, bool, error) + func (az *Cloud) GetZone() (cloudprovider.Zone, error) + func (az *Cloud) GetZoneByNodeName(nodeName types.NodeName) (cloudprovider.Zone, error) + func (az *Cloud) GetZoneByProviderID(providerID string) (cloudprovider.Zone, error) + func (az *Cloud) HasClusterID() bool + func (az *Cloud) Initialize(clientBuilder controller.ControllerClientBuilder) + func (az *Cloud) InstanceExistsByProviderID(providerID string) (bool, error) + func (az *Cloud) InstanceID(name types.NodeName) (string, error) + func (az *Cloud) InstanceType(name types.NodeName) (string, error) + func (az *Cloud) InstanceTypeByProviderID(providerID string) (string, error) + func (az *Cloud) Instances() (cloudprovider.Instances, bool) + func (az *Cloud) ListRoutes(clusterName string) (routes []*cloudprovider.Route, err error) + func (az *Cloud) LoadBalancer() (cloudprovider.LoadBalancer, bool) + func (az *Cloud) NodeAddresses(name types.NodeName) ([]v1.NodeAddress, error) + func (az *Cloud) NodeAddressesByProviderID(providerID string) ([]v1.NodeAddress, error) + func (az *Cloud) ProviderName() string + func (az *Cloud) Routes() (cloudprovider.Routes, bool) + func (az *Cloud) ScrubDNS(nameservers, searches []string) (nsOut, srchOut []string) + func (az *Cloud) UpdateLoadBalancer(clusterName string, service *v1.Service, nodes []*v1.Node) error + func (az *Cloud) VirtualMachineClientGetWithRetry(resourceGroup, vmName string, types compute.InstanceViewTypes) (compute.VirtualMachine, error) + func (az *Cloud) Zones() (cloudprovider.Zones, bool) + func (c Cloud) AttachDisk(isManagedDisk bool, diskName, diskURI string, nodeName types.NodeName, ...) error + func (c Cloud) DetachDiskByName(diskName, diskURI string, nodeName types.NodeName) error + func (c Cloud) DisksAreAttached(diskNames []string, nodeName types.NodeName) (map[string]bool, error) + func (c Cloud) GetDiskLun(diskName, diskURI string, nodeName types.NodeName) (int32, error) + func (c Cloud) GetNextDiskLun(nodeName types.NodeName) (int32, error) + type Config struct + AADClientCertPassword string + AADClientCertPath string + AADClientID string + AADClientSecret string + Cloud string + CloudProviderBackoff bool + CloudProviderBackoffDuration int + CloudProviderBackoffExponent float64 + CloudProviderBackoffJitter float64 + CloudProviderBackoffRetries int + CloudProviderRateLimit bool + CloudProviderRateLimitBucket int + CloudProviderRateLimitQPS float32 + Location string + PrimaryAvailabilitySetName string + ResourceGroup string + RouteTableName string + SecurityGroupName string + SubnetName string + SubscriptionID string + TenantID string + UseInstanceMetadata bool + UseManagedIdentityExtension bool + VnetName string + VnetResourceGroup string + func ParseConfig(configReader io.Reader) (*Config, *azure.Environment, error) + type IPAddress struct + PrivateIP string + PublicIP string + type InstanceMetadata struct + func NewInstanceMetadata() *InstanceMetadata + func (i *InstanceMetadata) Object(path string, obj interface{}) error + func (i *InstanceMetadata) Text(path string) (string, error) + type ManagedDiskController struct + func (c *ManagedDiskController) CreateManagedDisk(diskName string, storageAccountType storage.SkuName, sizeGB int, ...) (string, error) + func (c *ManagedDiskController) DeleteManagedDisk(diskURI string) error + type NetworkData struct + IPAddress []IPAddress + Subnet []Subnet + type NetworkInterface struct + IPV4 NetworkData + IPV6 NetworkData + MAC string + type NetworkMetadata struct + Interface []NetworkInterface + type Subnet struct + Address string + Prefix string