Documentation
¶
Index ¶
- Constants
- func NewCloud(configReader io.Reader) (cloudprovider.Interface, error)
- type Cloud
- func (az *Cloud) AddSSHKeyToAllInstances(user string, keyData []byte) error
- func (az *Cloud) AttachDisk(diskName, diskURI string, nodeName types.NodeName, lun int32, ...) error
- func (az *Cloud) Clusters() (cloudprovider.Clusters, bool)
- 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) CreateVolume(name, storageAccount, storageType, location string, requestGB int) (string, string, int, error)
- func (az *Cloud) CurrentNodeName(hostname string) (types.NodeName, 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) DeleteVolume(name, uri string) error
- func (az *Cloud) DetachDiskByName(diskName, diskURI string, nodeName types.NodeName) error
- func (az *Cloud) DisksAreAttached(diskNames []string, nodeName types.NodeName) (map[string]bool, 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) GetDiskLun(diskName, diskURI string, nodeName types.NodeName) (int32, error)
- func (az *Cloud) GetLoadBalancer(clusterName string, service *v1.Service) (status *v1.LoadBalancerStatus, exists bool, err error)
- func (az *Cloud) GetNextDiskLun(nodeName types.NodeName) (int32, error)
- func (az *Cloud) GetVirtualMachineWithRetry(name types.NodeName) (compute.VirtualMachine, bool, error)
- func (az *Cloud) GetZone() (cloudprovider.Zone, error)
- func (az *Cloud) InstanceID(name types.NodeName) (string, error)
- func (az *Cloud) InstanceType(name types.NodeName) (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) 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) Zones() (cloudprovider.Zones, bool)
- type Config
Constants ¶
const (
// CloudProviderName is the value used for the --cloud-provider flag
CloudProviderName = "azure"
)
const ServiceAnnotationLoadBalancerInternal = "service.beta.kubernetes.io/azure-load-balancer-internal"
ServiceAnnotationLoadBalancerInternal is the annotation used on the service
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Cloud ¶
type Cloud struct { Config Environment azure.Environment RoutesClient network.RoutesClient SubnetsClient network.SubnetsClient InterfacesClient network.InterfacesClient RouteTablesClient network.RouteTablesClient LoadBalancerClient network.LoadBalancersClient PublicIPAddressesClient network.PublicIPAddressesClient SecurityGroupsClient network.SecurityGroupsClient VirtualMachinesClient compute.VirtualMachinesClient StorageAccountClient storage.AccountsClient // contains filtered or unexported fields }
Cloud holds the config and clients
func (*Cloud) AddSSHKeyToAllInstances ¶
AddSSHKeyToAllInstances adds an SSH public key as a legal identity for all instances expected format for the key is standard ssh-keygen format: <protocol> <blob>
func (*Cloud) AttachDisk ¶
func (az *Cloud) AttachDisk(diskName, diskURI string, nodeName types.NodeName, lun int32, cachingMode compute.CachingTypes) error
AttachDisk attaches a vhd to vm the vhd must exist, can be identified by diskName, diskURI, and lun.
func (*Cloud) Clusters ¶
func (az *Cloud) Clusters() (cloudprovider.Clusters, bool)
Clusters returns a clusters interface. Also returns true if the interface is supported, false otherwise.
func (*Cloud) CreateOrUpdateInterfaceWithRetry ¶ added in v1.6.6
CreateOrUpdateInterfaceWithRetry invokes az.PublicIPAddressesClient.CreateOrUpdate with exponential backoff retry
func (*Cloud) CreateOrUpdateLBWithRetry ¶ added in v1.6.6
func (az *Cloud) CreateOrUpdateLBWithRetry(lb network.LoadBalancer) error
CreateOrUpdateLBWithRetry invokes az.LoadBalancerClient.CreateOrUpdate with exponential backoff retry
func (*Cloud) CreateOrUpdatePIPWithRetry ¶ added in v1.6.6
func (az *Cloud) CreateOrUpdatePIPWithRetry(pip network.PublicIPAddress) error
CreateOrUpdatePIPWithRetry invokes az.PublicIPAddressesClient.CreateOrUpdate with exponential backoff retry
func (*Cloud) CreateOrUpdateRouteTableWithRetry ¶ added in v1.6.6
func (az *Cloud) CreateOrUpdateRouteTableWithRetry(routeTable network.RouteTable) error
CreateOrUpdateRouteTableWithRetry invokes az.RouteTablesClient.CreateOrUpdate with exponential backoff retry
func (*Cloud) CreateOrUpdateRouteWithRetry ¶ added in v1.6.6
CreateOrUpdateRouteWithRetry invokes az.RoutesClient.CreateOrUpdate with exponential backoff retry
func (*Cloud) CreateOrUpdateSGWithRetry ¶ added in v1.6.6
func (az *Cloud) CreateOrUpdateSGWithRetry(sg network.SecurityGroup) error
CreateOrUpdateSGWithRetry invokes az.SecurityGroupsClient.CreateOrUpdate with exponential backoff retry
func (*Cloud) CreateOrUpdateVMWithRetry ¶ added in v1.6.6
func (az *Cloud) CreateOrUpdateVMWithRetry(vmName string, newVM compute.VirtualMachine) error
CreateOrUpdateVMWithRetry invokes az.VirtualMachinesClient.CreateOrUpdate with exponential backoff retry
func (*Cloud) CreateRoute ¶
func (az *Cloud) CreateRoute(clusterName string, nameHint string, kubeRoute *cloudprovider.Route) error
CreateRoute creates the described managed route route.Name will be ignored, although the cloud-provider may use nameHint to create a more user-meaningful name.
func (*Cloud) CreateVolume ¶ added in v1.5.0
func (az *Cloud) CreateVolume(name, storageAccount, storageType, location string, requestGB int) (string, string, int, error)
CreateVolume creates a VHD blob in a storage account that has storageType and location using the given storage account. If no storage account is given, search all the storage accounts associated with the resource group and pick one that fits storage type and location.
func (*Cloud) CurrentNodeName ¶
CurrentNodeName returns the name of the node we are currently running on On most clouds (e.g. GCE) this is the hostname, so we provide the hostname
func (*Cloud) DeleteLBWithRetry ¶ added in v1.6.6
DeleteLBWithRetry invokes az.LoadBalancerClient.Delete with exponential backoff retry
func (*Cloud) DeletePublicIPWithRetry ¶ added in v1.6.6
DeletePublicIPWithRetry invokes az.PublicIPAddressesClient.Delete with exponential backoff retry
func (*Cloud) DeleteRoute ¶
func (az *Cloud) DeleteRoute(clusterName string, kubeRoute *cloudprovider.Route) error
DeleteRoute deletes the specified managed route Route should be as returned by ListRoutes
func (*Cloud) DeleteRouteWithRetry ¶ added in v1.6.6
DeleteRouteWithRetry invokes az.RoutesClient.Delete with exponential backoff retry
func (*Cloud) DeleteVolume ¶ added in v1.5.0
DeleteVolume deletes a VHD blob
func (*Cloud) DetachDiskByName ¶
DetachDiskByName detaches a vhd from host the vhd can be identified by diskName or diskURI
func (*Cloud) DisksAreAttached ¶ added in v1.4.6
func (az *Cloud) DisksAreAttached(diskNames []string, nodeName types.NodeName) (map[string]bool, error)
DisksAreAttached checks if a list of volumes are attached to the node with the specified NodeName
func (*Cloud) EnsureLoadBalancer ¶
func (az *Cloud) EnsureLoadBalancer(clusterName string, service *v1.Service, nodes []*v1.Node) (*v1.LoadBalancerStatus, error)
EnsureLoadBalancer creates a new load balancer 'name', or updates the existing one. Returns the status of the balancer
func (*Cloud) EnsureLoadBalancerDeleted ¶
EnsureLoadBalancerDeleted deletes the specified load balancer if it exists, returning nil if the load balancer specified either didn't exist or was successfully deleted. This construction is useful because many cloud providers' load balancers have multiple underlying components, meaning a Get could say that the LB doesn't exist even if some part of it is still laying around.
func (*Cloud) ExternalID ¶
ExternalID returns the cloud provider ID of the specified instance (deprecated).
func (*Cloud) GetDiskLun ¶
GetDiskLun finds the lun on the host that the vhd is attached to, given a vhd's diskName and diskURI
func (*Cloud) GetLoadBalancer ¶
func (az *Cloud) GetLoadBalancer(clusterName string, service *v1.Service) (status *v1.LoadBalancerStatus, exists bool, err error)
GetLoadBalancer returns whether the specified load balancer exists, and if so, what its status is.
func (*Cloud) GetNextDiskLun ¶
GetNextDiskLun searches all vhd attachment on the host and find unused lun return -1 if all luns are used
func (*Cloud) GetVirtualMachineWithRetry ¶ added in v1.6.6
func (az *Cloud) GetVirtualMachineWithRetry(name types.NodeName) (compute.VirtualMachine, bool, error)
GetVirtualMachineWithRetry invokes az.getVirtualMachine with exponential backoff retry
func (*Cloud) GetZone ¶
func (az *Cloud) GetZone() (cloudprovider.Zone, error)
GetZone returns the Zone containing the current failure zone and locality region that the program is running in
func (*Cloud) InstanceID ¶
InstanceID returns the cloud provider ID of the specified instance. Note that if the instance does not exist or is no longer running, we must return ("", cloudprovider.InstanceNotFound)
func (*Cloud) InstanceType ¶
InstanceType returns the type of the specified instance. Note that if the instance does not exist or is no longer running, we must return ("", cloudprovider.InstanceNotFound) (Implementer Note): This is used by kubelet. Kubelet will label the node. Real log from kubelet:
Adding node label from cloud provider: beta.kubernetes.io/instance-type=[value]
func (*Cloud) Instances ¶
func (az *Cloud) Instances() (cloudprovider.Instances, bool)
Instances returns an instances interface. Also returns true if the interface is supported, false otherwise.
func (*Cloud) ListRoutes ¶
func (az *Cloud) ListRoutes(clusterName string) (routes []*cloudprovider.Route, err error)
ListRoutes lists all managed routes that belong to the specified clusterName
func (*Cloud) LoadBalancer ¶
func (az *Cloud) LoadBalancer() (cloudprovider.LoadBalancer, bool)
LoadBalancer returns a balancer interface. Also returns true if the interface is supported, false otherwise.
func (*Cloud) NodeAddresses ¶
NodeAddresses returns the addresses of the specified instance.
func (*Cloud) ProviderName ¶
ProviderName returns the cloud provider ID.
func (*Cloud) Routes ¶
func (az *Cloud) Routes() (cloudprovider.Routes, bool)
Routes returns a routes interface along with whether the interface is supported.
func (*Cloud) ScrubDNS ¶
ScrubDNS provides an opportunity for cloud-provider-specific code to process DNS settings for pods.
type Config ¶
type Config struct { // The cloud environment identifier. Takes values from https://github.com/Azure/go-autorest/blob/ec5f4903f77ed9927ac95b19ab8e44ada64c1356/autorest/azure/environments.go#L13 Cloud string `json:"cloud" yaml:"cloud"` // The AAD Tenant ID for the Subscription that the cluster is deployed in TenantID string `json:"tenantId" yaml:"tenantId"` // The ID of the Azure Subscription that the cluster is deployed in SubscriptionID string `json:"subscriptionId" yaml:"subscriptionId"` // The name of the resource group that the cluster is deployed in ResourceGroup string `json:"resourceGroup" yaml:"resourceGroup"` // The location of the resource group that the cluster is deployed in Location string `json:"location" yaml:"location"` // The name of the VNet that the cluster is deployed in VnetName string `json:"vnetName" yaml:"vnetName"` // The name of the subnet that the cluster is deployed in SubnetName string `json:"subnetName" yaml:"subnetName"` // The name of the security group attached to the cluster's subnet SecurityGroupName string `json:"securityGroupName" yaml:"securityGroupName"` // (Optional in 1.6) The name of the route table attached to the subnet that the cluster is deployed in RouteTableName string `json:"routeTableName" yaml:"routeTableName"` // (Optional) The name of the availability set that should be used as the load balancer backend // If this is set, the Azure cloudprovider will only add nodes from that availability set to the load // balancer backend pool. If this is not set, and multiple agent pools (availability sets) are used, then // the cloudprovider will try to add all nodes to a single backend pool which is forbidden. // In other words, if you use multiple agent pools (availability sets), you MUST set this field. PrimaryAvailabilitySetName string `json:"primaryAvailabilitySetName" yaml:"primaryAvailabilitySetName"` // The ClientID for an AAD application with RBAC access to talk to Azure RM APIs AADClientID string `json:"aadClientId" yaml:"aadClientId"` // The ClientSecret for an AAD application with RBAC access to talk to Azure RM APIs AADClientSecret string `json:"aadClientSecret" yaml:"aadClientSecret"` // Enable exponential backoff to manage resource request retries CloudProviderBackoff bool `json:"cloudProviderBackoff" yaml:"cloudProviderBackoff"` // Backoff retry limit CloudProviderBackoffRetries int `json:"cloudProviderBackoffRetries" yaml:"cloudProviderBackoffRetries"` // Backoff exponent CloudProviderBackoffExponent float64 `json:"cloudProviderBackoffExponent" yaml:"cloudProviderBackoffExponent"` // Backoff duration CloudProviderBackoffDuration int `json:"cloudProviderBackoffDuration" yaml:"cloudProviderBackoffDuration"` // Backoff jitter CloudProviderBackoffJitter float64 `json:"cloudProviderBackoffJitter" yaml:"cloudProviderBackoffJitter"` // Enable rate limiting CloudProviderRateLimit bool `json:"cloudProviderRateLimit" yaml:"cloudProviderRateLimit"` // Rate limit QPS CloudProviderRateLimitQPS float32 `json:"cloudProviderRateLimitQPS" yaml:"cloudProviderRateLimitQPS"` // Rate limit Bucket Size CloudProviderRateLimitBucket int `json:"cloudProviderRateLimitBucket" yaml:"cloudProviderRateLimitBucket"` }
Config holds the configuration parsed from the --cloud-config flag All fields are required unless otherwise specified