provider

Sep 16, 2024

Changes in this version

type Cloud

+ AuthProvider *azclient.AuthProvider

Jan 17, 2024

Changes in this version

+ const DefaultTokenAudience

+ func FilterNonExistingDisks(ctx context.Context, diskClient diskclient.Interface, ...) []compute.DataDisk

+ func ToArmcomputeDisk(disks []compute.DataDisk) ([]*armcompute.DataDisk, error)

type AttachDiskOptions

+ CachingMode compute.CachingTypes

+ DiskEncryptionSetID string

+ DiskName string

+ Lun int32

+ WriteAcceleratorEnabled bool

type Cloud

+ ComputeClientFactory azclient.ClientFactory

+ NetworkClientFactory azclient.ClientFactory

+ func (az *Cloud) GetNodeVMSet(nodeName types.NodeName, crt azcache.AzureCacheReadType) (VMSet, error)

+ func (az *Cloud) GetStorageAccesskeyFromServiceAccountToken(ctx context.Context, ...) (string, error)

+ type LockMap struct

+ func (lm *LockMap) LockEntry(entry string)

+ func (lm *LockMap) UnlockEntry(entry string)

Jan 17, 2024

Changes in this version

type Config

+ ClusterServiceLoadBalancerHealthProbeMode string

+ ClusterServiceSharedLoadBalancerHealthProbePath string

+ ClusterServiceSharedLoadBalancerHealthProbePort int32

Aug 22, 2023

Changes in this version

+ const IPVersionIPv4

+ const IPVersionIPv6

+ func IntInSlice(i int, list []int) bool

+ func StringInSlice(s string, list []string) bool

type AccountOptions

+ GetLatestAccountKey bool

+ PickRandomMatchingAccount bool

type Config

+ DisableAPICallCache bool

+ LoadBalancerBackendPoolUpdateIntervalInSeconds int

+ MultipleStandardLoadBalancerConfigurations []MultipleStandardLoadBalancerConfiguration

+ RouteUpdateIntervalInSeconds int

type ManagedDiskOptions

+ PublicNetworkAccess compute.PublicNetworkAccess

+ type MultipleStandardLoadBalancerConfiguration struct

+ Name string

+ type MultipleStandardLoadBalancerConfigurationSpec struct

+ AllowServicePlacement *bool

+ NodeSelector *metav1.LabelSelector

+ PrimaryVMSet string

+ ServiceLabelSelector *metav1.LabelSelector

+ ServiceNamespaceSelector *metav1.LabelSelector

+ type MultipleStandardLoadBalancerConfigurationStatus struct

+ ActiveNodes sets.Set[string]

+ ActiveServices sets.Set[string]

Apr 21, 2023

Changes in this version

type AccountOptions

+ EnableBlobVersioning *bool

+ SoftDeleteBlobs int32

+ SoftDeleteContainers int32

+ StorageEndpointSuffix string

+ StorageType StorageType

type FlexScaleSet

+ func (fs *FlexScaleSet) UpdateVMAsync(ctx context.Context, nodeName types.NodeName) (*azure.Future, error)

type MockVMSet

+ func (m *MockVMSet) UpdateVMAsync(ctx context.Context, nodeName types.NodeName) (*azure.Future, error)

type MockVMSetMockRecorder

+ func (mr *MockVMSetMockRecorder) UpdateVMAsync(ctx, nodeName interface{}) *gomock.Call

type ScaleSet

+ func (ss *ScaleSet) UpdateVMAsync(ctx context.Context, nodeName types.NodeName) (*azure.Future, error)

+ type StorageType string

+ const StorageTypeBlob

+ const StorageTypeFile

type VMSet

+ UpdateVMAsync func(ctx context.Context, nodeName types.NodeName) (*azure.Future, error)

Dec 13, 2022

Changes in this version

type AccountOptions

+ AccessTier string

+ IsMultichannelEnabled *bool

type ComputeMetadata

+ ResourceID string

type Config

+ EnableVmssFlexNodes bool

+ NonVmssUniformNodesCacheTTLInSeconds int

+ type NonVmssUniformNodesEntry struct

+ AvSetVMNodeNames sets.String

+ AvSetVMProviderIDs sets.String

+ ClusterNodeNames sets.String

+ VMSSFlexVMNodeNames sets.String

+ VMSSFlexVMProviderIDs sets.String

type VMManagementType

+ const ManagedByVmssFlex

Nov 1, 2023

Changes in this version

type Cloud

+ func (az *Cloud) GetVMNameByIPConfigurationName(nicResourceGroup, nicName string) (string, error)

Aug 2, 2023

Changes in this version

type ManagedDiskOptions

+ Location string

+ PerformancePlus *bool

Jul 21, 2023

Changes in this version

+ type VMManagementType string

+ const ManagedByAvSet

+ const ManagedByUnknownVMSet

+ const ManagedByVmssUniform

Sep 30, 2022

Changes in this version

type FlexScaleSet

+ func (fs *FlexScaleSet) DeleteCacheForNode(nodeName string) error

Sep 5, 2022

