Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

azure

package

Go to main page

Versions in this module

v0

v0.10.2

Jul 15, 2021

v0.10.1

Dec 8, 2020

v0.10.0

Aug 3, 2020

Changes in this version

type ContainerServiceAgentPool

+ func (agentPool *ContainerServiceAgentPool) GetACSAgentPool(agentProfiles *[]containerservice.AgentPoolProfile) (ret *containerservice.AgentPoolProfile)

+ func (agentPool *ContainerServiceAgentPool) GetAKSAgentPool(agentProfiles *[]containerservice.ManagedClusterAgentPoolProfile) (ret *containerservice.ManagedClusterAgentPoolProfile)

v0.1.0

May 29, 2018

Changes in this version

+ const ProviderName

+ var InstanceTypes = map[string]*instanceType

+ func BuildAzureCloudProvider(azureManager *AzureManager, resourceLimiter *cloudprovider.ResourceLimiter) (cloudprovider.CloudProvider, error)

+ func GetVMNameIndex(osType compute.OperatingSystemTypes, vmName string) (int, error)

+ type AccountsClient interface

+ ListKeys func(resourceGroupName string, accountName string) (result storage.AccountListKeysResult, err error)

+ type AccountsClientMock struct

+ func (m *AccountsClientMock) ListKeys(resourceGroupName string, accountName string) (result storage.AccountListKeysResult, err error)

+ type AgentPool struct

+ func NewAgentPool(spec *dynamic.NodeGroupSpec, az *AzureManager) (*AgentPool, error)

+ func (as *AgentPool) Autoprovisioned() bool

+ func (as *AgentPool) Belongs(node *apiv1.Node) (bool, error)

+ func (as *AgentPool) Create() error

+ func (as *AgentPool) Debug() string

+ func (as *AgentPool) DecreaseTargetSize(delta int) error

+ func (as *AgentPool) Delete() error

+ func (as *AgentPool) DeleteInstances(instances []*azureRef) error

+ func (as *AgentPool) DeleteNodes(nodes []*apiv1.Node) error

+ func (as *AgentPool) Exist() bool

+ func (as *AgentPool) GetVMIndexes() ([]int, map[int]string, error)

+ func (as *AgentPool) GetVirtualMachines() (instances []compute.VirtualMachine, err error)

+ func (as *AgentPool) Id() string

+ func (as *AgentPool) IncreaseSize(delta int) error

+ func (as *AgentPool) MaxSize() int

+ func (as *AgentPool) MinSize() int

+ func (as *AgentPool) Nodes() ([]string, error)

+ func (as *AgentPool) TargetSize() (int, error)

+ func (as *AgentPool) TemplateNodeInfo() (*schedulercache.NodeInfo, error)

+ func (m *AgentPool) GetKey() string

+ type AzUtil struct

+ func (util *AzUtil) DeleteBlob(accountName, vhdContainer, vhdBlob string) error

+ func (util *AzUtil) DeleteVirtualMachine(rg string, name string) error

+ type AzureCloudProvider struct

+ func (azure *AzureCloudProvider) Cleanup() error

+ func (azure *AzureCloudProvider) GetAvailableMachineTypes() ([]string, error)

+ func (azure *AzureCloudProvider) GetResourceLimiter() (*cloudprovider.ResourceLimiter, error)

+ func (azure *AzureCloudProvider) Name() string

+ func (azure *AzureCloudProvider) NewNodeGroup(machineType string, labels map[string]string, systemLabels map[string]string, ...) (cloudprovider.NodeGroup, error)

+ func (azure *AzureCloudProvider) NodeGroupForNode(node *apiv1.Node) (cloudprovider.NodeGroup, error)

+ func (azure *AzureCloudProvider) NodeGroups() []cloudprovider.NodeGroup

+ func (azure *AzureCloudProvider) Pricing() (cloudprovider.PricingModel, errors.AutoscalerError)

+ func (azure *AzureCloudProvider) Refresh() error

+ type AzureManager struct

+ func CreateAzureManager(configReader io.Reader, discoveryOpts cloudprovider.NodeGroupDiscoveryOptions) (*AzureManager, error)

+ func (m *AzureManager) Cleanup()

+ func (m *AzureManager) GetAsgForInstance(instance *azureRef) (cloudprovider.NodeGroup, error)

+ func (m *AzureManager) Refresh() error

+ func (m *AzureManager) RegisterAsg(asg cloudprovider.NodeGroup) bool

+ func (m *AzureManager) UnregisterAsg(asg cloudprovider.NodeGroup) bool

+ type Config struct

+ AADClientCertPassword string

+ AADClientCertPath string

+ AADClientID string

+ AADClientSecret string

+ Cloud string

