Documentation ¶
Overview ¶
Package provider is a generated GoMock package.
Package provider is an implementation of CloudProvider Interface, LoadBalancer and Instances for Azure.
Index ¶
- Constants
- Variables
- func AreVNetRulesEqual(account storage.Account, accountOptions *AccountOptions) bool
- func ConvertResourceGroupNameToLower(resourceID string) (string, error)
- func FilterNonExistingDisks(ctx context.Context, diskClient diskclient.Interface, ...) []compute.DataDisk
- func IntInSlice(i int, list []int) bool
- func MakeCRC32(str string) string
- func MapRouteNameToNodeName(ipv6DualStackEnabled bool, routeName string) types.NodeName
- func NewCloud(ctx context.Context, config *Config, callFromCCM bool) (cloudprovider.Interface, error)
- func NewCloudFromConfigFile(ctx context.Context, configFilePath string, calFromCCM bool) (cloudprovider.Interface, error)
- func NewCloudFromSecret(ctx context.Context, clientBuilder cloudprovider.ControllerClientBuilder, ...) (cloudprovider.Interface, error)
- func StringInSlice(s string, list []string) bool
- func ToArmcomputeDisk(disks []compute.DataDisk) ([]*armcompute.DataDisk, error)
- type AccountOptions
- type AttachDiskOptions
- type AvailabilitySetEntry
- type BackendPool
- type Cloud
- func (az *Cloud) AddSSHKeyToAllInstances(_ context.Context, _ string, _ []byte) error
- func (az *Cloud) AddStorageAccountTags(ctx context.Context, subsID, resourceGroup, account string, ...) *retry.Error
- func (az *Cloud) Clusters() (cloudprovider.Clusters, bool)
- func (az *Cloud) CreateFileShare(ctx context.Context, accountOptions *AccountOptions, ...) (string, string, error)
- func (az *Cloud) CreateOrUpdateInterface(service *v1.Service, nic network.Interface) error
- func (az *Cloud) CreateOrUpdateLB(service *v1.Service, lb network.LoadBalancer) error
- func (az *Cloud) CreateOrUpdateLBBackendPool(lbName string, backendPool network.BackendAddressPool) error
- func (az *Cloud) CreateOrUpdatePIP(service *v1.Service, pipResourceGroup string, pip network.PublicIPAddress) error
- func (az *Cloud) CreateOrUpdatePLS(_ *v1.Service, resourceGroup string, pls network.PrivateLinkService) error
- func (az *Cloud) CreateOrUpdateRouteTable(routeTable network.RouteTable) error
- func (az *Cloud) CreateOrUpdateSecurityGroup(sg network.SecurityGroup) error
- func (az *Cloud) CreateOrUpdateSubnet(service *v1.Service, subnet network.Subnet) error
- func (az *Cloud) CreateOrUpdateVMSS(resourceGroupName string, VMScaleSetName string, ...) *retry.Error
- func (az *Cloud) CreateRoute(_ context.Context, clusterName string, _ string, ...) error
- func (az *Cloud) CurrentNodeName(_ context.Context, hostname string) (types.NodeName, error)
- func (az *Cloud) DeleteFileShare(ctx context.Context, subsID, resourceGroup, accountName, shareName string) error
- func (az *Cloud) DeleteLB(service *v1.Service, lbName string) *retry.Error
- func (az *Cloud) DeleteLBBackendPool(lbName, backendPoolName string) error
- func (az *Cloud) DeletePEConn(service *v1.Service, resourceGroup, plsName, peConnName string) *retry.Error
- func (az *Cloud) DeletePLS(service *v1.Service, resourceGroup, plsName, plsLBFrontendID string) *retry.Error
- func (az *Cloud) DeletePublicIP(service *v1.Service, pipResourceGroup string, pipName string) error
- func (az *Cloud) DeleteRoute(_ context.Context, clusterName string, kubeRoute *cloudprovider.Route) error
- func (az *Cloud) EnsureLoadBalancer(ctx context.Context, clusterName string, service *v1.Service, nodes []*v1.Node) (*v1.LoadBalancerStatus, error)
- func (az *Cloud) EnsureLoadBalancerDeleted(ctx context.Context, clusterName string, service *v1.Service) error
- func (az *Cloud) EnsureStorageAccount(ctx context.Context, accountOptions *AccountOptions, ...) (string, string, error)
- func (az *Cloud) Event(obj runtime.Object, eventType, reason, message string)
- func (az *Cloud) GetActiveZones() (*utilsets.IgnoreCaseSet, error)
- func (az *Cloud) GetFileShare(ctx context.Context, subsID, resourceGroupName, accountName, name string) (storage.FileShare, error)
- func (az *Cloud) GetIPForMachineWithRetry(name types.NodeName) (string, string, error)
- func (az *Cloud) GetLoadBalancer(ctx context.Context, clusterName string, service *v1.Service) (status *v1.LoadBalancerStatus, exists bool, err error)
- func (az *Cloud) GetLoadBalancerName(_ context.Context, _ string, service *v1.Service) string
- func (az *Cloud) GetLocation() string
- func (az *Cloud) GetNodeNames() (*utilsets.IgnoreCaseSet, error)
- func (az *Cloud) GetNodeResourceGroup(nodeName string) (string, error)
- func (az *Cloud) GetNodeVMSet(nodeName types.NodeName, crt azcache.AzureCacheReadType) (VMSet, error)
- func (az *Cloud) GetPlatformSubFaultDomain() (string, error)
- func (az *Cloud) GetResourceGroups() (*utilsets.IgnoreCaseSet, error)
- func (az *Cloud) GetStorageAccesskey(ctx context.Context, subsID, account, resourceGroup string, ...) (string, error)
- func (az *Cloud) GetStorageAccesskeyFromServiceAccountToken(ctx context.Context, ...) (string, error)
- func (az *Cloud) GetUnmanagedNodes() (*utilsets.IgnoreCaseSet, error)
- func (az *Cloud) GetVMNameByIPConfigurationName(nicResourceGroup, nicName string) (string, error)
- func (az *Cloud) GetVirtualMachineWithRetry(name types.NodeName, crt azcache.AzureCacheReadType) (compute.VirtualMachine, error)
- func (az *Cloud) GetZone(_ context.Context) (cloudprovider.Zone, error)
- func (az *Cloud) GetZoneByNodeName(_ context.Context, nodeName types.NodeName) (cloudprovider.Zone, error)
- func (az *Cloud) GetZoneByProviderID(ctx context.Context, providerID string) (cloudprovider.Zone, error)
- func (az *Cloud) GetZoneID(zoneLabel string) string
- func (az *Cloud) HasClusterID() bool
- func (az *Cloud) Initialize(clientBuilder cloudprovider.ControllerClientBuilder, _ <-chan struct{})
- func (az *Cloud) InitializeCloudFromConfig(ctx context.Context, config *Config, fromSecret, callFromCCM bool) error
- func (az *Cloud) InstanceExists(ctx context.Context, node *v1.Node) (bool, error)
- func (az *Cloud) InstanceExistsByProviderID(ctx context.Context, providerID string) (bool, error)
- func (az *Cloud) InstanceID(_ context.Context, name types.NodeName) (string, error)
- func (az *Cloud) InstanceMetadata(ctx context.Context, node *v1.Node) (*cloudprovider.InstanceMetadata, error)
- func (az *Cloud) InstanceShutdown(ctx context.Context, node *v1.Node) (bool, error)
- func (az *Cloud) InstanceShutdownByProviderID(_ context.Context, providerID string) (bool, error)
- func (az *Cloud) InstanceType(_ context.Context, name types.NodeName) (string, error)
- func (az *Cloud) InstanceTypeByProviderID(ctx context.Context, providerID string) (string, error)
- func (az *Cloud) Instances() (cloudprovider.Instances, bool)
- func (az *Cloud) InstancesV2() (cloudprovider.InstancesV2, bool)
- func (az *Cloud) IsNodeUnmanaged(nodeName string) (bool, error)
- func (az *Cloud) IsNodeUnmanagedByProviderID(providerID string) bool
- func (az *Cloud) ListLB(service *v1.Service) ([]network.LoadBalancer, error)
- func (az *Cloud) ListManagedLBs(service *v1.Service, nodes []*v1.Node, clusterName string) (*[]network.LoadBalancer, error)
- func (az *Cloud) ListRoutes(_ context.Context, clusterName string) ([]*cloudprovider.Route, error)
- func (az *Cloud) ListVirtualMachines(resourceGroup string) ([]compute.VirtualMachine, error)
- func (az *Cloud) LoadBalancer() (cloudprovider.LoadBalancer, bool)
- func (az *Cloud) MigrateToIPBasedBackendPoolAndWaitForCompletion(lbName string, backendPoolNames []string, nicsCountMap map[string]int) error
- func (az *Cloud) NodeAddresses(_ context.Context, name types.NodeName) ([]v1.NodeAddress, error)
- func (az *Cloud) NodeAddressesByProviderID(ctx context.Context, providerID string) ([]v1.NodeAddress, error)
- func (az *Cloud) ProviderName() string
- func (az *Cloud) RemoveStorageAccountTag(ctx context.Context, subsID, resourceGroup, account, key string) *retry.Error
- func (az *Cloud) RequestBackoff() (resourceRequestBackoff wait.Backoff)
- func (az *Cloud) ResizeFileShare(ctx context.Context, subsID, resourceGroup, accountName, name string, ...) error
- func (az *Cloud) Routes() (cloudprovider.Routes, bool)
- func (az *Cloud) SetInformers(informerFactory informers.SharedInformerFactory)
- func (az *Cloud) ShouldNodeExcludedFromLoadBalancer(nodeName string) (bool, error)
- func (az *Cloud) UpdateLoadBalancer(ctx context.Context, clusterName string, service *v1.Service, nodes []*v1.Node) error
- func (az *Cloud) Zones() (cloudprovider.Zones, bool)
- type ComputeMetadata
- type Config
- type ExtendedLocation
- type FlexScaleSet
- func (fs *FlexScaleSet) AttachDisk(ctx context.Context, nodeName types.NodeName, ...) error
- func (fs *FlexScaleSet) DeleteCacheForNode(nodeName string) error
- func (fs *FlexScaleSet) DetachDisk(ctx context.Context, nodeName types.NodeName, diskMap map[string]string, ...) error
- func (fs *FlexScaleSet) EnsureBackendPoolDeleted(service *v1.Service, backendPoolIDs []string, vmSetName string, ...) (bool, error)
- func (fs *FlexScaleSet) EnsureBackendPoolDeletedFromVMSets(vmssNamesMap map[string]bool, backendPoolIDs []string) error
- func (fs *FlexScaleSet) EnsureHostInPool(service *v1.Service, nodeName types.NodeName, backendPoolID string, ...) (string, string, string, *compute.VirtualMachineScaleSetVM, error)
- func (fs *FlexScaleSet) EnsureHostsInPool(service *v1.Service, nodes []*v1.Node, backendPoolID string, ...) error
- func (fs *FlexScaleSet) GetAgentPoolVMSetNames(nodes []*v1.Node) (*[]string, error)
- func (fs *FlexScaleSet) GetDataDisks(nodeName types.NodeName, crt azcache.AzureCacheReadType) ([]*armcompute.DataDisk, *string, error)
- func (fs *FlexScaleSet) GetIPByNodeName(name string) (string, string, error)
- func (fs *FlexScaleSet) GetInstanceIDByNodeName(name string) (string, error)
- func (fs *FlexScaleSet) GetInstanceTypeByNodeName(name string) (string, error)
- func (fs *FlexScaleSet) GetNodeCIDRMasksByProviderID(providerID string) (int, int, error)
- func (fs *FlexScaleSet) GetNodeNameByIPConfigurationID(ipConfigurationID string) (string, string, error)
- func (fs *FlexScaleSet) GetNodeNameByProviderID(providerID string) (types.NodeName, error)
- func (fs *FlexScaleSet) GetNodeVMSetName(node *v1.Node) (string, error)
- func (fs *FlexScaleSet) GetPowerStatusByNodeName(name string) (powerState string, err error)
- func (fs *FlexScaleSet) GetPrimaryInterface(nodeName string) (network.Interface, error)
- func (fs *FlexScaleSet) GetPrimaryVMSetName() string
- func (fs *FlexScaleSet) GetPrivateIPsByNodeName(name string) ([]string, error)
- func (fs *FlexScaleSet) GetProvisioningStateByNodeName(name string) (provisioningState string, err error)
- func (fs *FlexScaleSet) GetVMSetNames(service *v1.Service, nodes []*v1.Node) (*[]string, error)
- func (fs *FlexScaleSet) GetZoneByNodeName(name string) (cloudprovider.Zone, error)
- func (fs *FlexScaleSet) UpdateVM(ctx context.Context, nodeName types.NodeName) error
- func (fs *FlexScaleSet) UpdateVMAsync(ctx context.Context, nodeName types.NodeName) (*azure.Future, error)
- func (fs *FlexScaleSet) WaitForUpdateResult(ctx context.Context, future *azure.Future, nodeName types.NodeName, ...) error
- type IPAddress
- type InstanceMetadata
- type InstanceMetadataService
- type LoadBalancerMetadata
- type LoadbalancerProfile
- type LockMap
- type MockBackendPool
- func (m *MockBackendPool) CleanupVMSetFromBackendPoolByCondition(slb *network.LoadBalancer, service *v1.Service, nodes []*v1.Node, ...) (*network.LoadBalancer, error)
- func (m *MockBackendPool) EXPECT() *MockBackendPoolMockRecorder
- func (m *MockBackendPool) EnsureHostsInPool(service *v1.Service, nodes []*v1.Node, ...) error
- func (m *MockBackendPool) GetBackendPrivateIPs(clusterName string, service *v1.Service, lb *network.LoadBalancer) ([]string, []string)
- func (m *MockBackendPool) ReconcileBackendPools(clusterName string, service *v1.Service, lb *network.LoadBalancer) (bool, bool, *network.LoadBalancer, error)
- type MockBackendPoolMockRecorder
- func (mr *MockBackendPoolMockRecorder) CleanupVMSetFromBackendPoolByCondition(slb, service, nodes, clusterName, shouldRemoveVMSetFromSLB interface{}) *gomock.Call
- func (mr *MockBackendPoolMockRecorder) EnsureHostsInPool(...) *gomock.Call
- func (mr *MockBackendPoolMockRecorder) GetBackendPrivateIPs(clusterName, service, lb interface{}) *gomock.Call
- func (mr *MockBackendPoolMockRecorder) ReconcileBackendPools(clusterName, service, lb interface{}) *gomock.Call
- type MockVMSet
- func (m *MockVMSet) AttachDisk(ctx context.Context, nodeName types.NodeName, ...) error
- func (m *MockVMSet) DeleteCacheForNode(nodeName string) error
- func (m *MockVMSet) DetachDisk(ctx context.Context, nodeName types.NodeName, diskMap map[string]string, ...) error
- func (m *MockVMSet) EXPECT() *MockVMSetMockRecorder
- func (m *MockVMSet) EnsureBackendPoolDeleted(service *v1.Service, backendPoolIDs []string, vmSetName string, ...) (bool, error)
- func (m *MockVMSet) EnsureBackendPoolDeletedFromVMSets(vmSetNamesMap map[string]bool, backendPoolIDs []string) error
- func (m *MockVMSet) EnsureHostInPool(service *v1.Service, nodeName types.NodeName, backendPoolID, vmSetName string) (string, string, string, *compute.VirtualMachineScaleSetVM, error)
- func (m *MockVMSet) EnsureHostsInPool(service *v1.Service, nodes []*v1.Node, backendPoolID, vmSetName string) error
- func (m *MockVMSet) GetAgentPoolVMSetNames(nodes []*v1.Node) (*[]string, error)
- func (m *MockVMSet) GetDataDisks(nodeName types.NodeName, crt cache.AzureCacheReadType) ([]*v5.DataDisk, *string, error)
- func (m *MockVMSet) GetIPByNodeName(name string) (string, string, error)
- func (m *MockVMSet) GetInstanceIDByNodeName(name string) (string, error)
- func (m *MockVMSet) GetInstanceTypeByNodeName(name string) (string, error)
- func (m *MockVMSet) GetNodeCIDRMasksByProviderID(providerID string) (int, int, error)
- func (m *MockVMSet) GetNodeNameByIPConfigurationID(ipConfigurationID string) (string, string, error)
- func (m *MockVMSet) GetNodeNameByProviderID(providerID string) (types.NodeName, error)
- func (m *MockVMSet) GetNodeVMSetName(node *v1.Node) (string, error)
- func (m *MockVMSet) GetPowerStatusByNodeName(name string) (string, error)
- func (m *MockVMSet) GetPrimaryInterface(nodeName string) (network.Interface, error)
- func (m *MockVMSet) GetPrimaryVMSetName() string
- func (m *MockVMSet) GetPrivateIPsByNodeName(name string) ([]string, error)
- func (m *MockVMSet) GetProvisioningStateByNodeName(name string) (string, error)
- func (m *MockVMSet) GetVMSetNames(service *v1.Service, nodes []*v1.Node) (*[]string, error)
- func (m *MockVMSet) GetZoneByNodeName(name string) (cloud_provider.Zone, error)
- func (m *MockVMSet) UpdateVM(ctx context.Context, nodeName types.NodeName) error
- type MockVMSetMockRecorder
- func (mr *MockVMSetMockRecorder) AttachDisk(ctx, nodeName, diskMap any) *gomock.Call
- func (mr *MockVMSetMockRecorder) DeleteCacheForNode(nodeName any) *gomock.Call
- func (mr *MockVMSetMockRecorder) DetachDisk(ctx, nodeName, diskMap any) *gomock.Call
- func (mr *MockVMSetMockRecorder) EnsureBackendPoolDeleted(service, backendPoolIDs, vmSetName, backendAddressPools, deleteFromVMSet any) *gomock.Call
- func (mr *MockVMSetMockRecorder) EnsureBackendPoolDeletedFromVMSets(vmSetNamesMap, backendPoolIDs any) *gomock.Call
- func (mr *MockVMSetMockRecorder) EnsureHostInPool(service, nodeName, backendPoolID, vmSetName any) *gomock.Call
- func (mr *MockVMSetMockRecorder) EnsureHostsInPool(service, nodes, backendPoolID, vmSetName any) *gomock.Call
- func (mr *MockVMSetMockRecorder) GetAgentPoolVMSetNames(nodes any) *gomock.Call
- func (mr *MockVMSetMockRecorder) GetDataDisks(nodeName, crt any) *gomock.Call
- func (mr *MockVMSetMockRecorder) GetIPByNodeName(name any) *gomock.Call
- func (mr *MockVMSetMockRecorder) GetInstanceIDByNodeName(name any) *gomock.Call
- func (mr *MockVMSetMockRecorder) GetInstanceTypeByNodeName(name any) *gomock.Call
- func (mr *MockVMSetMockRecorder) GetNodeCIDRMasksByProviderID(providerID any) *gomock.Call
- func (mr *MockVMSetMockRecorder) GetNodeNameByIPConfigurationID(ipConfigurationID any) *gomock.Call
- func (mr *MockVMSetMockRecorder) GetNodeNameByProviderID(providerID any) *gomock.Call
- func (mr *MockVMSetMockRecorder) GetNodeVMSetName(node any) *gomock.Call
- func (mr *MockVMSetMockRecorder) GetPowerStatusByNodeName(name any) *gomock.Call
- func (mr *MockVMSetMockRecorder) GetPrimaryInterface(nodeName any) *gomock.Call
- func (mr *MockVMSetMockRecorder) GetPrimaryVMSetName() *gomock.Call
- func (mr *MockVMSetMockRecorder) GetPrivateIPsByNodeName(name any) *gomock.Call
- func (mr *MockVMSetMockRecorder) GetProvisioningStateByNodeName(name any) *gomock.Call
- func (mr *MockVMSetMockRecorder) GetVMSetNames(service, nodes any) *gomock.Call
- func (mr *MockVMSetMockRecorder) GetZoneByNodeName(name any) *gomock.Call
- func (mr *MockVMSetMockRecorder) UpdateVM(ctx, nodeName any) *gomock.Call
- type MultipleStandardLoadBalancerConfiguration
- type MultipleStandardLoadBalancerConfigurationSpec
- type MultipleStandardLoadBalancerConfigurationStatus
- type NetworkData
- type NetworkInterface
- type NetworkMetadata
- type NonVmssUniformNodesEntry
- type PublicIPMetadata
- type ScaleSet
- func (ss *ScaleSet) AttachDisk(ctx context.Context, nodeName types.NodeName, ...) error
- func (ss *ScaleSet) DeleteCacheForNode(nodeName string) error
- func (ss *ScaleSet) DetachDisk(ctx context.Context, nodeName types.NodeName, diskMap map[string]string, ...) error
- func (ss *ScaleSet) EnsureBackendPoolDeleted(service *v1.Service, backendPoolIDs []string, vmSetName string, ...) (bool, error)
- func (ss *ScaleSet) EnsureBackendPoolDeletedFromVMSets(vmssNamesMap map[string]bool, backendPoolIDs []string) error
- func (ss *ScaleSet) EnsureHostInPool(_ *v1.Service, nodeName types.NodeName, backendPoolID string, ...) (string, string, string, *compute.VirtualMachineScaleSetVM, error)
- func (ss *ScaleSet) EnsureHostsInPool(service *v1.Service, nodes []*v1.Node, backendPoolID string, ...) error
- func (ss *ScaleSet) GetAgentPoolVMSetNames(nodes []*v1.Node) (*[]string, error)
- func (ss *ScaleSet) GetDataDisks(nodeName types.NodeName, crt azcache.AzureCacheReadType) ([]*armcompute.DataDisk, *string, error)
- func (ss *ScaleSet) GetIPByNodeName(nodeName string) (string, string, error)
- func (ss *ScaleSet) GetInstanceIDByNodeName(name string) (string, error)
- func (ss *ScaleSet) GetInstanceTypeByNodeName(name string) (string, error)
- func (ss *ScaleSet) GetNodeCIDRMasksByProviderID(providerID string) (int, int, error)
- func (ss *ScaleSet) GetNodeNameByIPConfigurationID(ipConfigurationID string) (string, string, error)
- func (ss *ScaleSet) GetNodeNameByProviderID(providerID string) (types.NodeName, error)
- func (ss *ScaleSet) GetNodeVMSetName(node *v1.Node) (string, error)
- func (ss *ScaleSet) GetPowerStatusByNodeName(name string) (powerState string, err error)
- func (ss *ScaleSet) GetPrimaryInterface(nodeName string) (network.Interface, error)
- func (ss *ScaleSet) GetPrimaryVMSetName() string
- func (ss *ScaleSet) GetPrivateIPsByNodeName(nodeName string) ([]string, error)
- func (ss *ScaleSet) GetProvisioningStateByNodeName(name string) (provisioningState string, err error)
- func (ss *ScaleSet) GetVMSetNames(service *v1.Service, nodes []*v1.Node) (*[]string, error)
- func (ss *ScaleSet) GetZoneByNodeName(name string) (cloudprovider.Zone, error)
- func (ss *ScaleSet) UpdateVM(ctx context.Context, nodeName types.NodeName) error
- func (ss *ScaleSet) UpdateVMAsync(ctx context.Context, nodeName types.NodeName) (*azure.Future, error)
- func (ss *ScaleSet) VMSSBatchSize(vmssName string) (int, error)
- func (ss *ScaleSet) WaitForUpdateResult(ctx context.Context, future *azure.Future, nodeName types.NodeName, ...) error
- type StorageType
- type Subnet
- type VMManagementType
- type VMSSEntry
- type VMSSVirtualMachineEntry
- type VMSet
Constants ¶
const ( IPVersionIPv6 bool = true IPVersionIPv4 bool = false )
const DefaultTokenAudience = "api://AzureADTokenExchange" //nolint:gosec // G101 ignore this!
const LocationGlobal = "global"
const SkipMatchingTag = "skip-matching"
SkipMatchingTag skip account matching tag
const ( // WriteAcceleratorEnabled support for Azure Write Accelerator on Azure Disks // https://docs.microsoft.com/azure/virtual-machines/windows/how-to-enable-write-accelerator WriteAcceleratorEnabled = "writeacceleratorenabled" )
Variables ¶
var ( // ErrorNotVmssInstance indicates an instance is not belonging to any vmss. ErrorNotVmssInstance = errors.New("not a vmss instance") ErrScaleSetNotFound = errors.New("scale set not found") )
var ( // ErrorVmssIDIsEmpty indicates the vmss id is empty. ErrorVmssIDIsEmpty = errors.New("VMSS ID is empty") )
Functions ¶
func AreVNetRulesEqual ¶ added in v1.1.0
func AreVNetRulesEqual(account storage.Account, accountOptions *AccountOptions) bool
func ConvertResourceGroupNameToLower ¶ added in v1.25.0
ConvertResourceGroupNameToLower converts the resource group name in the resource ID to be lowered.
func FilterNonExistingDisks ¶ added in v1.29.0
func IntInSlice ¶ added in v1.28.0
IntInSlice checks if an int is in a list
func MapRouteNameToNodeName ¶ added in v1.0.0
MapRouteNameToNodeName is used with mapNodeNameToRouteName. See comment on mapNodeNameToRouteName for detailed usage.
func NewCloud ¶
func NewCloud(ctx context.Context, config *Config, callFromCCM bool) (cloudprovider.Interface, error)
NewCloud returns a Cloud with initialized clients
func NewCloudFromConfigFile ¶ added in v1.0.1
func NewCloudFromSecret ¶ added in v1.0.0
func NewCloudFromSecret(ctx context.Context, clientBuilder cloudprovider.ControllerClientBuilder, secretName, secretNamespace, cloudConfigKey string) (cloudprovider.Interface, error)
func StringInSlice ¶ added in v1.28.0
StringInSlice check if string in a list
func ToArmcomputeDisk ¶ added in v1.29.0
ToArmcomputeDisk converts compute.DataDisk to armcompute.DataDisk This is a workaround during track2 migration. TODO: remove this function after compute api is migrated to track2
Types ¶
type AccountOptions ¶
type AccountOptions struct { SubscriptionID string Name, Type, Kind, ResourceGroup, Location string EnableHTTPSTrafficOnly bool // indicate whether create new account when Name is empty or when account does not exists CreateAccount bool CreatePrivateEndpoint *bool StorageType StorageType StorageEndpointSuffix string DisableFileServiceDeleteRetentionPolicy *bool IsHnsEnabled *bool EnableNfsV3 *bool AllowBlobPublicAccess *bool RequireInfrastructureEncryption *bool IsMultichannelEnabled *bool KeyName *string KeyVersion *string KeyVaultURI *string Tags map[string]string VirtualNetworkResourceIDs []string VNetResourceGroup string VNetName string SubnetName string AccessTier string MatchTags bool GetLatestAccountKey bool EnableBlobVersioning *bool SoftDeleteBlobs int32 SoftDeleteContainers int32 // indicate whether to get a random matching account, if false, will get the first matching account PickRandomMatchingAccount bool }
AccountOptions contains the fields which are used to create storage account.
type AttachDiskOptions ¶
type AttachDiskOptions struct { CachingMode compute.CachingTypes DiskName string DiskEncryptionSetID string WriteAcceleratorEnabled bool Lun int32 }
AttachDiskOptions attach disk options
type AvailabilitySetEntry ¶ added in v1.1.27
type AvailabilitySetEntry struct { VMAS *compute.AvailabilitySet ResourceGroup string }
type BackendPool ¶ added in v1.23.0
type BackendPool interface { // EnsureHostsInPool ensures the nodes join the backend pool of the load balancer EnsureHostsInPool(service *v1.Service, nodes []*v1.Node, backendPoolID, vmSetName, clusterName, lbName string, backendPool network.BackendAddressPool) error // CleanupVMSetFromBackendPoolByCondition removes nodes of the unwanted vmSet from the lb backend pool. // This is needed in two scenarios: // 1. When migrating from single SLB to multiple SLBs, the existing // SLB's backend pool contains nodes from different agent pools, while we only want the // nodes from the primary agent pool to join the backend pool. // 2. When migrating from dedicated SLB to shared SLB (or vice versa), we should move the vmSet from // one SLB to another one. CleanupVMSetFromBackendPoolByCondition(slb *network.LoadBalancer, service *v1.Service, nodes []*v1.Node, clusterName string, shouldRemoveVMSetFromSLB func(string) bool) (*network.LoadBalancer, error) // ReconcileBackendPools creates the inbound backend pool if it is not existed, and removes nodes that are supposed to be // excluded from the load balancers. ReconcileBackendPools(clusterName string, service *v1.Service, lb *network.LoadBalancer) (bool, bool, *network.LoadBalancer, error) // GetBackendPrivateIPs returns the private IPs of LoadBalancer's backend pool GetBackendPrivateIPs(clusterName string, service *v1.Service, lb *network.LoadBalancer) ([]string, []string) }
type Cloud ¶
type Cloud struct { Config Environment azure.Environment RoutesClient routeclient.Interface SubnetsClient subnetclient.Interface InterfacesClient interfaceclient.Interface RouteTablesClient routetableclient.Interface LoadBalancerClient loadbalancerclient.Interface PublicIPAddressesClient publicipclient.Interface SecurityGroupsClient securitygroupclient.Interface VirtualMachinesClient vmclient.Interface StorageAccountClient storageaccountclient.Interface DisksClient diskclient.Interface SnapshotsClient snapshotclient.Interface FileClient fileclient.Interface BlobClient blobclient.Interface VirtualMachineScaleSetsClient vmssclient.Interface VirtualMachineScaleSetVMsClient vmssvmclient.Interface VirtualMachineSizesClient vmsizeclient.Interface AvailabilitySetsClient vmasclient.Interface ZoneClient zoneclient.Interface PrivateLinkServiceClient privatelinkserviceclient.Interface ComputeClientFactory azclient.ClientFactory NetworkClientFactory azclient.ClientFactory AuthProvider *azclient.AuthProvider ResourceRequestBackoff wait.Backoff Metadata *InstanceMetadataService VMSet VMSet LoadBalancerBackendPool BackendPool KubeClient clientset.Interface // contains filtered or unexported fields }
Cloud holds the config and clients
func GetTestCloud ¶
func GetTestCloud(ctrl *gomock.Controller) (az *Cloud)
GetTestCloud returns a fake azure cloud for unit tests in Azure related CSI drivers
func GetTestCloudWithExtendedLocation ¶ added in v0.7.1
func GetTestCloudWithExtendedLocation(ctrl *gomock.Controller) (az *Cloud)
GetTestCloudWithExtendedLocation returns a fake azure cloud for unit tests in Azure related CSI drivers with extended location.
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) AddStorageAccountTags ¶ added in v0.7.1
func (az *Cloud) AddStorageAccountTags(ctx context.Context, subsID, resourceGroup, account string, tags map[string]*string) *retry.Error
AddStorageAccountTags add tags to storage account
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) CreateFileShare ¶
func (az *Cloud) CreateFileShare(ctx context.Context, accountOptions *AccountOptions, shareOptions *fileclient.ShareOptions) (string, string, error)
CreateFileShare creates a file share, using a matching storage account type, account kind, etc. storage account will be created if specified account is not found
func (*Cloud) CreateOrUpdateInterface ¶
CreateOrUpdateInterface invokes az.InterfacesClient.CreateOrUpdate with exponential backoff retry
func (*Cloud) CreateOrUpdateLB ¶
CreateOrUpdateLB invokes az.LoadBalancerClient.CreateOrUpdate with exponential backoff retry
func (*Cloud) CreateOrUpdateLBBackendPool ¶ added in v1.23.0
func (az *Cloud) CreateOrUpdateLBBackendPool(lbName string, backendPool network.BackendAddressPool) error
func (*Cloud) CreateOrUpdatePIP ¶
func (az *Cloud) CreateOrUpdatePIP(service *v1.Service, pipResourceGroup string, pip network.PublicIPAddress) error
CreateOrUpdatePIP invokes az.PublicIPAddressesClient.CreateOrUpdate with exponential backoff retry
func (*Cloud) CreateOrUpdatePLS ¶ added in v1.0.19
func (*Cloud) CreateOrUpdateRouteTable ¶
func (az *Cloud) CreateOrUpdateRouteTable(routeTable network.RouteTable) error
CreateOrUpdateRouteTable invokes az.RouteTablesClient.CreateOrUpdate with exponential backoff retry
func (*Cloud) CreateOrUpdateSecurityGroup ¶
func (az *Cloud) CreateOrUpdateSecurityGroup(sg network.SecurityGroup) error
CreateOrUpdateSecurityGroup invokes az.SecurityGroupsClient.CreateOrUpdate with exponential backoff retry
func (*Cloud) CreateOrUpdateSubnet ¶ added in v1.0.19
CreateOrUpdateSubnet invokes az.SubnetClient.CreateOrUpdate with exponential backoff retry
func (*Cloud) CreateOrUpdateVMSS ¶
func (az *Cloud) CreateOrUpdateVMSS(resourceGroupName string, VMScaleSetName string, parameters compute.VirtualMachineScaleSet) *retry.Error
CreateOrUpdateVMSS invokes az.VirtualMachineScaleSetsClient.Update().
func (*Cloud) CreateRoute ¶
func (az *Cloud) CreateRoute(_ context.Context, clusterName string, _ 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. implements cloudprovider.Routes.CreateRoute
func (*Cloud) CurrentNodeName ¶
CurrentNodeName returns the name of the node we are currently running on. On Azure this is the hostname, so we just return the hostname.
func (*Cloud) DeleteFileShare ¶
func (az *Cloud) DeleteFileShare(ctx context.Context, subsID, resourceGroup, accountName, shareName string) error
DeleteFileShare deletes a file share using storage account name and key
func (*Cloud) DeleteLB ¶
DeleteLB invokes az.LoadBalancerClient.Delete with exponential backoff retry
func (*Cloud) DeleteLBBackendPool ¶ added in v1.23.4
func (*Cloud) DeletePEConn ¶ added in v1.0.19
func (az *Cloud) DeletePEConn(service *v1.Service, resourceGroup, plsName, peConnName string) *retry.Error
DeletePEConn invokes az.PrivateLinkServiceClient.DeletePEConnection with exponential backoff retry
func (*Cloud) DeletePLS ¶ added in v1.0.19
func (az *Cloud) DeletePLS(service *v1.Service, resourceGroup, plsName, plsLBFrontendID string) *retry.Error
DeletePLS invokes az.PrivateLinkServiceClient.Delete with exponential backoff retry
func (*Cloud) DeletePublicIP ¶
DeletePublicIP invokes az.PublicIPAddressesClient.Delete with exponential backoff retry
func (*Cloud) DeleteRoute ¶
func (az *Cloud) DeleteRoute(_ context.Context, clusterName string, kubeRoute *cloudprovider.Route) error
DeleteRoute deletes the specified managed route Route should be as returned by ListRoutes implements cloudprovider.Routes.DeleteRoute
func (*Cloud) EnsureLoadBalancer ¶
func (az *Cloud) EnsureLoadBalancer(ctx context.Context, 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 Implementations must treat the *v1.Service and *v1.Node parameters as read-only and not modify them. Parameter 'clusterName' is the name of the cluster as presented to kube-controller-manager.
Implementations may return a (possibly wrapped) api.RetryError to enforce backing off at a fixed duration. This can be used for cases like when the load balancer is not ready yet (e.g., it is still being provisioned) and polling at a fixed rate is preferred over backing off exponentially in order to minimize latency.
func (*Cloud) EnsureLoadBalancerDeleted ¶
func (az *Cloud) EnsureLoadBalancerDeleted(ctx context.Context, clusterName string, service *v1.Service) error
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. Implementations must treat the *v1.Service parameter as read-only and not modify it. Parameter 'clusterName' is the name of the cluster as presented to kube-controller-manager
func (*Cloud) EnsureStorageAccount ¶
func (az *Cloud) EnsureStorageAccount(ctx context.Context, accountOptions *AccountOptions, genAccountNamePrefix string) (string, string, error)
EnsureStorageAccount search storage account, create one storage account(with genAccountNamePrefix) if not found, return accountName, accountKey
func (*Cloud) GetActiveZones ¶
func (az *Cloud) GetActiveZones() (*utilsets.IgnoreCaseSet, error)
GetActiveZones returns all the zones in which k8s nodes are currently running.
func (*Cloud) GetFileShare ¶
func (az *Cloud) GetFileShare(ctx context.Context, subsID, resourceGroupName, accountName, name string) (storage.FileShare, error)
GetFileShare gets a file share
func (*Cloud) GetIPForMachineWithRetry ¶
GetIPForMachineWithRetry invokes az.getIPForMachine with exponential backoff retry
func (*Cloud) GetLoadBalancer ¶
func (az *Cloud) GetLoadBalancer(ctx context.Context, 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. Implementations must treat the *v1.Service parameter as read-only and not modify it. Parameter 'clusterName' is the name of the cluster as presented to kube-controller-manager. TODO: Break this up into different interfaces (LB, etc) when we have more than one type of service
func (*Cloud) GetLoadBalancerName ¶
GetLoadBalancerName returns the name of the load balancer. Implementations must treat the *v1.Service parameter as read-only and not modify it.
func (*Cloud) GetLocation ¶
GetLocation returns the location in which k8s cluster is currently running.
func (*Cloud) GetNodeNames ¶ added in v0.7.3
func (az *Cloud) GetNodeNames() (*utilsets.IgnoreCaseSet, error)
GetNodeNames returns a set of all node names in the k8s cluster.
func (*Cloud) GetNodeResourceGroup ¶
GetNodeResourceGroup gets resource group for given node.
func (*Cloud) GetNodeVMSet ¶ added in v1.29.0
func (az *Cloud) GetNodeVMSet(nodeName types.NodeName, crt azcache.AzureCacheReadType) (VMSet, error)
getNodeVMSet gets the VMSet interface based on config.VMType and the real virtual machine type.
func (*Cloud) GetPlatformSubFaultDomain ¶ added in v0.7.13
GetPlatformSubFaultDomain returns the PlatformSubFaultDomain from IMDS if set.
func (*Cloud) GetResourceGroups ¶
func (az *Cloud) GetResourceGroups() (*utilsets.IgnoreCaseSet, error)
GetResourceGroups returns a set of resource groups that all nodes are running on.
func (*Cloud) GetStorageAccesskey ¶
func (az *Cloud) GetStorageAccesskey(ctx context.Context, subsID, account, resourceGroup string, getLatestAccountKey bool) (string, error)
GetStorageAccesskey gets the storage account access key getLatestAccountKey: get the latest account key per CreationTime if true, otherwise get the first account key
func (*Cloud) GetStorageAccesskeyFromServiceAccountToken ¶ added in v1.29.0
func (*Cloud) GetUnmanagedNodes ¶
func (az *Cloud) GetUnmanagedNodes() (*utilsets.IgnoreCaseSet, error)
GetUnmanagedNodes returns a list of nodes not managed by Azure cloud provider (e.g. on-prem nodes).
func (*Cloud) GetVMNameByIPConfigurationName ¶ added in v1.25.21
func (*Cloud) GetVirtualMachineWithRetry ¶
func (az *Cloud) GetVirtualMachineWithRetry(name types.NodeName, crt azcache.AzureCacheReadType) (compute.VirtualMachine, error)
GetVirtualMachineWithRetry invokes az.getVirtualMachine with exponential backoff retry
func (*Cloud) GetZone ¶
GetZone returns the Zone containing the current availability zone and locality region that the program is running in. DEPRECATED: Zones is deprecated in favor of retrieving zone/region information from InstancesV2. This interface will not be called if InstancesV2 is enabled. If the node is not running with availability zones, then it will fall back to fault domain.
func (*Cloud) GetZoneByNodeName ¶
func (az *Cloud) GetZoneByNodeName(_ context.Context, nodeName types.NodeName) (cloudprovider.Zone, error)
GetZoneByNodeName implements Zones.GetZoneByNodeName This is particularly useful in external cloud providers where the kubelet does not initialize node data. DEPRECATED: Zones is deprecated in favor of retrieving zone/region information from InstancesV2. This interface will not be called if InstancesV2 is enabled.
func (*Cloud) GetZoneByProviderID ¶
func (az *Cloud) GetZoneByProviderID(ctx context.Context, providerID string) (cloudprovider.Zone, error)
GetZoneByProviderID implements Zones.GetZoneByProviderID This is particularly useful in external cloud providers where the kubelet does not initialize node data. DEPRECATED: Zones is deprecated in favor of retrieving zone/region information from InstancesV2. This interface will not be called if InstancesV2 is enabled.
func (*Cloud) HasClusterID ¶
HasClusterID returns true if the cluster has a clusterID
func (*Cloud) Initialize ¶
func (az *Cloud) Initialize(clientBuilder cloudprovider.ControllerClientBuilder, _ <-chan struct{})
Initialize passes a Kubernetes clientBuilder interface to the cloud provider
func (*Cloud) InitializeCloudFromConfig ¶
func (az *Cloud) InitializeCloudFromConfig(ctx context.Context, config *Config, fromSecret, callFromCCM bool) error
InitializeCloudFromConfig initializes the Cloud from config.
func (*Cloud) InstanceExists ¶ added in v0.7.1
InstanceExists returns true if the instance for the given node exists according to the cloud provider. Use the node.name or node.spec.providerID field to find the node in the cloud provider.
func (*Cloud) InstanceExistsByProviderID ¶
InstanceExistsByProviderID returns true if the instance with the given provider id still exists and is running. If false is returned with no error, the instance will be immediately deleted by the cloud controller manager.
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) InstanceMetadata ¶ added in v0.7.1
func (az *Cloud) InstanceMetadata(ctx context.Context, node *v1.Node) (*cloudprovider.InstanceMetadata, error)
InstanceMetadata returns the instance's metadata. The values returned in InstanceMetadata are translated into specific fields in the Node object on registration. Use the node.name or node.spec.providerID field to find the node in the cloud provider.
func (*Cloud) InstanceShutdown ¶ added in v0.7.1
InstanceShutdown returns true if the instance is shutdown according to the cloud provider. Use the node.name or node.spec.providerID field to find the node in the cloud provider.
func (*Cloud) InstanceShutdownByProviderID ¶
InstanceShutdownByProviderID returns true if the instance is in safe state to detach volumes
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) InstanceTypeByProviderID ¶
InstanceTypeByProviderID returns the cloudprovider instance type of the node with the specified unique providerID This method will not be called from the node that is requesting this ID. i.e. metadata service and other local methods cannot be used here
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) InstancesV2 ¶
func (az *Cloud) InstancesV2() (cloudprovider.InstancesV2, bool)
InstancesV2 is an implementation for instances and should only be implemented by external cloud providers. Implementing InstancesV2 is behaviorally identical to Instances but is optimized to significantly reduce API calls to the cloud provider when registering and syncing nodes. Implementation of this interface will disable calls to the Zones interface. Also returns true if the interface is supported, false otherwise.
func (*Cloud) IsNodeUnmanaged ¶
IsNodeUnmanaged returns true if the node is not managed by Azure cloud provider. Those nodes includes on-prem or VMs from other clouds. They will not be added to load balancer backends. Azure routes and managed disks are also not supported for them.
func (*Cloud) IsNodeUnmanagedByProviderID ¶
IsNodeUnmanagedByProviderID returns true if the node is not managed by Azure cloud provider. All managed node's providerIDs are in format 'azure:///subscriptions/<id>/resourceGroups/<rg>/providers/Microsoft.Compute/.*'
func (*Cloud) ListManagedLBs ¶ added in v0.7.9
func (az *Cloud) ListManagedLBs(service *v1.Service, nodes []*v1.Node, clusterName string) (*[]network.LoadBalancer, error)
ListManagedLBs invokes az.LoadBalancerClient.List and filter out those that are not managed by cloud provider azure or not associated to a managed VMSet.
func (*Cloud) ListRoutes ¶
ListRoutes lists all managed routes that belong to the specified clusterName implements cloudprovider.Routes.ListRoutes
func (*Cloud) ListVirtualMachines ¶
func (az *Cloud) ListVirtualMachines(resourceGroup string) ([]compute.VirtualMachine, error)
ListVirtualMachines invokes az.VirtualMachinesClient.List with exponential backoff retry
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) MigrateToIPBasedBackendPoolAndWaitForCompletion ¶ added in v1.24.21
func (az *Cloud) MigrateToIPBasedBackendPoolAndWaitForCompletion( lbName string, backendPoolNames []string, nicsCountMap map[string]int, ) error
MigrateToIPBasedBackendPoolAndWaitForCompletion use the migration API to migrate from NIC-based to IP-based LB backend pools. It also makes sure the number of IP addresses in the backend pools is expected.
func (*Cloud) NodeAddresses ¶
NodeAddresses returns the addresses of the specified instance.
func (*Cloud) NodeAddressesByProviderID ¶
func (az *Cloud) NodeAddressesByProviderID(ctx context.Context, providerID string) ([]v1.NodeAddress, error)
NodeAddressesByProviderID returns the node addresses of an instances with the specified unique providerID This method will not be called from the node that is requesting this ID. i.e. metadata service and other local methods cannot be used here
func (*Cloud) ProviderName ¶
ProviderName returns the cloud provider ID.
func (*Cloud) RemoveStorageAccountTag ¶ added in v0.7.1
func (az *Cloud) RemoveStorageAccountTag(ctx context.Context, subsID, resourceGroup, account, key string) *retry.Error
RemoveStorageAccountTag remove tag from storage account
func (*Cloud) RequestBackoff ¶
RequestBackoff if backoff is disabled in cloud provider it returns a new Backoff object steps = 1 This is to make sure that the requested command executes at least once
func (*Cloud) ResizeFileShare ¶
func (az *Cloud) ResizeFileShare(ctx context.Context, subsID, resourceGroup, accountName, name string, sizeGiB int) error
ResizeFileShare resizes a file share
func (*Cloud) Routes ¶
func (az *Cloud) Routes() (cloudprovider.Routes, bool)
Routes returns a routes interface along with whether the interface is supported.
func (*Cloud) SetInformers ¶
func (az *Cloud) SetInformers(informerFactory informers.SharedInformerFactory)
SetInformers sets informers for Azure cloud provider.
func (*Cloud) ShouldNodeExcludedFromLoadBalancer ¶
ShouldNodeExcludedFromLoadBalancer returns true if node is unmanaged, in external resource group or labeled with "node.kubernetes.io/exclude-from-external-load-balancers".
func (*Cloud) UpdateLoadBalancer ¶
func (az *Cloud) UpdateLoadBalancer(ctx context.Context, clusterName string, service *v1.Service, nodes []*v1.Node) error
UpdateLoadBalancer updates hosts under the specified load balancer. Implementations must treat the *v1.Service and *v1.Node parameters as read-only and not modify them. Parameter 'clusterName' is the name of the cluster as presented to kube-controller-manager
func (*Cloud) Zones ¶
func (az *Cloud) Zones() (cloudprovider.Zones, bool)
Zones returns a zones interface. Also returns true if the interface is supported, false otherwise. DEPRECATED: Zones is deprecated in favor of retrieving zone/region information from InstancesV2. This interface will not be called if InstancesV2 is enabled.
type ComputeMetadata ¶
type ComputeMetadata struct { Environment string `json:"azEnvironment,omitempty"` SKU string `json:"sku,omitempty"` Name string `json:"name,omitempty"` Zone string `json:"zone,omitempty"` VMSize string `json:"vmSize,omitempty"` OSType string `json:"osType,omitempty"` Location string `json:"location,omitempty"` FaultDomain string `json:"platformFaultDomain,omitempty"` PlatformSubFaultDomain string `json:"platformSubFaultDomain,omitempty"` UpdateDomain string `json:"platformUpdateDomain,omitempty"` ResourceGroup string `json:"resourceGroupName,omitempty"` VMScaleSetName string `json:"vmScaleSetName,omitempty"` SubscriptionID string `json:"subscriptionId,omitempty"` ResourceID string `json:"resourceId,omitempty"` }
ComputeMetadata represents compute information
type Config ¶
type Config struct { ratelimitconfig.AzureAuthConfig `json:",inline" yaml:",inline"` ratelimitconfig.CloudProviderRateLimitConfig `json:",inline" yaml:",inline"` // The cloud configure type for Azure cloud provider. Supported values are file, secret and merge. CloudConfigType configloader.CloudConfigType `json:"cloudConfigType,omitempty" yaml:"cloudConfigType,omitempty"` // The name of the resource group that the cluster is deployed in ResourceGroup string `json:"resourceGroup,omitempty" yaml:"resourceGroup,omitempty"` // The location of the resource group that the cluster is deployed in Location string `json:"location,omitempty" yaml:"location,omitempty"` // The name of site where the cluster will be deployed to that is more granular than the region specified by the "location" field. // Currently only public ip, load balancer and managed disks support this. ExtendedLocationName string `json:"extendedLocationName,omitempty" yaml:"extendedLocationName,omitempty"` // The type of site that is being targeted. // Currently only public ip, load balancer and managed disks support this. ExtendedLocationType string `json:"extendedLocationType,omitempty" yaml:"extendedLocationType,omitempty"` // The name of the VNet that the cluster is deployed in VnetName string `json:"vnetName,omitempty" yaml:"vnetName,omitempty"` // The name of the resource group that the Vnet is deployed in VnetResourceGroup string `json:"vnetResourceGroup,omitempty" yaml:"vnetResourceGroup,omitempty"` // The name of the subnet that the cluster is deployed in SubnetName string `json:"subnetName,omitempty" yaml:"subnetName,omitempty"` // The name of the security group attached to the cluster's subnet SecurityGroupName string `json:"securityGroupName,omitempty" yaml:"securityGroupName,omitempty"` // The name of the resource group that the security group is deployed in SecurityGroupResourceGroup string `json:"securityGroupResourceGroup,omitempty" yaml:"securityGroupResourceGroup,omitempty"` // (Optional in 1.6) The name of the route table attached to the subnet that the cluster is deployed in RouteTableName string `json:"routeTableName,omitempty" yaml:"routeTableName,omitempty"` // The name of the resource group that the RouteTable is deployed in RouteTableResourceGroup string `json:"routeTableResourceGroup,omitempty" yaml:"routeTableResourceGroup,omitempty"` // (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,omitempty" yaml:"primaryAvailabilitySetName,omitempty"` // The type of azure nodes. Candidate values are: vmss, standard and vmssflex. // If not set, it will be default to vmss. VMType string `json:"vmType,omitempty" yaml:"vmType,omitempty"` // The name of the scale set that should be used as the load balancer backend. // If this is set, the Azure cloudprovider will only add nodes from that scale set to the load // balancer backend pool. If this is not set, and multiple agent pools (scale sets) are used, then // the cloudprovider will try to add all nodes to a single backend pool which is forbidden in the basic sku. // In other words, if you use multiple agent pools (scale sets), and loadBalancerSku is set to basic, you MUST set this field. PrimaryScaleSetName string `json:"primaryScaleSetName,omitempty" yaml:"primaryScaleSetName,omitempty"` // Tags determines what tags shall be applied to the shared resources managed by controller manager, which // includes load balancer, security group and route table. The supported format is `a=b,c=d,...`. After updated // this config, the old tags would be replaced by the new ones. // Because special characters are not supported in "tags" configuration, "tags" support would be removed in a future release, // please consider migrating the config to "tagsMap". Tags string `json:"tags,omitempty" yaml:"tags,omitempty"` // TagsMap is similar to Tags but holds tags with special characters such as `=` and `,`. TagsMap map[string]string `json:"tagsMap,omitempty" yaml:"tagsMap,omitempty"` // SystemTags determines the tag keys managed by cloud provider. If it is not set, no tags would be deleted if // the `Tags` is changed. However, the old tags would be deleted if they are neither included in `Tags` nor // in `SystemTags` after the update of `Tags`. SystemTags string `json:"systemTags,omitempty" yaml:"systemTags,omitempty"` // Sku of Load Balancer and Public IP. Candidate values are: basic and standard. // If not set, it will be default to basic. LoadBalancerSku string `json:"loadBalancerSku,omitempty" yaml:"loadBalancerSku,omitempty"` // LoadBalancerName determines the specific name of the load balancer user want to use, working with // LoadBalancerResourceGroup LoadBalancerName string `json:"loadBalancerName,omitempty" yaml:"loadBalancerName,omitempty"` // LoadBalancerResourceGroup determines the specific resource group of the load balancer user want to use, working // with LoadBalancerName LoadBalancerResourceGroup string `json:"loadBalancerResourceGroup,omitempty" yaml:"loadBalancerResourceGroup,omitempty"` // PreConfiguredBackendPoolLoadBalancerTypes determines whether the LoadBalancer BackendPool has been preconfigured. // Candidate values are: // "": exactly with today (not pre-configured for any LBs) // "internal": for internal LoadBalancer // "external": for external LoadBalancer // "all": for both internal and external LoadBalancer PreConfiguredBackendPoolLoadBalancerTypes string `json:"preConfiguredBackendPoolLoadBalancerTypes,omitempty" yaml:"preConfiguredBackendPoolLoadBalancerTypes,omitempty"` // DisableAvailabilitySetNodes disables VMAS nodes support when "VMType" is set to "vmss". DisableAvailabilitySetNodes bool `json:"disableAvailabilitySetNodes,omitempty" yaml:"disableAvailabilitySetNodes,omitempty"` // EnableVmssFlexNodes enables vmss flex nodes support when "VMType" is set to "vmss". EnableVmssFlexNodes bool `json:"enableVmssFlexNodes,omitempty" yaml:"enableVmssFlexNodes,omitempty"` // DisableAzureStackCloud disables AzureStackCloud support. It should be used // when setting AzureAuthConfig.Cloud with "AZURESTACKCLOUD" to customize ARM endpoints // while the cluster is not running on AzureStack. DisableAzureStackCloud bool `json:"disableAzureStackCloud,omitempty" yaml:"disableAzureStackCloud,omitempty"` // Enable exponential backoff to manage resource request retries CloudProviderBackoff bool `json:"cloudProviderBackoff,omitempty" yaml:"cloudProviderBackoff,omitempty"` // Use instance metadata service where possible UseInstanceMetadata bool `json:"useInstanceMetadata,omitempty" yaml:"useInstanceMetadata,omitempty"` // Backoff exponent CloudProviderBackoffExponent float64 `json:"cloudProviderBackoffExponent,omitempty" yaml:"cloudProviderBackoffExponent,omitempty"` // Backoff jitter CloudProviderBackoffJitter float64 `json:"cloudProviderBackoffJitter,omitempty" yaml:"cloudProviderBackoffJitter,omitempty"` // ExcludeMasterFromStandardLB excludes master nodes from standard load balancer. // If not set, it will be default to true. ExcludeMasterFromStandardLB *bool `json:"excludeMasterFromStandardLB,omitempty" yaml:"excludeMasterFromStandardLB,omitempty"` // DisableOutboundSNAT disables the outbound SNAT for public load balancer rules. // It should only be set when loadBalancerSku is standard. If not set, it will be default to false. DisableOutboundSNAT *bool `json:"disableOutboundSNAT,omitempty" yaml:"disableOutboundSNAT,omitempty"` // Maximum allowed LoadBalancer Rule Count is the limit enforced by Azure Load balancer MaximumLoadBalancerRuleCount int `json:"maximumLoadBalancerRuleCount,omitempty" yaml:"maximumLoadBalancerRuleCount,omitempty"` // Backoff retry limit CloudProviderBackoffRetries int `json:"cloudProviderBackoffRetries,omitempty" yaml:"cloudProviderBackoffRetries,omitempty"` // Backoff duration CloudProviderBackoffDuration int `json:"cloudProviderBackoffDuration,omitempty" yaml:"cloudProviderBackoffDuration,omitempty"` // NonVmssUniformNodesCacheTTLInSeconds sets the Cache TTL for NonVmssUniformNodesCacheTTLInSeconds // if not set, will use default value NonVmssUniformNodesCacheTTLInSeconds int `json:"nonVmssUniformNodesCacheTTLInSeconds,omitempty" yaml:"nonVmssUniformNodesCacheTTLInSeconds,omitempty"` // VmssCacheTTLInSeconds sets the cache TTL for VMSS VmssCacheTTLInSeconds int `json:"vmssCacheTTLInSeconds,omitempty" yaml:"vmssCacheTTLInSeconds,omitempty"` // VmssVirtualMachinesCacheTTLInSeconds sets the cache TTL for vmssVirtualMachines VmssVirtualMachinesCacheTTLInSeconds int `json:"vmssVirtualMachinesCacheTTLInSeconds,omitempty" yaml:"vmssVirtualMachinesCacheTTLInSeconds,omitempty"` // VmssFlexCacheTTLInSeconds sets the cache TTL for VMSS Flex VmssFlexCacheTTLInSeconds int `json:"vmssFlexCacheTTLInSeconds,omitempty" yaml:"vmssFlexCacheTTLInSeconds,omitempty"` // VmssFlexVMCacheTTLInSeconds sets the cache TTL for vmss flex vms VmssFlexVMCacheTTLInSeconds int `json:"vmssFlexVMCacheTTLInSeconds,omitempty" yaml:"vmssFlexVMCacheTTLInSeconds,omitempty"` // VmCacheTTLInSeconds sets the cache TTL for vm VMCacheTTLInSeconds int `json:"vmCacheTTLInSeconds,omitempty" yaml:"vmCacheTTLInSeconds,omitempty"` // LoadBalancerCacheTTLInSeconds sets the cache TTL for load balancer LoadBalancerCacheTTLInSeconds int `json:"loadBalancerCacheTTLInSeconds,omitempty" yaml:"loadBalancerCacheTTLInSeconds,omitempty"` // NsgCacheTTLInSeconds sets the cache TTL for network security group NsgCacheTTLInSeconds int `json:"nsgCacheTTLInSeconds,omitempty" yaml:"nsgCacheTTLInSeconds,omitempty"` // RouteTableCacheTTLInSeconds sets the cache TTL for route table RouteTableCacheTTLInSeconds int `json:"routeTableCacheTTLInSeconds,omitempty" yaml:"routeTableCacheTTLInSeconds,omitempty"` // PlsCacheTTLInSeconds sets the cache TTL for private link service resource PlsCacheTTLInSeconds int `json:"plsCacheTTLInSeconds,omitempty" yaml:"plsCacheTTLInSeconds,omitempty"` // AvailabilitySetsCacheTTLInSeconds sets the cache TTL for VMAS AvailabilitySetsCacheTTLInSeconds int `json:"availabilitySetsCacheTTLInSeconds,omitempty" yaml:"availabilitySetsCacheTTLInSeconds,omitempty"` // PublicIPCacheTTLInSeconds sets the cache TTL for public ip PublicIPCacheTTLInSeconds int `json:"publicIPCacheTTLInSeconds,omitempty" yaml:"publicIPCacheTTLInSeconds,omitempty"` // RouteUpdateWaitingInSeconds is the delay time for waiting route updates to take effect. This waiting delay is added // because the routes are not taken effect when the async route updating operation returns success. Default is 30 seconds. RouteUpdateWaitingInSeconds int `json:"routeUpdateWaitingInSeconds,omitempty" yaml:"routeUpdateWaitingInSeconds,omitempty"` // The user agent for Azure customer usage attribution UserAgent string `json:"userAgent,omitempty" yaml:"userAgent,omitempty"` // LoadBalancerBackendPoolConfigurationType defines how vms join the load balancer backend pools. Supported values // are `nodeIPConfiguration`, `nodeIP` and `podIP`. // `nodeIPConfiguration`: vm network interfaces will be attached to the inbound backend pool of the load balancer (default); // `nodeIP`: vm private IPs will be attached to the inbound backend pool of the load balancer; // `podIP`: pod IPs will be attached to the inbound backend pool of the load balancer (not supported yet). LoadBalancerBackendPoolConfigurationType string `json:"loadBalancerBackendPoolConfigurationType,omitempty" yaml:"loadBalancerBackendPoolConfigurationType,omitempty"` // PutVMSSVMBatchSize defines how many requests the client send concurrently when putting the VMSS VMs. // If it is smaller than or equal to zero, the request will be sent one by one in sequence (default). PutVMSSVMBatchSize int `json:"putVMSSVMBatchSize" yaml:"putVMSSVMBatchSize"` // PrivateLinkServiceResourceGroup determines the specific resource group of the private link services user want to use PrivateLinkServiceResourceGroup string `json:"privateLinkServiceResourceGroup,omitempty" yaml:"privateLinkServiceResourceGroup,omitempty"` // EnableMigrateToIPBasedBackendPoolAPI uses the migration API to migrate from NIC-based to IP-based backend pool. // The migration API can provide a migration from NIC-based to IP-based backend pool without service downtime. // If the API is not used, the migration will be done by decoupling all nodes on the backend pool and then re-attaching // node IPs, which will introduce service downtime. The downtime increases with the number of nodes in the backend pool. EnableMigrateToIPBasedBackendPoolAPI bool `json:"enableMigrateToIPBasedBackendPoolAPI" yaml:"enableMigrateToIPBasedBackendPoolAPI"` // MultipleStandardLoadBalancerConfigurations stores the properties regarding multiple standard load balancers. // It will be ignored if LoadBalancerBackendPoolConfigurationType is nodeIPConfiguration. // If the length is not 0, it is assumed the multiple standard load balancers mode is on. In this case, // there must be one configuration named "<clustername>" or an error will be reported. MultipleStandardLoadBalancerConfigurations []MultipleStandardLoadBalancerConfiguration `json:"multipleStandardLoadBalancerConfigurations,omitempty" yaml:"multipleStandardLoadBalancerConfigurations,omitempty"` // DisableAPICallCache disables the cache for Azure API calls. It is for ARG support and not all resources will be disabled. DisableAPICallCache bool `json:"disableAPICallCache,omitempty" yaml:"disableAPICallCache,omitempty"` // RouteUpdateIntervalInSeconds is the interval for updating routes. Default is 30 seconds. RouteUpdateIntervalInSeconds int `json:"routeUpdateIntervalInSeconds,omitempty" yaml:"routeUpdateIntervalInSeconds,omitempty"` // LoadBalancerBackendPoolUpdateIntervalInSeconds is the interval for updating load balancer backend pool of local services. Default is 30 seconds. LoadBalancerBackendPoolUpdateIntervalInSeconds int `` /* 127-byte string literal not displayed */ // ClusterServiceLoadBalancerHealthProbeMode determines the health probe mode for cluster service load balancer. // Supported values are `shared` and `servicenodeport`. // `servicenodeport`: the health probe will be created against each port of each service by watching the backend application (default). // `shared`: all cluster services shares one HTTP probe targeting the kube-proxy on the node (<nodeIP>/healthz:10256). ClusterServiceLoadBalancerHealthProbeMode string `json:"clusterServiceLoadBalancerHealthProbeMode,omitempty" yaml:"clusterServiceLoadBalancerHealthProbeMode,omitempty"` ClusterServiceSharedLoadBalancerHealthProbePort int32 `` /* 129-byte string literal not displayed */ ClusterServiceSharedLoadBalancerHealthProbePath string `` /* 129-byte string literal not displayed */ }
Config holds the configuration parsed from the --cloud-config flag All fields are required unless otherwise specified NOTE: Cloud config files should follow the same Kubernetes deprecation policy as flags or CLIs. Config fields should not change behavior in incompatible ways and should be deprecated for at least 2 release prior to removing. See https://kubernetes.io/docs/reference/using-api/deprecation-policy/#deprecating-a-flag-or-cli for more details.
func ParseConfig ¶ added in v1.1.1
ParseConfig returns a parsed configuration for an Azure cloudprovider config file
func (*Config) HasExtendedLocation ¶ added in v0.7.1
HasExtendedLocation returns true if extendedlocation prop are specified.
type ExtendedLocation ¶ added in v0.7.3
type ExtendedLocation struct { // Name - The name of the extended location. Name string `json:"name,omitempty"` // Type - The type of the extended location. Type string `json:"type,omitempty"` }
ExtendedLocation contains additional info about the location of resources.
type FlexScaleSet ¶ added in v1.25.0
type FlexScaleSet struct { *Cloud // contains filtered or unexported fields }
FlexScaleSet implements VMSet interface for Azure Flexible VMSS.
func NewTestFlexScaleSet ¶ added in v1.25.0
func NewTestFlexScaleSet(ctrl *gomock.Controller) (*FlexScaleSet, error)
func (*FlexScaleSet) AttachDisk ¶ added in v1.25.0
func (fs *FlexScaleSet) AttachDisk(ctx context.Context, nodeName types.NodeName, diskMap map[string]*AttachDiskOptions) error
AttachDisk attaches a disk to vm
func (*FlexScaleSet) DeleteCacheForNode ¶ added in v1.25.2
func (fs *FlexScaleSet) DeleteCacheForNode(nodeName string) error
func (*FlexScaleSet) DetachDisk ¶ added in v1.25.0
func (fs *FlexScaleSet) DetachDisk(ctx context.Context, nodeName types.NodeName, diskMap map[string]string, forceDetach bool) error
DetachDisk detaches a disk from VM
func (*FlexScaleSet) EnsureBackendPoolDeleted ¶ added in v1.25.0
func (fs *FlexScaleSet) EnsureBackendPoolDeleted(service *v1.Service, backendPoolIDs []string, vmSetName string, backendAddressPools *[]network.BackendAddressPool, deleteFromVMSet bool) (bool, error)
EnsureBackendPoolDeleted ensures the loadBalancer backendAddressPools deleted from the specified nodes.
func (*FlexScaleSet) EnsureBackendPoolDeletedFromVMSets ¶ added in v1.25.0
func (fs *FlexScaleSet) EnsureBackendPoolDeletedFromVMSets(vmssNamesMap map[string]bool, backendPoolIDs []string) error
EnsureBackendPoolDeletedFromVMSets ensures the loadBalancer backendAddressPools deleted from the specified VMSS Flex
func (*FlexScaleSet) EnsureHostInPool ¶ added in v1.25.0
func (fs *FlexScaleSet) EnsureHostInPool(service *v1.Service, nodeName types.NodeName, backendPoolID string, vmSetNameOfLB string) (string, string, string, *compute.VirtualMachineScaleSetVM, error)
EnsureHostInPool ensures the given VM's Primary NIC's Primary IP Configuration is participating in the specified LoadBalancer Backend Pool, which returns (resourceGroup, vmasName, instanceID, vmssVM, error).
func (*FlexScaleSet) EnsureHostsInPool ¶ added in v1.25.0
func (fs *FlexScaleSet) EnsureHostsInPool(service *v1.Service, nodes []*v1.Node, backendPoolID string, vmSetNameOfLB string) error
EnsureHostsInPool ensures the given Node's primary IP configurations are participating in the specified LoadBalancer Backend Pool.
func (*FlexScaleSet) GetAgentPoolVMSetNames ¶ added in v1.25.0
func (fs *FlexScaleSet) GetAgentPoolVMSetNames(nodes []*v1.Node) (*[]string, error)
GetAgentPoolVMSetNames returns all vmSet names according to the nodes
func (*FlexScaleSet) GetDataDisks ¶ added in v1.25.0
func (fs *FlexScaleSet) GetDataDisks(nodeName types.NodeName, crt azcache.AzureCacheReadType) ([]*armcompute.DataDisk, *string, error)
GetDataDisks gets a list of data disks attached to the node.
func (*FlexScaleSet) GetIPByNodeName ¶ added in v1.25.0
func (fs *FlexScaleSet) GetIPByNodeName(name string) (string, string, error)
GetIPByNodeName gets machine private IP and public IP by node name.
func (*FlexScaleSet) GetInstanceIDByNodeName ¶ added in v1.25.0
func (fs *FlexScaleSet) GetInstanceIDByNodeName(name string) (string, error)
GetInstanceIDByNodeName gets the cloud provider ID by node name. It must return ("", cloudprovider.InstanceNotFound) if the instance does not exist or is no longer running.
func (*FlexScaleSet) GetInstanceTypeByNodeName ¶ added in v1.25.0
func (fs *FlexScaleSet) GetInstanceTypeByNodeName(name string) (string, error)
GetInstanceTypeByNodeName gets the instance type by node name.
func (*FlexScaleSet) GetNodeCIDRMasksByProviderID ¶ added in v1.25.0
func (fs *FlexScaleSet) GetNodeCIDRMasksByProviderID(providerID string) (int, int, error)
GetNodeCIDRMaskByProviderID returns the node CIDR subnet mask by provider ID.
func (*FlexScaleSet) GetNodeNameByIPConfigurationID ¶ added in v1.25.0
func (fs *FlexScaleSet) GetNodeNameByIPConfigurationID(ipConfigurationID string) (string, string, error)
GetNodeNameByIPConfigurationID gets the nodeName and vmSetName by IP configuration ID.
func (*FlexScaleSet) GetNodeNameByProviderID ¶ added in v1.25.0
func (fs *FlexScaleSet) GetNodeNameByProviderID(providerID string) (types.NodeName, error)
GetNodeNameByProviderID gets the node name by provider ID. providerID example: azure:///subscriptions/sub/resourceGroups/rg/providers/Microsoft.Compute/virtualMachines/flexprofile-mp-0_df53ee36 Different from vmas where vm name is always equal to nodeName, we need to further map vmName to actual nodeName in vmssflex. Note: nodeName is always equal ptr.Derefs.ToLower(*vm.OsProfile.ComputerName, "")
func (*FlexScaleSet) GetNodeVMSetName ¶ added in v1.25.0
func (fs *FlexScaleSet) GetNodeVMSetName(node *v1.Node) (string, error)
GetNodeVMSetName returns the availability set or vmss name by the node name. It will return empty string when using standalone vms.
func (*FlexScaleSet) GetPowerStatusByNodeName ¶ added in v1.25.0
func (fs *FlexScaleSet) GetPowerStatusByNodeName(name string) (powerState string, err error)
GetPowerStatusByNodeName returns the powerState for the specified node.
func (*FlexScaleSet) GetPrimaryInterface ¶ added in v1.25.0
func (fs *FlexScaleSet) GetPrimaryInterface(nodeName string) (network.Interface, error)
GetPrimaryInterface gets machine primary network interface by node name.
func (*FlexScaleSet) GetPrimaryVMSetName ¶ added in v1.25.0
func (fs *FlexScaleSet) GetPrimaryVMSetName() string
GetPrimaryVMSetName returns the VM set name depending on the configured vmType. It returns config.PrimaryScaleSetName for vmss and config.PrimaryAvailabilitySetName for standard vmType.
func (*FlexScaleSet) GetPrivateIPsByNodeName ¶ added in v1.25.0
func (fs *FlexScaleSet) GetPrivateIPsByNodeName(name string) ([]string, error)
GetPrivateIPsByNodeName returns a slice of all private ips assigned to node (ipv6 and ipv4) TODO (khenidak): This should read all nics, not just the primary allowing users to split ipv4/v6 on multiple nics
func (*FlexScaleSet) GetProvisioningStateByNodeName ¶ added in v1.25.0
func (fs *FlexScaleSet) GetProvisioningStateByNodeName(name string) (provisioningState string, err error)
GetProvisioningStateByNodeName returns the provisioningState for the specified node.
func (*FlexScaleSet) GetVMSetNames ¶ added in v1.25.0
GetVMSetNames selects all possible availability sets or scale sets (depending vmType configured) for service load balancer, if the service has no loadbalancer mode annotation returns the primary VMSet. If service annotation for loadbalancer exists then returns the eligible VMSet. The mode selection annotation would be ignored when using one SLB per cluster.
func (*FlexScaleSet) GetZoneByNodeName ¶ added in v1.25.0
func (fs *FlexScaleSet) GetZoneByNodeName(name string) (cloudprovider.Zone, error)
GetZoneByNodeName gets availability zone for the specified node. If the node is not running with availability zone, then it returns fault domain. for details, refer to https://kubernetes-sigs.github.io/cloud-provider-azure/topics/availability-zones/#node-labels
func (*FlexScaleSet) UpdateVMAsync ¶ added in v1.27.0
func (fs *FlexScaleSet) UpdateVMAsync(ctx context.Context, nodeName types.NodeName) (*azure.Future, error)
UpdateVMAsync updates a vm asynchronously
type IPAddress ¶
type IPAddress struct { PrivateIP string `json:"privateIpAddress"` PublicIP string `json:"publicIpAddress"` }
IPAddress represents IP address information.
type InstanceMetadata ¶
type InstanceMetadata struct { Compute *ComputeMetadata `json:"compute,omitempty"` Network *NetworkMetadata `json:"network,omitempty"` }
InstanceMetadata represents instance information.
type InstanceMetadataService ¶
type InstanceMetadataService struct {
// contains filtered or unexported fields
}
InstanceMetadataService knows how to query the Azure instance metadata server.
func NewInstanceMetadataService ¶
func NewInstanceMetadataService(imdsServer string) (*InstanceMetadataService, error)
NewInstanceMetadataService creates an instance of the InstanceMetadataService accessor object.
func (*InstanceMetadataService) GetMetadata ¶
func (ims *InstanceMetadataService) GetMetadata(crt azcache.AzureCacheReadType) (*InstanceMetadata, error)
GetMetadata gets instance metadata from cache. crt determines if we can get data from stalled cache/need fresh if cache expired.
type LoadBalancerMetadata ¶ added in v0.7.3
type LoadBalancerMetadata struct {
LoadBalancer *LoadbalancerProfile `json:"loadbalancer,omitempty"`
}
LoadBalancerMetadata represents load balancer metadata.
type LoadbalancerProfile ¶ added in v0.7.3
type LoadbalancerProfile struct {
PublicIPAddresses []PublicIPMetadata `json:"publicIpAddresses,omitempty"`
}
LoadbalancerProfile represents load balancer profile in IMDS.
type LockMap ¶ added in v1.29.0
LockMap used to lock on entries
func (*LockMap) LockEntry ¶ added in v1.29.0
LockEntry acquires a lock associated with the specific entry
func (*LockMap) UnlockEntry ¶ added in v1.29.0
UnlockEntry release the lock associated with the specific entry
type MockBackendPool ¶ added in v1.23.0
type MockBackendPool struct {
// contains filtered or unexported fields
}
MockBackendPool is a mock of BackendPool interface.
func NewMockBackendPool ¶ added in v1.23.0
func NewMockBackendPool(ctrl *gomock.Controller) *MockBackendPool
NewMockBackendPool creates a new mock instance.
func (*MockBackendPool) CleanupVMSetFromBackendPoolByCondition ¶ added in v1.23.0
func (m *MockBackendPool) CleanupVMSetFromBackendPoolByCondition(slb *network.LoadBalancer, service *v1.Service, nodes []*v1.Node, clusterName string, shouldRemoveVMSetFromSLB func(string) bool) (*network.LoadBalancer, error)
CleanupVMSetFromBackendPoolByCondition mocks base method.
func (*MockBackendPool) EXPECT ¶ added in v1.23.0
func (m *MockBackendPool) EXPECT() *MockBackendPoolMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockBackendPool) EnsureHostsInPool ¶ added in v1.23.0
func (m *MockBackendPool) EnsureHostsInPool(service *v1.Service, nodes []*v1.Node, backendPoolID, vmSetName, clusterName, lbName string, backendPool network.BackendAddressPool) error
EnsureHostsInPool mocks base method.
func (*MockBackendPool) GetBackendPrivateIPs ¶ added in v1.23.15
func (m *MockBackendPool) GetBackendPrivateIPs(clusterName string, service *v1.Service, lb *network.LoadBalancer) ([]string, []string)
GetBackendPrivateIPs mocks base method.
func (*MockBackendPool) ReconcileBackendPools ¶ added in v1.23.0
func (m *MockBackendPool) ReconcileBackendPools(clusterName string, service *v1.Service, lb *network.LoadBalancer) (bool, bool, *network.LoadBalancer, error)
ReconcileBackendPools mocks base method.
type MockBackendPoolMockRecorder ¶ added in v1.23.0
type MockBackendPoolMockRecorder struct {
// contains filtered or unexported fields
}
MockBackendPoolMockRecorder is the mock recorder for MockBackendPool.
func (*MockBackendPoolMockRecorder) CleanupVMSetFromBackendPoolByCondition ¶ added in v1.23.0
func (mr *MockBackendPoolMockRecorder) CleanupVMSetFromBackendPoolByCondition(slb, service, nodes, clusterName, shouldRemoveVMSetFromSLB interface{}) *gomock.Call
CleanupVMSetFromBackendPoolByCondition indicates an expected call of CleanupVMSetFromBackendPoolByCondition.
func (*MockBackendPoolMockRecorder) EnsureHostsInPool ¶ added in v1.23.0
func (mr *MockBackendPoolMockRecorder) EnsureHostsInPool(service, nodes, backendPoolID, vmSetName, clusterName, lbName, backendPool interface{}) *gomock.Call
EnsureHostsInPool indicates an expected call of EnsureHostsInPool.
func (*MockBackendPoolMockRecorder) GetBackendPrivateIPs ¶ added in v1.23.15
func (mr *MockBackendPoolMockRecorder) GetBackendPrivateIPs(clusterName, service, lb interface{}) *gomock.Call
GetBackendPrivateIPs indicates an expected call of GetBackendPrivateIPs.
func (*MockBackendPoolMockRecorder) ReconcileBackendPools ¶ added in v1.23.0
func (mr *MockBackendPoolMockRecorder) ReconcileBackendPools(clusterName, service, lb interface{}) *gomock.Call
ReconcileBackendPools indicates an expected call of ReconcileBackendPools.
type MockVMSet ¶
type MockVMSet struct {
// contains filtered or unexported fields
}
MockVMSet is a mock of VMSet interface.
func NewMockVMSet ¶
func NewMockVMSet(ctrl *gomock.Controller) *MockVMSet
NewMockVMSet creates a new mock instance.
func (*MockVMSet) AttachDisk ¶
func (m *MockVMSet) AttachDisk(ctx context.Context, nodeName types.NodeName, diskMap map[string]*AttachDiskOptions) error
AttachDisk mocks base method.
func (*MockVMSet) DeleteCacheForNode ¶ added in v1.23.21
DeleteCacheForNode mocks base method.
func (*MockVMSet) DetachDisk ¶
func (m *MockVMSet) DetachDisk(ctx context.Context, nodeName types.NodeName, diskMap map[string]string, forceDetach bool) error
DetachDisk mocks base method.
func (*MockVMSet) EXPECT ¶
func (m *MockVMSet) EXPECT() *MockVMSetMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockVMSet) EnsureBackendPoolDeleted ¶
func (m *MockVMSet) EnsureBackendPoolDeleted(service *v1.Service, backendPoolIDs []string, vmSetName string, backendAddressPools *[]network.BackendAddressPool, deleteFromVMSet bool) (bool, error)
EnsureBackendPoolDeleted mocks base method.
func (*MockVMSet) EnsureBackendPoolDeletedFromVMSets ¶ added in v0.7.3
func (m *MockVMSet) EnsureBackendPoolDeletedFromVMSets(vmSetNamesMap map[string]bool, backendPoolIDs []string) error
EnsureBackendPoolDeletedFromVMSets mocks base method.
func (*MockVMSet) EnsureHostInPool ¶
func (m *MockVMSet) EnsureHostInPool(service *v1.Service, nodeName types.NodeName, backendPoolID, vmSetName string) (string, string, string, *compute.VirtualMachineScaleSetVM, error)
EnsureHostInPool mocks base method.
func (*MockVMSet) EnsureHostsInPool ¶
func (m *MockVMSet) EnsureHostsInPool(service *v1.Service, nodes []*v1.Node, backendPoolID, vmSetName string) error
EnsureHostsInPool mocks base method.
func (*MockVMSet) GetAgentPoolVMSetNames ¶ added in v0.7.3
GetAgentPoolVMSetNames mocks base method.
func (*MockVMSet) GetDataDisks ¶
func (m *MockVMSet) GetDataDisks(nodeName types.NodeName, crt cache.AzureCacheReadType) ([]*v5.DataDisk, *string, error)
GetDataDisks mocks base method.
func (*MockVMSet) GetIPByNodeName ¶
GetIPByNodeName mocks base method.
func (*MockVMSet) GetInstanceIDByNodeName ¶
GetInstanceIDByNodeName mocks base method.
func (*MockVMSet) GetInstanceTypeByNodeName ¶
GetInstanceTypeByNodeName mocks base method.
func (*MockVMSet) GetNodeCIDRMasksByProviderID ¶ added in v0.7.3
GetNodeCIDRMasksByProviderID mocks base method.
func (*MockVMSet) GetNodeNameByIPConfigurationID ¶
func (m *MockVMSet) GetNodeNameByIPConfigurationID(ipConfigurationID string) (string, string, error)
GetNodeNameByIPConfigurationID mocks base method.
func (*MockVMSet) GetNodeNameByProviderID ¶
GetNodeNameByProviderID mocks base method.
func (*MockVMSet) GetNodeVMSetName ¶ added in v1.23.0
GetNodeVMSetName mocks base method.
func (*MockVMSet) GetPowerStatusByNodeName ¶
GetPowerStatusByNodeName mocks base method.
func (*MockVMSet) GetPrimaryInterface ¶
GetPrimaryInterface mocks base method.
func (*MockVMSet) GetPrimaryVMSetName ¶
GetPrimaryVMSetName mocks base method.
func (*MockVMSet) GetPrivateIPsByNodeName ¶
GetPrivateIPsByNodeName mocks base method.
func (*MockVMSet) GetProvisioningStateByNodeName ¶ added in v0.7.7
GetProvisioningStateByNodeName mocks base method.
func (*MockVMSet) GetVMSetNames ¶
GetVMSetNames mocks base method.
func (*MockVMSet) GetZoneByNodeName ¶
func (m *MockVMSet) GetZoneByNodeName(name string) (cloud_provider.Zone, error)
GetZoneByNodeName mocks base method.
type MockVMSetMockRecorder ¶
type MockVMSetMockRecorder struct {
// contains filtered or unexported fields
}
MockVMSetMockRecorder is the mock recorder for MockVMSet.
func (*MockVMSetMockRecorder) AttachDisk ¶
func (mr *MockVMSetMockRecorder) AttachDisk(ctx, nodeName, diskMap any) *gomock.Call
AttachDisk indicates an expected call of AttachDisk.
func (*MockVMSetMockRecorder) DeleteCacheForNode ¶ added in v1.23.21
func (mr *MockVMSetMockRecorder) DeleteCacheForNode(nodeName any) *gomock.Call
DeleteCacheForNode indicates an expected call of DeleteCacheForNode.
func (*MockVMSetMockRecorder) DetachDisk ¶
func (mr *MockVMSetMockRecorder) DetachDisk(ctx, nodeName, diskMap any) *gomock.Call
DetachDisk indicates an expected call of DetachDisk.
func (*MockVMSetMockRecorder) EnsureBackendPoolDeleted ¶
func (mr *MockVMSetMockRecorder) EnsureBackendPoolDeleted(service, backendPoolIDs, vmSetName, backendAddressPools, deleteFromVMSet any) *gomock.Call
EnsureBackendPoolDeleted indicates an expected call of EnsureBackendPoolDeleted.
func (*MockVMSetMockRecorder) EnsureBackendPoolDeletedFromVMSets ¶ added in v0.7.3
func (mr *MockVMSetMockRecorder) EnsureBackendPoolDeletedFromVMSets(vmSetNamesMap, backendPoolIDs any) *gomock.Call
EnsureBackendPoolDeletedFromVMSets indicates an expected call of EnsureBackendPoolDeletedFromVMSets.
func (*MockVMSetMockRecorder) EnsureHostInPool ¶
func (mr *MockVMSetMockRecorder) EnsureHostInPool(service, nodeName, backendPoolID, vmSetName any) *gomock.Call
EnsureHostInPool indicates an expected call of EnsureHostInPool.
func (*MockVMSetMockRecorder) EnsureHostsInPool ¶
func (mr *MockVMSetMockRecorder) EnsureHostsInPool(service, nodes, backendPoolID, vmSetName any) *gomock.Call
EnsureHostsInPool indicates an expected call of EnsureHostsInPool.
func (*MockVMSetMockRecorder) GetAgentPoolVMSetNames ¶ added in v0.7.3
func (mr *MockVMSetMockRecorder) GetAgentPoolVMSetNames(nodes any) *gomock.Call
GetAgentPoolVMSetNames indicates an expected call of GetAgentPoolVMSetNames.
func (*MockVMSetMockRecorder) GetDataDisks ¶
func (mr *MockVMSetMockRecorder) GetDataDisks(nodeName, crt any) *gomock.Call
GetDataDisks indicates an expected call of GetDataDisks.
func (*MockVMSetMockRecorder) GetIPByNodeName ¶
func (mr *MockVMSetMockRecorder) GetIPByNodeName(name any) *gomock.Call
GetIPByNodeName indicates an expected call of GetIPByNodeName.
func (*MockVMSetMockRecorder) GetInstanceIDByNodeName ¶
func (mr *MockVMSetMockRecorder) GetInstanceIDByNodeName(name any) *gomock.Call
GetInstanceIDByNodeName indicates an expected call of GetInstanceIDByNodeName.
func (*MockVMSetMockRecorder) GetInstanceTypeByNodeName ¶
func (mr *MockVMSetMockRecorder) GetInstanceTypeByNodeName(name any) *gomock.Call
GetInstanceTypeByNodeName indicates an expected call of GetInstanceTypeByNodeName.
func (*MockVMSetMockRecorder) GetNodeCIDRMasksByProviderID ¶ added in v0.7.3
func (mr *MockVMSetMockRecorder) GetNodeCIDRMasksByProviderID(providerID any) *gomock.Call
GetNodeCIDRMasksByProviderID indicates an expected call of GetNodeCIDRMasksByProviderID.
func (*MockVMSetMockRecorder) GetNodeNameByIPConfigurationID ¶
func (mr *MockVMSetMockRecorder) GetNodeNameByIPConfigurationID(ipConfigurationID any) *gomock.Call
GetNodeNameByIPConfigurationID indicates an expected call of GetNodeNameByIPConfigurationID.
func (*MockVMSetMockRecorder) GetNodeNameByProviderID ¶
func (mr *MockVMSetMockRecorder) GetNodeNameByProviderID(providerID any) *gomock.Call
GetNodeNameByProviderID indicates an expected call of GetNodeNameByProviderID.
func (*MockVMSetMockRecorder) GetNodeVMSetName ¶ added in v1.23.0
func (mr *MockVMSetMockRecorder) GetNodeVMSetName(node any) *gomock.Call
GetNodeVMSetName indicates an expected call of GetNodeVMSetName.
func (*MockVMSetMockRecorder) GetPowerStatusByNodeName ¶
func (mr *MockVMSetMockRecorder) GetPowerStatusByNodeName(name any) *gomock.Call
GetPowerStatusByNodeName indicates an expected call of GetPowerStatusByNodeName.
func (*MockVMSetMockRecorder) GetPrimaryInterface ¶
func (mr *MockVMSetMockRecorder) GetPrimaryInterface(nodeName any) *gomock.Call
GetPrimaryInterface indicates an expected call of GetPrimaryInterface.
func (*MockVMSetMockRecorder) GetPrimaryVMSetName ¶
func (mr *MockVMSetMockRecorder) GetPrimaryVMSetName() *gomock.Call
GetPrimaryVMSetName indicates an expected call of GetPrimaryVMSetName.
func (*MockVMSetMockRecorder) GetPrivateIPsByNodeName ¶
func (mr *MockVMSetMockRecorder) GetPrivateIPsByNodeName(name any) *gomock.Call
GetPrivateIPsByNodeName indicates an expected call of GetPrivateIPsByNodeName.
func (*MockVMSetMockRecorder) GetProvisioningStateByNodeName ¶ added in v0.7.7
func (mr *MockVMSetMockRecorder) GetProvisioningStateByNodeName(name any) *gomock.Call
GetProvisioningStateByNodeName indicates an expected call of GetProvisioningStateByNodeName.
func (*MockVMSetMockRecorder) GetVMSetNames ¶
func (mr *MockVMSetMockRecorder) GetVMSetNames(service, nodes any) *gomock.Call
GetVMSetNames indicates an expected call of GetVMSetNames.
func (*MockVMSetMockRecorder) GetZoneByNodeName ¶
func (mr *MockVMSetMockRecorder) GetZoneByNodeName(name any) *gomock.Call
GetZoneByNodeName indicates an expected call of GetZoneByNodeName.
type MultipleStandardLoadBalancerConfiguration ¶ added in v1.28.0
type MultipleStandardLoadBalancerConfiguration struct { // Name of the public load balancer. There will be an internal load balancer // created if needed, and the name will be `<name>-internal`. The internal lb // shares the same configurations as the external one. The internal lbs // are not needed to be included in `MultipleStandardLoadBalancerConfigurations`. // There must be a name of "<clustername>" in the load balancer configuration list. Name string `json:"name" yaml:"name"` MultipleStandardLoadBalancerConfigurationSpec MultipleStandardLoadBalancerConfigurationStatus }
MultipleStandardLoadBalancerConfiguration stores the properties regarding multiple standard load balancers.
type MultipleStandardLoadBalancerConfigurationSpec ¶ added in v1.28.0
type MultipleStandardLoadBalancerConfigurationSpec struct { // This load balancer can have services placed on it. Defaults to true, // can be set to false to drain and eventually remove a load balancer. // This only affects services that will be using the LB. For services // that is currently using the LB, they will not be affected. AllowServicePlacement *bool `json:"allowServicePlacement" yaml:"allowServicePlacement"` // A string value that must specify the name of an existing vmSet. // All nodes in the given vmSet will always be added to this load balancer. // A vmSet can only be the primary vmSet for a single load balancer. PrimaryVMSet string `json:"primaryVMSet" yaml:"primaryVMSet"` // Services that must match this selector can be placed on this load balancer. If not supplied, // services with any labels can be created on the load balancer. ServiceLabelSelector *metav1.LabelSelector `json:"serviceLabelSelector" yaml:"serviceLabelSelector"` // Services created in namespaces with the supplied label will be allowed to select that load balancer. // If not supplied, services created in any namespaces can be created on that load balancer. ServiceNamespaceSelector *metav1.LabelSelector `json:"serviceNamespaceSelector" yaml:"serviceNamespaceSelector"` // Nodes matching this selector will be preferentially added to the load balancers that // they match selectors for. NodeSelector does not override primaryAgentPool for node allocation. NodeSelector *metav1.LabelSelector `json:"nodeSelector" yaml:"nodeSelector"` }
MultipleStandardLoadBalancerConfigurationSpec stores the properties regarding multiple standard load balancers.
type MultipleStandardLoadBalancerConfigurationStatus ¶ added in v1.28.0
type MultipleStandardLoadBalancerConfigurationStatus struct { // ActiveServices stores the services that are supposed to use the load balancer. ActiveServices *utilsets.IgnoreCaseSet `json:"activeServices" yaml:"activeServices"` // ActiveNodes stores the nodes that are supposed to be in the load balancer. // It will be used in EnsureHostsInPool to make sure the given ones are in the backend pool. ActiveNodes *utilsets.IgnoreCaseSet `json:"activeNodes" yaml:"activeNodes"` }
MultipleStandardLoadBalancerConfigurationStatus stores the properties regarding multiple standard load balancers.
type NetworkData ¶
type NetworkData struct { IPAddress []IPAddress `json:"ipAddress"` Subnet []Subnet `json:"subnet"` }
NetworkData contains IP information for a network.
type NetworkInterface ¶
type NetworkInterface struct { IPV4 NetworkData `json:"ipv4"` IPV6 NetworkData `json:"ipv6"` MAC string `json:"macAddress"` }
NetworkInterface represents an instances network interface.
type NetworkMetadata ¶
type NetworkMetadata struct {
Interface []NetworkInterface `json:"interface"`
}
NetworkMetadata contains metadata about an instance's network
type NonVmssUniformNodesEntry ¶ added in v1.26.0
type NonVmssUniformNodesEntry struct { VMSSFlexVMNodeNames *utilsets.IgnoreCaseSet VMSSFlexVMProviderIDs *utilsets.IgnoreCaseSet AvSetVMNodeNames *utilsets.IgnoreCaseSet AvSetVMProviderIDs *utilsets.IgnoreCaseSet ClusterNodeNames *utilsets.IgnoreCaseSet }
type PublicIPMetadata ¶ added in v0.7.3
type PublicIPMetadata struct { FrontendIPAddress string `json:"frontendIpAddress,omitempty"` PrivateIPAddress string `json:"privateIpAddress,omitempty"` }
PublicIPMetadata represents the public IP metadata.
type ScaleSet ¶ added in v0.7.3
type ScaleSet struct { *Cloud // contains filtered or unexported fields }
ScaleSet implements VMSet interface for Azure scale set.
func NewTestScaleSet ¶ added in v0.7.3
func NewTestScaleSet(ctrl *gomock.Controller) (*ScaleSet, error)
NewTestScaleSet creates a fake ScaleSet for unit test
func (*ScaleSet) AttachDisk ¶ added in v0.7.3
func (ss *ScaleSet) AttachDisk(ctx context.Context, nodeName types.NodeName, diskMap map[string]*AttachDiskOptions) error
AttachDisk attaches a disk to vm
func (*ScaleSet) DeleteCacheForNode ¶ added in v1.1.24
DeleteCacheForNode deletes Node from VMSS VM and VM caches.
func (*ScaleSet) DetachDisk ¶ added in v0.7.3
func (ss *ScaleSet) DetachDisk(ctx context.Context, nodeName types.NodeName, diskMap map[string]string, forceDetach bool) error
DetachDisk detaches a disk from VM
func (*ScaleSet) EnsureBackendPoolDeleted ¶ added in v0.7.3
func (ss *ScaleSet) EnsureBackendPoolDeleted(service *v1.Service, backendPoolIDs []string, vmSetName string, backendAddressPools *[]network.BackendAddressPool, deleteFromVMSet bool) (bool, error)
EnsureBackendPoolDeleted ensures the loadBalancer backendAddressPools deleted from the specified nodes.
func (*ScaleSet) EnsureBackendPoolDeletedFromVMSets ¶ added in v0.7.3
func (ss *ScaleSet) EnsureBackendPoolDeletedFromVMSets(vmssNamesMap map[string]bool, backendPoolIDs []string) error
EnsureBackendPoolDeletedFromVMSets ensures the loadBalancer backendAddressPools deleted from the specified VMSS
func (*ScaleSet) EnsureHostInPool ¶ added in v0.7.3
func (ss *ScaleSet) EnsureHostInPool(_ *v1.Service, nodeName types.NodeName, backendPoolID string, vmSetNameOfLB string) (string, string, string, *compute.VirtualMachineScaleSetVM, error)
EnsureHostInPool ensures the given VM's Primary NIC's Primary IP Configuration is participating in the specified LoadBalancer Backend Pool, which returns (resourceGroup, vmasName, instanceID, vmssVM, error).
func (*ScaleSet) EnsureHostsInPool ¶ added in v0.7.3
func (ss *ScaleSet) EnsureHostsInPool(service *v1.Service, nodes []*v1.Node, backendPoolID string, vmSetNameOfLB string) error
EnsureHostsInPool ensures the given Node's primary IP configurations are participating in the specified LoadBalancer Backend Pool.
func (*ScaleSet) GetAgentPoolVMSetNames ¶ added in v0.7.3
GetAgentPoolVMSetNames returns all VMSS/VMAS names according to the nodes. We need to include the VMAS here because some of the cluster provisioning tools like capz allows mixed instance type.
func (*ScaleSet) GetDataDisks ¶ added in v0.7.3
func (ss *ScaleSet) GetDataDisks(nodeName types.NodeName, crt azcache.AzureCacheReadType) ([]*armcompute.DataDisk, *string, error)
GetDataDisks gets a list of data disks attached to the node.
func (*ScaleSet) GetIPByNodeName ¶ added in v0.7.3
GetIPByNodeName gets machine private IP and public IP by node name.
func (*ScaleSet) GetInstanceIDByNodeName ¶ added in v0.7.3
GetInstanceIDByNodeName gets the cloud provider ID by node name. It must return ("", cloudprovider.InstanceNotFound) if the instance does not exist or is no longer running.
func (*ScaleSet) GetInstanceTypeByNodeName ¶ added in v0.7.3
GetInstanceTypeByNodeName gets the instance type by node name.
func (*ScaleSet) GetNodeCIDRMasksByProviderID ¶ added in v0.7.3
GetNodeCIDRMaskByProviderID returns the node CIDR subnet mask by provider ID.
func (*ScaleSet) GetNodeNameByIPConfigurationID ¶ added in v0.7.3
func (ss *ScaleSet) GetNodeNameByIPConfigurationID(ipConfigurationID string) (string, string, error)
GetNodeNameByIPConfigurationID gets the node name and the VMSS name by IP configuration ID.
func (*ScaleSet) GetNodeNameByProviderID ¶ added in v0.7.3
GetNodeNameByProviderID gets the node name by provider ID. providerID example: 1. vmas providerID: azure:///subscriptions/subsid/resourceGroups/rg/providers/Microsoft.Compute/virtualMachines/aks-nodepool1-27053986-0 2. vmss providerID: azure:///subscriptions/subsid/resourceGroups/rg/providers/Microsoft.Compute/virtualMachineScaleSets/aks-agentpool-22126781-vmss/virtualMachines/1 /subscriptions/subsid/resourceGroups/rg/providers/Microsoft.Compute/virtualMachineScaleSets/aks-agentpool-22126781-vmss/virtualMachines/k8s-agentpool-36841236-vmss_1
func (*ScaleSet) GetNodeVMSetName ¶ added in v1.23.0
func (*ScaleSet) GetPowerStatusByNodeName ¶ added in v0.7.3
GetPowerStatusByNodeName returns the power state of the specified node.
func (*ScaleSet) GetPrimaryInterface ¶ added in v0.7.3
GetPrimaryInterface gets machine primary network interface by node name and vmSet.
func (*ScaleSet) GetPrimaryVMSetName ¶ added in v0.7.3
GetPrimaryVMSetName returns the VM set name depending on the configured vmType. It returns config.PrimaryScaleSetName for vmss and config.PrimaryAvailabilitySetName for standard vmType.
func (*ScaleSet) GetPrivateIPsByNodeName ¶ added in v0.7.3
returns a list of private ips assigned to node TODO (khenidak): This should read all nics, not just the primary allowing users to split ipv4/v6 on multiple nics
func (*ScaleSet) GetProvisioningStateByNodeName ¶ added in v0.7.7
func (ss *ScaleSet) GetProvisioningStateByNodeName(name string) (provisioningState string, err error)
GetProvisioningStateByNodeName returns the provisioningState for the specified node.
func (*ScaleSet) GetVMSetNames ¶ added in v0.7.3
GetVMSetNames selects all possible scale sets for service load balancer. If the service has no loadbalancer mode annotation returns the primary VMSet. If service annotation for loadbalancer exists then return the eligible VMSet.
func (*ScaleSet) GetZoneByNodeName ¶ added in v0.7.3
func (ss *ScaleSet) GetZoneByNodeName(name string) (cloudprovider.Zone, error)
GetZoneByNodeName gets availability zone for the specified node. If the node is not running with availability zone, then it returns fault domain.
func (*ScaleSet) UpdateVMAsync ¶ added in v1.27.0
func (ss *ScaleSet) UpdateVMAsync(ctx context.Context, nodeName types.NodeName) (*azure.Future, error)
UpdateVMAsync updates a vm asynchronously
func (*ScaleSet) VMSSBatchSize ¶ added in v1.1.22
VMSSBatchSize returns the batch size for VMSS operations.
type StorageType ¶ added in v1.27.0
type StorageType string
const ( StorageTypeBlob StorageType = "blob" StorageTypeFile StorageType = "file" )
type VMManagementType ¶ added in v1.25.16
type VMManagementType string
const ( ManagedByVmssUniform VMManagementType = "ManagedByVmssUniform" ManagedByVmssFlex VMManagementType = "ManagedByVmssFlex" ManagedByAvSet VMManagementType = "ManagedByAvSet" ManagedByUnknownVMSet VMManagementType = "ManagedByUnknownVMSet" )
type VMSSEntry ¶ added in v1.1.27
type VMSSEntry struct { VMSS *compute.VirtualMachineScaleSet ResourceGroup string LastUpdate time.Time }
type VMSSVirtualMachineEntry ¶ added in v1.23.26
type VMSet ¶
type VMSet interface { // GetInstanceIDByNodeName gets the cloud provider ID by node name. // It must return ("", cloudprovider.InstanceNotFound) if the instance does // not exist or is no longer running. GetInstanceIDByNodeName(name string) (string, error) // GetInstanceTypeByNodeName gets the instance type by node name. GetInstanceTypeByNodeName(name string) (string, error) // GetIPByNodeName gets machine private IP and public IP by node name. GetIPByNodeName(name string) (string, string, error) // GetPrimaryInterface gets machine primary network interface by node name. GetPrimaryInterface(nodeName string) (network.Interface, error) // GetNodeNameByProviderID gets the node name by provider ID. GetNodeNameByProviderID(providerID string) (types.NodeName, error) // GetZoneByNodeName gets cloudprovider.Zone by node name. GetZoneByNodeName(name string) (cloudprovider.Zone, error) // GetPrimaryVMSetName returns the VM set name depending on the configured vmType. // It returns config.PrimaryScaleSetName for vmss and config.PrimaryAvailabilitySetName for standard vmType. GetPrimaryVMSetName() string // GetVMSetNames selects all possible availability sets or scale sets // (depending vmType configured) for service load balancer, if the service has // no loadbalancer mode annotation returns the primary VMSet. If service annotation // for loadbalancer exists then return the eligible VMSet. GetVMSetNames(service *v1.Service, nodes []*v1.Node) (availabilitySetNames *[]string, err error) // GetNodeVMSetName returns the availability set or vmss name by the node name. // It will return empty string when using standalone vms. GetNodeVMSetName(node *v1.Node) (string, error) // EnsureHostsInPool ensures the given Node's primary IP configurations are // participating in the specified LoadBalancer Backend Pool. EnsureHostsInPool(service *v1.Service, nodes []*v1.Node, backendPoolID string, vmSetName string) error // EnsureHostInPool ensures the given VM's Primary NIC's Primary IP Configuration is // participating in the specified LoadBalancer Backend Pool. EnsureHostInPool(service *v1.Service, nodeName types.NodeName, backendPoolID string, vmSetName string) (string, string, string, *compute.VirtualMachineScaleSetVM, error) // EnsureBackendPoolDeleted ensures the loadBalancer backendAddressPools deleted from the specified nodes. EnsureBackendPoolDeleted(service *v1.Service, backendPoolIDs []string, vmSetName string, backendAddressPools *[]network.BackendAddressPool, deleteFromVMSet bool) (bool, error) //EnsureBackendPoolDeletedFromVMSets ensures the loadBalancer backendAddressPools deleted from the specified VMSS/VMAS EnsureBackendPoolDeletedFromVMSets(vmSetNamesMap map[string]bool, backendPoolIDs []string) error // AttachDisk attaches a disk to vm AttachDisk(ctx context.Context, nodeName types.NodeName, diskMap map[string]*AttachDiskOptions) error // DetachDisk detaches a disk from vm DetachDisk(ctx context.Context, nodeName types.NodeName, diskMap map[string]string, forceDetach bool) error // GetDataDisks gets a list of data disks attached to the node. GetDataDisks(nodeName types.NodeName, crt azcache.AzureCacheReadType) ([]*armcompute.DataDisk, *string, error) // UpdateVM updates a vm UpdateVM(ctx context.Context, nodeName types.NodeName) error // GetPowerStatusByNodeName returns the powerState for the specified node. GetPowerStatusByNodeName(name string) (string, error) // GetProvisioningStateByNodeName returns the provisioningState for the specified node. GetProvisioningStateByNodeName(name string) (string, error) // GetPrivateIPsByNodeName returns a slice of all private ips assigned to node (ipv6 and ipv4) GetPrivateIPsByNodeName(name string) ([]string, error) // GetNodeNameByIPConfigurationID gets the nodeName and vmSetName by IP configuration ID. GetNodeNameByIPConfigurationID(ipConfigurationID string) (string, string, error) // GetNodeCIDRMasksByProviderID returns the node CIDR subnet mask by provider ID. GetNodeCIDRMasksByProviderID(providerID string) (int, int, error) // GetAgentPoolVMSetNames returns all vmSet names according to the nodes GetAgentPoolVMSetNames(nodes []*v1.Node) (*[]string, error) // DeleteCacheForNode removes the node entry from cache. DeleteCacheForNode(nodeName string) error }
VMSet defines functions all vmsets (including scale set and availability set) should be implemented. Don't forget to run the following command to generate the mock client: mockgen -destination=$GOPATH/src/sigs.k8s.io/cloud-provider-azure/pkg/provider/azure_mock_vmsets.go -source=$GOPATH/src/sigs.k8s.io/cloud-provider-azure/pkg/provider/azure_vmsets.go -package=provider VMSet
Source Files ¶
- azure.go
- azure_backoff.go
- azure_controller_common.go
- azure_controller_standard.go
- azure_controller_vmss.go
- azure_controller_vmssflex.go
- azure_fakes.go
- azure_file.go
- azure_instance_metadata.go
- azure_instances_v1.go
- azure_instances_v2.go
- azure_interface_repo.go
- azure_loadbalancer.go
- azure_loadbalancer_accesscontrol.go
- azure_loadbalancer_backendpool.go
- azure_loadbalancer_healthprobe.go
- azure_loadbalancer_repo.go
- azure_local_services.go
- azure_mock_loadbalancer_backendpool.go
- azure_mock_vmsets.go
- azure_privatelinkservice.go
- azure_privatelinkservice_repo.go
- azure_publicip_repo.go
- azure_routes.go
- azure_routetable_repo.go
- azure_securitygroup_repo.go
- azure_standard.go
- azure_storage.go
- azure_storageaccount.go
- azure_subnet_repo.go
- azure_utils.go
- azure_vmsets.go
- azure_vmsets_repo.go
- azure_vmss.go
- azure_vmss_cache.go
- azure_vmss_repo.go
- azure_vmssflex.go
- azure_vmssflex_cache.go
- azure_wrap.go
- azure_zones.go
- doc.go
Directories ¶
Path | Synopsis |
---|---|
Package auth provides a general library to authorize Azure ARM clients.
|
Package auth provides a general library to authorize Azure ARM clients. |