Changes in this version

+ var ErrorVmssIDIsEmpty = errors.New("VMSS ID is empty")

+ func ConvertResourceGroupNameToLower(resourceID string) (string, error)

type AccountOptions

+ AllowSharedKeyAccess *bool

+ KeyName *string

+ KeyVaultURI *string

+ KeyVersion *string

+ RequireInfrastructureEncryption *bool

type Cloud

+ BlobClient blobclient.Interface

type CloudProviderRateLimitConfig

+ ContainerServiceRateLimit *azclients.RateLimitConfig

+ DeploymentRateLimit *azclients.RateLimitConfig

+ PrivateDNSRateLimit *azclients.RateLimitConfig

+ PrivateDNSZoneGroupRateLimit *azclients.RateLimitConfig

+ PrivateEndpointRateLimit *azclients.RateLimitConfig

+ PrivateLinkServiceRateLimit *azclients.RateLimitConfig

+ VirtualNetworkRateLimit *azclients.RateLimitConfig

type Config

+ VmssFlexCacheTTLInSeconds int

+ VmssFlexVMCacheTTLInSeconds int

+ type FlexScaleSet struct

+ func NewTestFlexScaleSet(ctrl *gomock.Controller) (*FlexScaleSet, error)

+ func (c FlexScaleSet) DisksAreAttached(diskNames []string, nodeName types.NodeName) (map[string]bool, error)

+ func (c FlexScaleSet) GetDiskLun(diskName, diskURI string, nodeName types.NodeName) (int32, *string, error)

+ func (c FlexScaleSet) SetDiskLun(nodeName types.NodeName, diskURI string, diskMap map[string]*AttachDiskOptions) (int32, error)

+ func (fs *FlexScaleSet) AttachDisk(ctx context.Context, nodeName types.NodeName, ...) (*azure.Future, error)

+ func (fs *FlexScaleSet) DetachDisk(ctx context.Context, nodeName types.NodeName, diskMap map[string]string) error

+ func (fs *FlexScaleSet) EnsureBackendPoolDeleted(service *v1.Service, backendPoolID, vmSetName string, ...) error

+ func (fs *FlexScaleSet) EnsureBackendPoolDeletedFromVMSets(vmssNamesMap map[string]bool, backendPoolID 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) ([]compute.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) WaitForUpdateResult(ctx context.Context, future *azure.Future, resourceGroupName, source string) error

Jun 7, 2023

Changes in this version

type Cloud

+ func (az *Cloud) MigrateToIPBasedBackendPoolAndWaitForCompletion(lbName string, backendPoolNames []string, nicsCountMap map[string]int) error

type Config

+ EnableMigrateToIPBasedBackendPoolAPI bool

May 6, 2022

Changes in this version

type AccountOptions

+ MatchTags bool

+ SubnetName string

+ SubscriptionID string

+ VNetName string

+ VNetResourceGroup string

type ManagedDiskOptions

+ DiskEncryptionType string

+ SubscriptionID string

Jan 15, 2023

Changes in this version

+ type VMSSVirtualMachineEntry struct

+ InstanceID string

+ LastUpdate time.Time

+ ResourceGroup string

+ VMSSName string

+ VirtualMachine *compute.VirtualMachineScaleSetVM

Dec 27, 2022

Changes in this version

+ var ErrScaleSetNotFound = errors.New("scale set not found")

Sep 30, 2022

Changes in this version

type MockVMSet

+ func (m *MockVMSet) DeleteCacheForNode(nodeName string) error

type MockVMSetMockRecorder

+ func (mr *MockVMSetMockRecorder) DeleteCacheForNode(nodeName interface{}) *gomock.Call

Jul 12, 2022

Changes in this version

type BackendPool

+ GetBackendPrivateIPs func(clusterName string, service *v1.Service, lb *network.LoadBalancer) []string

type MockBackendPool

+ func (m *MockBackendPool) GetBackendPrivateIPs(clusterName string, service *v1.Service, lb *network.LoadBalancer) []string

type MockBackendPoolMockRecorder

+ func (mr *MockBackendPoolMockRecorder) GetBackendPrivateIPs(clusterName, service, lb interface{}) *gomock.Call

Feb 22, 2022

Changes in this version

type Cloud

+ func (az *Cloud) DeleteLBBackendPool(lbName, backendPoolName string) error

Dec 11, 2021

Changes in this version

type AccountOptions

+ AllowBlobPublicAccess *bool

+ type BackendPool interface

+ CleanupVMSetFromBackendPoolByCondition func(slb *network.LoadBalancer, service *v1.Service, nodes []*v1.Node, ...) (*network.LoadBalancer, error)

+ EnsureHostsInPool func(service *v1.Service, nodes []*v1.Node, ...) error

+ ReconcileBackendPools func(clusterName string, service *v1.Service, lb *network.LoadBalancer) (bool, bool, error)

type Cloud

+ LoadBalancerBackendPool BackendPool

+ Metadata *InstanceMetadataService

+ func (az *Cloud) CreateOrUpdateLBBackendPool(lbName string, backendPool network.BackendAddressPool) error