+ ClusterName string

+ Deployment string

+ DeploymentParameters map[string]interface{}

+ NodeResourceGroup string

+ ResourceGroup string

+ SubscriptionID string

+ TenantID string

+ UseManagedIdentityExtension bool

+ VMType string

+ func (c *Config) TrimSpace()

+ type ContainerServiceAgentPool struct

+ func NewContainerServiceAgentPool(spec *dynamic.NodeGroupSpec, am *AzureManager) (*ContainerServiceAgentPool, error)

+ func (agentPool *ContainerServiceAgentPool) Autoprovisioned() bool

+ func (agentPool *ContainerServiceAgentPool) Create() error

+ func (agentPool *ContainerServiceAgentPool) Debug() string

+ func (agentPool *ContainerServiceAgentPool) DecreaseTargetSize(delta int) error

+ func (agentPool *ContainerServiceAgentPool) Delete() error

+ func (agentPool *ContainerServiceAgentPool) DeleteNodes(nodes []*apiv1.Node) error

+ func (agentPool *ContainerServiceAgentPool) DeleteNodesInternal(providerIDs []string) error

+ func (agentPool *ContainerServiceAgentPool) Exist() bool

+ func (agentPool *ContainerServiceAgentPool) GetName(providerID string) (string, error)

+ func (agentPool *ContainerServiceAgentPool) GetNodeCount(agentProfiles *[]containerservice.AgentPoolProfile) (count int, err error)

+ func (agentPool *ContainerServiceAgentPool) GetNodes() ([]string, error)

+ func (agentPool *ContainerServiceAgentPool) GetPool(agentProfiles *[]containerservice.AgentPoolProfile) (ret *containerservice.AgentPoolProfile)

+ func (agentPool *ContainerServiceAgentPool) GetProviderID(name string) string

+ func (agentPool *ContainerServiceAgentPool) Id() string

+ func (agentPool *ContainerServiceAgentPool) IncreaseSize(delta int) error

+ func (agentPool *ContainerServiceAgentPool) IsContainerServiceNode(tags *map[string]*string) bool

+ func (agentPool *ContainerServiceAgentPool) MaxSize() int

+ func (agentPool *ContainerServiceAgentPool) MinSize() int

+ func (agentPool *ContainerServiceAgentPool) Nodes() ([]string, error)

+ func (agentPool *ContainerServiceAgentPool) SetNodeCount(agentProfiles *[]containerservice.AgentPoolProfile, count int) (err error)

+ func (agentPool *ContainerServiceAgentPool) SetSize(targetSize int) error

+ func (agentPool *ContainerServiceAgentPool) TargetSize() (int, error)

+ func (agentPool *ContainerServiceAgentPool) TemplateNodeInfo() (*schedulercache.NodeInfo, error)

+ func (m *ContainerServiceAgentPool) GetKey() string

+ type DeploymentsClient interface

+ CreateOrUpdate func(resourceGroupName string, deploymentName string, ...) (<-chan resources.DeploymentExtended, <-chan error)

+ ExportTemplate func(resourceGroupName string, deploymentName string) (result resources.DeploymentExportResult, err error)

+ Get func(resourceGroupName string, deploymentName string) (result resources.DeploymentExtended, err error)

+ type DeploymentsClientMock struct

+ FakeStore map[string]resources.DeploymentExtended

+ func (m *DeploymentsClientMock) CreateOrUpdate(resourceGroupName string, deploymentName string, ...) (<-chan resources.DeploymentExtended, <-chan error)

+ func (m *DeploymentsClientMock) ExportTemplate(resourceGroupName string, deploymentName string) (result resources.DeploymentExportResult, err error)

+ func (m *DeploymentsClientMock) Get(resourceGroupName string, deploymentName string) (result resources.DeploymentExtended, err error)

+ type DisksClient interface

+ Delete func(resourceGroupName string, diskName string, cancel <-chan struct{}) (<-chan disk.OperationStatusResponse, <-chan error)

+ type DisksClientMock struct

+ func (m *DisksClientMock) Delete(resourceGroupName string, diskName string, cancel <-chan struct{}) (<-chan disk.OperationStatusResponse, <-chan error)

+ type InterfacesClient interface

+ Delete func(resourceGroupName string, networkInterfaceName string, cancel <-chan struct{}) (<-chan autorest.Response, <-chan error)

+ type InterfacesClientMock struct

+ func (m *InterfacesClientMock) Delete(resourceGroupName string, networkInterfaceName string, cancel <-chan struct{}) (<-chan autorest.Response, <-chan error)

+ type ScaleSet struct

+ func NewScaleSet(spec *dynamic.NodeGroupSpec, az *AzureManager) (*ScaleSet, error)