+ func (az *Cloud) ListNodes(ctx context.Context) ([]v1.Node, error)

type Config

+ LoadBalancerBackendPoolConfigurationType string

+ type MockBackendPool struct

+ func NewMockBackendPool(ctrl *gomock.Controller) *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) ReconcileBackendPools(clusterName string, service *v1.Service, lb *network.LoadBalancer) (bool, bool, error)

+ type MockBackendPoolMockRecorder struct

+ func (mr *MockBackendPoolMockRecorder) CleanupVMSetFromBackendPoolByCondition(slb, service, nodes, clusterName, shouldRemoveVMSetFromSLB interface{}) *gomock.Call

+ func (mr *MockBackendPoolMockRecorder) EnsureHostsInPool(...) *gomock.Call

+ func (mr *MockBackendPoolMockRecorder) ReconcileBackendPools(clusterName, service, lb interface{}) *gomock.Call

type MockVMSet

+ func (m *MockVMSet) GetNodeVMSetName(node *v1.Node) (string, error)

+ func (m *MockVMSet) WaitForUpdateResult(ctx context.Context, future *azure.Future, resourceGroupName, source string) error

type MockVMSetMockRecorder

+ func (mr *MockVMSetMockRecorder) GetNodeVMSetName(node interface{}) *gomock.Call

+ func (mr *MockVMSetMockRecorder) WaitForUpdateResult(ctx, future, resourceGroupName, source interface{}) *gomock.Call

type ScaleSet

+ func (ss *ScaleSet) GetNodeVMSetName(node *v1.Node) (string, error)

type VMSet

+ GetNodeVMSetName func(node *v1.Node) (string, error)

Dec 4, 2022

Changes in this version

+ type AvailabilitySetEntry struct

+ ResourceGroup string

+ VMAS *compute.AvailabilitySet

+ type AvailabilitySetNodeEntry struct

+ NodeNames sets.String

+ VMNames sets.String

+ VMs []compute.VirtualMachine

+ type VMSSEntry struct

+ LastUpdate time.Time

+ ResourceGroup string

+ VMSS *compute.VirtualMachineScaleSet

+ type VMSSVirtualMachinesEntry struct

+ InstanceID string

+ LastUpdate time.Time

+ ResourceGroup string

+ VMSSName string

+ VirtualMachine *compute.VirtualMachineScaleSetVM

Sep 30, 2022

Changes in this version

type ScaleSet

+ func (ss *ScaleSet) DeleteCacheForNode(nodeName string) error

type VMSet

+ DeleteCacheForNode func(nodeName string) error

Sep 17, 2022

Changes in this version

type ScaleSet

+ func (ss *ScaleSet) VMSSBatchSize(vmssName string) (int, error)

Aug 26, 2021

Changes in this version

type Cloud

+ func (az *Cloud) GetConfigFromSecret() (*Config, error)

type Config

+ func ParseConfig(configReader io.Reader) (*Config, error)

Aug 12, 2021

Changes in this version

+ const GroupIDFile

+ const LocationGlobal

+ const PrivateDNSZoneName

+ func AreVNetRulesEqual(account storage.Account, accountOptions *AccountOptions) bool

type AccountOptions

+ CreatePrivateEndpoint bool

type CloudProviderRateLimitConfig

+ AttachDetachDiskRateLimit *azclients.RateLimitConfig

type ManagedDiskOptions

+ BurstingEnabled *bool

+ DiskAccessID *string

+ NetworkAccessPolicy compute.NetworkAccessPolicy

Jul 11, 2022

Changes in this version

type Cloud

+ func (az *Cloud) GetBackendPrivateIPs(clusterName string, service *v1.Service, lb *network.LoadBalancer) []string

Jun 19, 2022

Changes in this version

+ func SliceEqual(s1, s2 []string) bool

May 17, 2022

Changes in this version

type Cloud

+ PrivateLinkServiceClient privatelinkserviceclient.Interface

+ func (az *Cloud) CreateOrUpdatePLS(service *v1.Service, pls network.PrivateLinkService) error

+ func (az *Cloud) CreateOrUpdateSubnet(service *v1.Service, subnet network.Subnet) error

+ func (az *Cloud) DeletePEConn(service *v1.Service, plsName string, peConnName string) *retry.Error

+ func (az *Cloud) DeletePLS(service *v1.Service, plsName string, plsLBFrontendID string) *retry.Error

type Config

+ PlsCacheTTLInSeconds int

+ PrivateLinkServiceResourceGroup string

Apr 13, 2022

Changes in this version

type ScaleSet

+ func (ss *ScaleSet) WaitForUpdateResult(ctx context.Context, future *azure.Future, resourceGroupName, source string) error

type VMSet

+ WaitForUpdateResult func(ctx context.Context, future *azure.Future, resourceGroupName, source string) error

Jan 9, 2022

Changes in this version

type Config

+ PutVMSSVMBatchSize int

Nov 10, 2021

Changes in this version

type Config

+ TagsMap map[string]string

Jun 21, 2021

Changes in this version

+ func NewCloudFromConfigFile(configFilePath string, calFromCCM bool) (cloudprovider.Interface, error)

type AccountOptions

+ EnableNfsV3 *bool

+ IsHnsEnabled *bool

type ManagedDiskOptions

+ SkipGetDiskOperation bool

May 7, 2021

Changes in this version

+ func MapRouteNameToNodeName(ipv6DualStackEnabled bool, routeName string) types.NodeName

+ func NewCloudFromSecret(clientBuilder cloudprovider.ControllerClientBuilder, ...) (cloudprovider.Interface, error)

type AccountOptions

+ EnableLargeFileShare bool

+ type InitSecretConfig struct

+ CloudConfigKey string

+ SecretName string

+ SecretNamespace string

Apr 30, 2022

Changes in this version

type Config

+ PublicIPCacheTTLInSeconds int

Apr 13, 2022

Changes in this version

type Config

+ UserAgent string

Feb 6, 2022

Changes in this version

type Cloud

+ func (az *Cloud) GetPlatformSubFaultDomain() (string, error)

type ComputeMetadata

+ PlatformSubFaultDomain string

Oct 20, 2021

Changes in this version

type Cloud

+ func (az *Cloud) ListManagedLBs(service *v1.Service, nodes []*v1.Node, clusterName string) ([]network.LoadBalancer, error)

Aug 12, 2021

Changes in this version

type MockVMSet

+ func (m *MockVMSet) GetProvisioningStateByNodeName(name string) (string, error)

type MockVMSetMockRecorder

+ func (mr *MockVMSetMockRecorder) GetProvisioningStateByNodeName(name interface{}) *gomock.Call

type ScaleSet

+ func (ss *ScaleSet) GetProvisioningStateByNodeName(name string) (provisioningState string, err error)

type VMSet

+ GetProvisioningStateByNodeName func(name string) (string, error)

Apr 19, 2021

Changes in this version

type AccountOptions

+ DisableFileServiceDeleteRetentionPolicy bool

type Cloud

+ AvailabilitySetsClient vmasclient.Interface

+ ZoneClient zoneclient.Interface

+ func (az *Cloud) GetNodeNames() (sets.String, error)

+ func (az *Cloud) ListAgentPoolLBs(service *v1.Service, nodes []*v1.Node, clusterName string) ([]network.LoadBalancer, error)

+ func (c Cloud) UpdateVM(nodeName types.NodeName) error

type CloudProviderRateLimitConfig

+ AvailabilitySetRateLimit *azclients.RateLimitConfig

type Config

+ AvailabilitySetsCacheTTLInSeconds int

+ NodePoolsWithoutDedicatedSLB string

+ RouteUpdateWaitingInSeconds int

+ SystemTags string

+ type ExtendedLocation struct

+ Name string

+ Type string

+ type LoadBalancerMetadata struct

+ LoadBalancer *LoadbalancerProfile

+ type LoadbalancerProfile struct

+ PublicIPAddresses []PublicIPMetadata

type MockVMSet

+ func (m *MockVMSet) EnsureBackendPoolDeletedFromVMSets(vmSetNamesMap map[string]bool, backendPoolID string) error

+ func (m *MockVMSet) GetAgentPoolVMSetNames(nodes []*v1.Node) (*[]string, error)

+ func (m *MockVMSet) GetNodeCIDRMasksByProviderID(providerID string) (int, int, error)

+ func (m *MockVMSet) UpdateVM(nodeName types.NodeName) error

type MockVMSetMockRecorder

+ func (mr *MockVMSetMockRecorder) EnsureBackendPoolDeletedFromVMSets(vmSetNamesMap, backendPoolID interface{}) *gomock.Call

+ func (mr *MockVMSetMockRecorder) GetAgentPoolVMSetNames(nodes interface{}) *gomock.Call

+ func (mr *MockVMSetMockRecorder) GetNodeCIDRMasksByProviderID(providerID interface{}) *gomock.Call

+ func (mr *MockVMSetMockRecorder) UpdateVM(nodeName interface{}) *gomock.Call

+ type PublicIPMetadata struct

+ FrontendIPAddress string

+ PrivateIPAddress string

+ type ScaleSet struct

+ func NewTestScaleSet(ctrl *gomock.Controller) (*ScaleSet, error)

+ func (c ScaleSet) DisksAreAttached(diskNames []string, nodeName types.NodeName) (map[string]bool, error)

+ func (c ScaleSet) GetDiskLun(diskName, diskURI string, nodeName types.NodeName) (int32, *string, error)

+ func (c ScaleSet) SetDiskLun(nodeName types.NodeName, diskURI string, diskMap map[string]*AttachDiskOptions) (int32, error)

+ func (ss *ScaleSet) AttachDisk(nodeName types.NodeName, diskMap map[string]*AttachDiskOptions) error

+ func (ss *ScaleSet) DetachDisk(nodeName types.NodeName, diskMap map[string]string) error