+ func (m *ScaleSet) GetKey() string

+ func (scaleSet *ScaleSet) Autoprovisioned() bool

+ func (scaleSet *ScaleSet) Belongs(node *apiv1.Node) (bool, error)

+ func (scaleSet *ScaleSet) Create() error

+ func (scaleSet *ScaleSet) Debug() string

+ func (scaleSet *ScaleSet) DecreaseTargetSize(delta int) error

+ func (scaleSet *ScaleSet) Delete() error

+ func (scaleSet *ScaleSet) DeleteInstances(instances []*azureRef) error

+ func (scaleSet *ScaleSet) DeleteNodes(nodes []*apiv1.Node) error

+ func (scaleSet *ScaleSet) Exist() bool

+ func (scaleSet *ScaleSet) GetScaleSetSize() (int64, error)

+ func (scaleSet *ScaleSet) GetScaleSetVms() ([]compute.VirtualMachineScaleSetVM, error)

+ func (scaleSet *ScaleSet) Id() string

+ func (scaleSet *ScaleSet) IncreaseSize(delta int) error

+ func (scaleSet *ScaleSet) MaxSize() int

+ func (scaleSet *ScaleSet) MinSize() int

+ func (scaleSet *ScaleSet) Nodes() ([]string, error)

+ func (scaleSet *ScaleSet) SetScaleSetSize(size int64) error

+ func (scaleSet *ScaleSet) TargetSize() (int, error)

+ func (scaleSet *ScaleSet) TemplateNodeInfo() (*schedulercache.NodeInfo, error)

+ type VirtualMachineScaleSetVMsClient interface

+ Get func(ctx context.Context, resourceGroupName string, VMScaleSetName string, ...) (result compute.VirtualMachineScaleSetVM, err error)

+ List func(ctx context.Context, resourceGroupName string, ...) (result []compute.VirtualMachineScaleSetVM, err error)

+ type VirtualMachineScaleSetVMsClientMock struct

+ func (m *VirtualMachineScaleSetVMsClientMock) Get(ctx context.Context, resourceGroupName string, VMScaleSetName string, ...) (result compute.VirtualMachineScaleSetVM, err error)

+ func (m *VirtualMachineScaleSetVMsClientMock) List(ctx context.Context, resourceGroupName string, ...) (result []compute.VirtualMachineScaleSetVM, err error)

+ type VirtualMachineScaleSetsClient interface

+ CreateOrUpdate func(ctx context.Context, resourceGroupName string, name string, ...) (resp *http.Response, err error)

+ DeleteInstances func(ctx context.Context, resourceGroupName string, vmScaleSetName string, ...) (resp *http.Response, err error)

+ Get func(ctx context.Context, resourceGroupName string, vmScaleSetName string) (result compute.VirtualMachineScaleSet, err error)

+ List func(ctx context.Context, resourceGroupName string) (result []compute.VirtualMachineScaleSet, err error)

+ type VirtualMachineScaleSetsClientMock struct

+ FakeStore map[string]map[string]compute.VirtualMachineScaleSet

+ func (client *VirtualMachineScaleSetsClientMock) CreateOrUpdate(ctx context.Context, resourceGroupName string, VMScaleSetName string, ...) (resp *http.Response, err error)

+ func (client *VirtualMachineScaleSetsClientMock) DeleteInstances(ctx context.Context, resourceGroupName string, vmScaleSetName string, ...) (resp *http.Response, err error)

+ func (client *VirtualMachineScaleSetsClientMock) Get(ctx context.Context, resourceGroupName string, vmScaleSetName string) (result compute.VirtualMachineScaleSet, err error)

+ func (client *VirtualMachineScaleSetsClientMock) List(ctx context.Context, resourceGroupName string) (result []compute.VirtualMachineScaleSet, err error)

+ type VirtualMachinesClient interface

+ Delete func(ctx context.Context, resourceGroupName string, VMName string) (resp *http.Response, err error)

+ Get func(ctx context.Context, resourceGroupName string, VMName string, ...) (result compute.VirtualMachine, err error)

+ List func(ctx context.Context, resourceGroupName string) (result []compute.VirtualMachine, err error)

+ type VirtualMachinesClientMock struct

+ FakeStore map[string]map[string]compute.VirtualMachine

+ func (m *VirtualMachinesClientMock) Delete(ctx context.Context, resourceGroupName string, VMName string) (resp *http.Response, err error)

+ func (m *VirtualMachinesClientMock) Get(ctx context.Context, resourceGroupName string, VMName string, ...) (result compute.VirtualMachine, err error)

+ func (m *VirtualMachinesClientMock) List(ctx context.Context, resourceGroupName string) (result []compute.VirtualMachine, err error)