+ func (ss *ScaleSet) EnsureBackendPoolDeleted(service *v1.Service, backendPoolID, vmSetName string, ...) error

+ func (ss *ScaleSet) EnsureBackendPoolDeletedFromVMSets(vmssNamesMap map[string]bool, backendPoolID string) error

+ func (ss *ScaleSet) EnsureHostInPool(service *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) ([]compute.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) 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) GetVMSetNames(service *v1.Service, nodes []*v1.Node) (*[]string, error)

+ func (ss *ScaleSet) GetZoneByNodeName(name string) (cloudprovider.Zone, error)

+ func (ss *ScaleSet) UpdateVM(nodeName types.NodeName) error

type VMSet

+ EnsureBackendPoolDeletedFromVMSets func(vmSetNamesMap map[string]bool, backendPoolID string) error

+ GetAgentPoolVMSetNames func(nodes []*v1.Node) (*[]string, error)

+ GetNodeCIDRMasksByProviderID func(providerID string) (int, int, error)

+ UpdateVM func(nodeName types.NodeName) error

Feb 27, 2021

Changes in this version

type Config

+ DisableAzureStackCloud bool

Feb 22, 2021

Changes in this version

+ const ServiceAnnotationDenyAllExceptLoadBalancerSourceRanges

+ const SkipMatchingTag

type AccountOptions

+ CreateAccount bool

type Cloud

+ func GetTestCloudWithExtendedLocation(ctrl *gomock.Controller) (az *Cloud)

+ func (az *Cloud) AddStorageAccountTags(resourceGroup, account string, tags map[string]*string) *retry.Error

+ func (az *Cloud) AliasRangesByProviderID(id string) ([]string, error)

+ func (az *Cloud) InstanceExists(ctx context.Context, node *v1.Node) (bool, 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) RemoveStorageAccountTag(resourceGroup, account, key string) *retry.Error

type Config

+ ExtendedLocationName string

+ ExtendedLocationType string

+ func (config *Config) HasExtendedLocation() bool

type ManagedDiskOptions

+ LogicalSectorSize int32

Jan 4, 2021

Changes in this version

+ const AzureStackCloudName

+ const CloudProviderName

+ const IPv6DualStack

+ const InternalLoadBalancerNameSuffix

+ const LabelFailureDomainBetaRegion

+ const LabelFailureDomainBetaZone

+ const PreConfiguredBackendPoolLoadBalancerTypesAll

+ const PreConfiguredBackendPoolLoadBalancerTypesExternal

+ const PreConfiguredBackendPoolLoadBalancerTypesInternal

+ const PreConfiguredBackendPoolLoadBalancerTypesNone

+ const ServiceAnnotationAllowedServiceTag

+ const ServiceAnnotationAzurePIPTags

+ const ServiceAnnotationDNSLabelName

+ const ServiceAnnotationIPTagsForPublicIP

+ const ServiceAnnotationLoadBalancerAutoModeValue

+ const ServiceAnnotationLoadBalancerDisableTCPReset

+ const ServiceAnnotationLoadBalancerEnableHighAvailabilityPorts

+ const ServiceAnnotationLoadBalancerHealthProbeProtocol

+ const ServiceAnnotationLoadBalancerHealthProbeRequestPath

+ const ServiceAnnotationLoadBalancerIdleTimeout

+ const ServiceAnnotationLoadBalancerInternal

+ const ServiceAnnotationLoadBalancerInternalSubnet

+ const ServiceAnnotationLoadBalancerMode

+ const ServiceAnnotationLoadBalancerResourceGroup

+ const ServiceAnnotationPIPName

+ const ServiceAnnotationSharedSecurityRule

+ const WriteAcceleratorEnabled

+ var ErrorNotVmssInstance = errors.New("not a vmss instance")

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

+ func InitializeCloudProviderRateLimitConfig(config *CloudProviderRateLimitConfig)

+ func MakeCRC32(str string) string

+ func NewCloud(configReader io.Reader) (cloudprovider.Interface, error)

+ type AccountOptions struct

+ EnableHTTPSTrafficOnly bool

+ Kind string

+ Location string

+ Name string

+ ResourceGroup string

+ Tags map[string]string

+ Type string

+ VirtualNetworkResourceIDs []string

+ type AttachDiskOptions struct

+ type BlobDiskController struct

+ func (c *BlobDiskController) CreateBlobDisk(dataDiskName string, storageAccountType storage.SkuName, sizeGB int) (string, error)

+ func (c *BlobDiskController) CreateVolume(blobName, accountName, accountType, location string, requestGB int) (string, string, int, error)

+ func (c *BlobDiskController) DeleteBlobDisk(diskURI string) error

+ func (c *BlobDiskController) DeleteVolume(diskURI string) error

+ type Cloud struct

+ DisksClient diskclient.Interface

+ Environment azure.Environment

+ FileClient fileclient.Interface

+ InterfacesClient interfaceclient.Interface

+ KubeClient clientset.Interface

+ LoadBalancerClient loadbalancerclient.Interface

+ PublicIPAddressesClient publicipclient.Interface

+ ResourceRequestBackoff wait.Backoff

+ RouteTablesClient routetableclient.Interface

+ RoutesClient routeclient.Interface

+ SecurityGroupsClient securitygroupclient.Interface

+ SnapshotsClient snapshotclient.Interface

+ StorageAccountClient storageaccountclient.Interface

+ SubnetsClient subnetclient.Interface

+ VMSet VMSet

+ VirtualMachineScaleSetVMsClient vmssvmclient.Interface

+ VirtualMachineScaleSetsClient vmssclient.Interface

+ VirtualMachineSizesClient vmsizeclient.Interface

+ VirtualMachinesClient vmclient.Interface

+ func GetTestCloud(ctrl *gomock.Controller) (az *Cloud)

+ func NewCloudWithoutFeatureGates(configReader io.Reader) (*Cloud, error)

+ func (az *Cloud) AddSSHKeyToAllInstances(ctx context.Context, user string, keyData []byte) error

+ func (az *Cloud) Clusters() (cloudprovider.Clusters, bool)

+ func (az *Cloud) CreateFileShare(accountOptions *AccountOptions, shareOptions *fileclient.ShareOptions) (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) CreateOrUpdatePIP(service *v1.Service, pipResourceGroup string, pip network.PublicIPAddress) error

+ func (az *Cloud) CreateOrUpdateRoute(route network.Route) error

+ func (az *Cloud) CreateOrUpdateRouteTable(routeTable network.RouteTable) error

+ func (az *Cloud) CreateOrUpdateSecurityGroup(sg network.SecurityGroup) error

+ func (az *Cloud) CreateOrUpdateVMSS(resourceGroupName string, VMScaleSetName string, ...) *retry.Error

+ func (az *Cloud) CreateRoute(ctx context.Context, clusterName string, nameHint string, ...) error

+ func (az *Cloud) CurrentNodeName(ctx context.Context, hostname string) (types.NodeName, error)

+ func (az *Cloud) DeleteFileShare(resourceGroup, accountName, shareName string) error

+ func (az *Cloud) DeleteLB(service *v1.Service, lbName string) error

+ func (az *Cloud) DeletePublicIP(service *v1.Service, pipResourceGroup string, pipName string) error

+ func (az *Cloud) DeleteRoute(ctx context.Context, clusterName string, kubeRoute *cloudprovider.Route) error

+ func (az *Cloud) DeleteRouteWithName(routeName string) 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(accountOptions *AccountOptions, genAccountNamePrefix string) (string, string, error)

+ func (az *Cloud) Event(obj runtime.Object, eventType, reason, message string)

+ func (az *Cloud) GetActiveZones() (sets.String, error)

+ func (az *Cloud) GetFileShare(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(ctx context.Context, clusterName string, service *v1.Service) string

+ func (az *Cloud) GetLocation() string

+ func (az *Cloud) GetNodeResourceGroup(nodeName string) (string, error)

+ func (az *Cloud) GetResourceGroups() (sets.String, error)

+ func (az *Cloud) GetStorageAccesskey(account, resourceGroup string) (string, error)

+ func (az *Cloud) GetUnmanagedNodes() (sets.String, error)

+ func (az *Cloud) GetVirtualMachineWithRetry(name types.NodeName, crt azcache.AzureCacheReadType) (compute.VirtualMachine, error)

+ func (az *Cloud) GetZone(ctx context.Context) (cloudprovider.Zone, error)

+ func (az *Cloud) GetZoneByNodeName(ctx 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, stop <-chan struct{})

+ func (az *Cloud) InitializeCloudFromConfig(config *Config, fromSecret bool) error

+ func (az *Cloud) InitializeCloudFromSecret()

+ func (az *Cloud) InstanceExistsByProviderID(ctx context.Context, providerID string) (bool, error)

+ func (az *Cloud) InstanceID(ctx context.Context, name types.NodeName) (string, error)

+ func (az *Cloud) InstanceShutdownByProviderID(ctx context.Context, providerID string) (bool, error)

+ func (az *Cloud) InstanceType(ctx 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) ListPIP(service *v1.Service, pipResourceGroup string) ([]network.PublicIPAddress, error)

+ func (az *Cloud) ListRoutes(ctx 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) NodeAddresses(ctx 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) RequestBackoff() (resourceRequestBackoff wait.Backoff)

+ func (az *Cloud) ResizeFileShare(resourceGroup, accountName, name string, sizeGiB int) error

+ func (az *Cloud) Routes() (cloudprovider.Routes, bool)

+ func (az *Cloud) SetInformers(informerFactory informers.SharedInformerFactory)

+ func (az *Cloud) ShouldNodeExcludedFromLoadBalancer(node *v1.Node) bool

+ func (az *Cloud) UpdateLoadBalancer(ctx context.Context, clusterName string, service *v1.Service, nodes []*v1.Node) error

+ func (az *Cloud) Zones() (cloudprovider.Zones, bool)

+ func (c *Cloud) GetAzureDiskLabels(diskURI string) (map[string]string, error)

+ func (c *Cloud) GetLabelsForVolume(ctx context.Context, pv *v1.PersistentVolume) (map[string]string, error)

+ func (c Cloud) AttachDisk(isManagedDisk bool, diskName, diskURI string, nodeName types.NodeName, ...) (int32, error)

+ func (c Cloud) DetachDisk(diskName, diskURI string, nodeName types.NodeName) error

+ func (c Cloud) DisksAreAttached(diskNames []string, nodeName types.NodeName) (map[string]bool, error)

+ func (c Cloud) GetDiskLun(diskName, diskURI string, nodeName types.NodeName) (int32, error)

+ func (c Cloud) SetDiskLun(nodeName types.NodeName, diskURI string, diskMap map[string]*AttachDiskOptions) (int32, error)

+ type CloudProviderRateLimitConfig struct

+ DiskRateLimit *azclients.RateLimitConfig

+ InterfaceRateLimit *azclients.RateLimitConfig

+ LoadBalancerRateLimit *azclients.RateLimitConfig

+ PublicIPAddressRateLimit *azclients.RateLimitConfig

+ RouteRateLimit *azclients.RateLimitConfig

+ RouteTableRateLimit *azclients.RateLimitConfig

+ SecurityGroupRateLimit *azclients.RateLimitConfig

+ SnapshotRateLimit *azclients.RateLimitConfig

+ StorageAccountRateLimit *azclients.RateLimitConfig

+ SubnetsRateLimit *azclients.RateLimitConfig

+ VirtualMachineRateLimit *azclients.RateLimitConfig

+ VirtualMachineScaleSetRateLimit *azclients.RateLimitConfig

+ VirtualMachineSizeRateLimit *azclients.RateLimitConfig

+ type ComputeMetadata struct

+ Environment string

+ FaultDomain string

+ Location string

+ Name string

+ OSType string

+ ResourceGroup string

+ SKU string

+ SubscriptionID string

+ UpdateDomain string

+ VMScaleSetName string

+ VMSize string

+ Zone string

+ type Config struct

+ AvailabilitySetNodesCacheTTLInSeconds int

+ CloudConfigType cloudConfigType

+ CloudProviderBackoff bool

+ CloudProviderBackoffDuration int

+ CloudProviderBackoffExponent float64

+ CloudProviderBackoffJitter float64

+ CloudProviderBackoffRetries int

+ DisableAvailabilitySetNodes bool

+ DisableOutboundSNAT *bool

+ EnableMultipleStandardLoadBalancers bool

+ ExcludeMasterFromStandardLB *bool

+ LoadBalancerCacheTTLInSeconds int

+ LoadBalancerName string

+ LoadBalancerResourceGroup string

+ LoadBalancerSku string

+ Location string

+ MaximumLoadBalancerRuleCount int

+ NsgCacheTTLInSeconds int

+ PreConfiguredBackendPoolLoadBalancerTypes string

+ PrimaryAvailabilitySetName string

+ PrimaryScaleSetName string

+ ResourceGroup string

+ RouteTableCacheTTLInSeconds int

+ RouteTableName string

+ RouteTableResourceGroup string

+ SecurityGroupName string

+ SecurityGroupResourceGroup string

+ SubnetName string

+ Tags string

+ UseInstanceMetadata bool

+ VMCacheTTLInSeconds int

+ VMType string

+ VmssCacheTTLInSeconds int

+ VmssVirtualMachinesCacheTTLInSeconds int

+ VnetName string

+ VnetResourceGroup string

+ type IPAddress struct

+ PrivateIP string

+ PublicIP string

+ type InstanceMetadata struct

+ Compute *ComputeMetadata

+ Network *NetworkMetadata

+ type InstanceMetadataService struct

+ func NewInstanceMetadataService(metadataURL string) (*InstanceMetadataService, error)

+ func (ims *InstanceMetadataService) GetMetadata(crt azcache.AzureCacheReadType) (*InstanceMetadata, error)

+ type ManagedDiskController struct

+ func (c *ManagedDiskController) CreateManagedDisk(options *ManagedDiskOptions) (string, error)

+ func (c *ManagedDiskController) DeleteManagedDisk(diskURI string) error

+ func (c *ManagedDiskController) GetDisk(resourceGroup, diskName string) (string, string, error)

+ func (c *ManagedDiskController) ResizeDisk(diskURI string, oldSize resource.Quantity, newSize resource.Quantity) (resource.Quantity, error)

+ type ManagedDiskOptions struct

+ AvailabilityZone string

+ DiskEncryptionSetID string

+ DiskIOPSReadWrite string

+ DiskMBpsReadWrite string

+ DiskName string

+ MaxShares int32

+ PVCName string

+ ResourceGroup string

+ SizeGB int

+ SourceResourceID string

+ SourceType string

+ StorageAccountType compute.DiskStorageAccountTypes

+ Tags map[string]string

+ type MockVMSet struct

+ func NewMockVMSet(ctrl *gomock.Controller) *MockVMSet

+ func (m *MockVMSet) AttachDisk(nodeName types.NodeName, diskMap map[string]*AttachDiskOptions) error

+ func (m *MockVMSet) DetachDisk(nodeName types.NodeName, diskMap map[string]string) error

+ func (m *MockVMSet) EXPECT() *MockVMSetMockRecorder

+ func (m *MockVMSet) EnsureBackendPoolDeleted(service *v1.Service, backendPoolID, vmSetName 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) GetDataDisks(nodeName types.NodeName, string cache.AzureCacheReadType) ([]compute.DataDisk, 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) GetNodeNameByIPConfigurationID(ipConfigurationID string) (string, string, error)

+ func (m *MockVMSet) GetNodeNameByProviderID(providerID string) (types.NodeName, 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) GetVMSetNames(service *v1.Service, nodes []*v1.Node) (*[]string, error)

+ func (m *MockVMSet) GetZoneByNodeName(name string) (cloudprovider.Zone, error)

+ type MockVMSetMockRecorder struct

+ func (mr *MockVMSetMockRecorder) AttachDisk(nodeName, diskMap interface{}) *gomock.Call

+ func (mr *MockVMSetMockRecorder) DetachDisk(nodeName, diskMap interface{}) *gomock.Call

+ func (mr *MockVMSetMockRecorder) EnsureBackendPoolDeleted(service, backendPoolID, vmSetName, backendAddressPools interface{}) *gomock.Call

+ func (mr *MockVMSetMockRecorder) EnsureHostInPool(service, nodeName, backendPoolID, vmSetName, isInternal interface{}) *gomock.Call

+ func (mr *MockVMSetMockRecorder) EnsureHostsInPool(service, nodes, backendPoolID, vmSetName, isInternal interface{}) *gomock.Call

+ func (mr *MockVMSetMockRecorder) GetDataDisks(nodeName, string interface{}) *gomock.Call

+ func (mr *MockVMSetMockRecorder) GetIPByNodeName(name interface{}) *gomock.Call

+ func (mr *MockVMSetMockRecorder) GetInstanceIDByNodeName(name interface{}) *gomock.Call

+ func (mr *MockVMSetMockRecorder) GetInstanceTypeByNodeName(name interface{}) *gomock.Call

+ func (mr *MockVMSetMockRecorder) GetNodeNameByIPConfigurationID(ipConfigurationID interface{}) *gomock.Call

+ func (mr *MockVMSetMockRecorder) GetNodeNameByProviderID(providerID interface{}) *gomock.Call

+ func (mr *MockVMSetMockRecorder) GetPowerStatusByNodeName(name interface{}) *gomock.Call

+ func (mr *MockVMSetMockRecorder) GetPrimaryInterface(nodeName interface{}) *gomock.Call

+ func (mr *MockVMSetMockRecorder) GetPrimaryVMSetName() *gomock.Call

+ func (mr *MockVMSetMockRecorder) GetPrivateIPsByNodeName(name interface{}) *gomock.Call

+ func (mr *MockVMSetMockRecorder) GetVMSetNames(service, nodes interface{}) *gomock.Call

+ func (mr *MockVMSetMockRecorder) GetZoneByNodeName(name interface{}) *gomock.Call

+ type NetworkData struct

+ IPAddress []IPAddress

+ Subnet []Subnet

+ type NetworkInterface struct

+ IPV4 NetworkData

+ IPV6 NetworkData

+ MAC string

+ type NetworkMetadata struct

+ Interface []NetworkInterface

+ type Subnet struct

+ Address string

+ Prefix string

+ type VMSet interface

+ AttachDisk func(nodeName types.NodeName, diskMap map[string]*AttachDiskOptions) error

+ DetachDisk func(nodeName types.NodeName, diskMap map[string]string) error

+ EnsureBackendPoolDeleted func(service *v1.Service, backendPoolID, vmSetName string, ...) error

+ EnsureHostInPool func(service *v1.Service, nodeName types.NodeName, backendPoolID string, ...) (string, string, string, *compute.VirtualMachineScaleSetVM, error)

+ EnsureHostsInPool func(service *v1.Service, nodes []*v1.Node, backendPoolID string, vmSetName string, ...) error

+ GetDataDisks func(nodeName types.NodeName, string azcache.AzureCacheReadType) ([]compute.DataDisk, error)

+ GetIPByNodeName func(name string) (string, string, error)

+ GetInstanceIDByNodeName func(name string) (string, error)

+ GetInstanceTypeByNodeName func(name string) (string, error)

+ GetNodeNameByIPConfigurationID func(ipConfigurationID string) (string, string, error)

+ GetNodeNameByProviderID func(providerID string) (types.NodeName, error)

+ GetPowerStatusByNodeName func(name string) (string, error)

+ GetPrimaryInterface func(nodeName string) (network.Interface, error)

+ GetPrimaryVMSetName func() string

+ GetPrivateIPsByNodeName func(name string) ([]string, error)

+ GetVMSetNames func(service *v1.Service, nodes []*v1.Node) (availabilitySetNames *[]string, err error)

+ GetZoneByNodeName func(name string) (cloudprovider.Zone, error)