armhelpers

Nov 4, 2017

Changes in this version

+ func K8sLinuxVMNameParts(vmName string) (poolIdentifier, nameSuffix string, agentIndex int, err error)

+ func VmssNameParts(vmssName string) (poolIdentifier, nameSuffix string, err error)

type ACSEngineClient

+ GetKubernetesClient func(masterURL, kubeConfig string, interval, timeout time.Duration) (KubernetesClient, error)

+ ListProviders func() (resources.ProviderListResult, error)

type AzureClient

+ func (az *AzureClient) EnsureProvidersRegistered(subscriptionID string) error

+ func (az *AzureClient) GetKubernetesClient(masterURL, kubeConfig string, interval, timeout time.Duration) (KubernetesClient, error)

+ func (az *AzureClient) ListProviders() (resources.ProviderListResult, error)

+ type KubernetesClient interface

+ DeletePod func(pod *v1.Pod) error

+ EvictPod func(pod *v1.Pod, policyGroupVersion string) error

+ GetNode func(name string) (*v1.Node, error)

+ ListPods func(node *v1.Node) (*v1.PodList, error)

+ SupportEviction func() (string, error)

+ UpdateNode func(node *v1.Node) (*v1.Node, error)

+ WaitForDelete func(logger *log.Entry, pods []v1.Pod, usingEviction bool) ([]v1.Pod, error)

+ type KubernetesClientSetClient struct

+ func (c *KubernetesClientSetClient) DeletePod(pod *v1.Pod) error

+ func (c *KubernetesClientSetClient) EvictPod(pod *v1.Pod, policyGroupVersion string) error

+ func (c *KubernetesClientSetClient) GetNode(name string) (*v1.Node, error)

+ func (c *KubernetesClientSetClient) ListPods(node *v1.Node) (*v1.PodList, error)

+ func (c *KubernetesClientSetClient) SupportEviction() (string, error)

+ func (c *KubernetesClientSetClient) UpdateNode(node *v1.Node) (*v1.Node, error)

+ func (c *KubernetesClientSetClient) WaitForDelete(logger *log.Entry, pods []v1.Pod, usingEviction bool) ([]v1.Pod, error)

type MockACSEngineClient

+ FailGetKubernetesClient bool

+ FailListProviders bool

+ MockKubernetesClient *MockKubernetesClient

+ func (mc *MockACSEngineClient) GetKubernetesClient(masterURL, kubeConfig string, interval, timeout time.Duration) (KubernetesClient, error)

+ func (mc *MockACSEngineClient) ListProviders() (resources.ProviderListResult, error)

+ type MockKubernetesClient struct

+ FailDeletePod bool

+ FailEvictPod bool

+ FailGetNode bool

+ FailListPods bool

+ FailSupportEviction bool

+ FailUpdateNode bool

+ FailWaitForDelete bool

+ PodsList *v1.PodList

+ ShouldSupportEviction bool

+ func (mkc *MockKubernetesClient) DeletePod(pod *v1.Pod) error

+ func (mkc *MockKubernetesClient) EvictPod(pod *v1.Pod, policyGroupVersion string) error

+ func (mkc *MockKubernetesClient) GetNode(name string) (*v1.Node, error)

+ func (mkc *MockKubernetesClient) ListPods(node *v1.Node) (*v1.PodList, error)

+ func (mkc *MockKubernetesClient) SupportEviction() (string, error)

+ func (mkc *MockKubernetesClient) UpdateNode(node *v1.Node) (*v1.Node, error)

+ func (mkc *MockKubernetesClient) WaitForDelete(logger *log.Entry, pods []v1.Pod, usingEviction bool) ([]v1.Pod, error)

Jul 20, 2017

Changes in this version

+ const AADContributorRoleID

+ const AADRoleReferenceTemplate

+ const AADRoleResourceGroupScopeTemplate

type ACSEngineClient

+ CreateApp func(applicationName, applicationURL string) (applicationID, servicePrincipalObjectID, secret string, err error)

+ CreateGraphApplication func(applicationCreateParameters graphrbac.ApplicationCreateParameters) (graphrbac.Application, error)

+ CreateGraphPrincipal func(servicePrincipalCreateParameters graphrbac.ServicePrincipalCreateParameters) (graphrbac.ServicePrincipal, error)

+ CreateRoleAssignment func(scope string, roleAssignmentName string, ...) (authorization.RoleAssignment, error)

+ CreateRoleAssignmentSimple func(applicationID, roleID string) error

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

+ ListManagedDisksByResourceGroup func(resourceGroupName string) (result disk.ListType, err error)

type AzureClient

+ func (az *AzureClient) CreateApp(appName, appURL string) (applicationID, servicePrincipalObjectID, servicePrincipalClientSecret string, ...)

+ func (az *AzureClient) CreateGraphApplication(applicationCreateParameters graphrbac.ApplicationCreateParameters) (graphrbac.Application, error)

+ func (az *AzureClient) CreateGraphPrincipal(servicePrincipalCreateParameters graphrbac.ServicePrincipalCreateParameters) (graphrbac.ServicePrincipal, error)

+ func (az *AzureClient) CreateRoleAssignment(scope string, roleAssignmentName string, ...) (authorization.RoleAssignment, error)

+ func (az *AzureClient) CreateRoleAssignmentSimple(resourceGroup, servicePrincipalObjectID string) error

+ func (az *AzureClient) DeleteManagedDisk(resourceGroupName string, diskName string, cancel <-chan struct{}) (<-chan disk.OperationStatusResponse, <-chan error)

+ func (az *AzureClient) ListManagedDisksByResourceGroup(resourceGroupName string) (result disk.ListType, err error)

type MockACSEngineClient

+ func (mc *MockACSEngineClient) CreateApp(applicationName, applicationURL string) (applicationID, servicePrincipalObjectID, secret string, err error)

+ func (mc *MockACSEngineClient) CreateGraphApplication(applicationCreateParameters graphrbac.ApplicationCreateParameters) (graphrbac.Application, error)

+ func (mc *MockACSEngineClient) CreateGraphPrincipal(servicePrincipalCreateParameters graphrbac.ServicePrincipalCreateParameters) (graphrbac.ServicePrincipal, error)

+ func (mc *MockACSEngineClient) CreateRoleAssignment(scope string, roleAssignmentName string, ...) (authorization.RoleAssignment, error)

+ func (mc *MockACSEngineClient) CreateRoleAssignmentSimple(applicationID, roleID string) error

+ func (mc *MockACSEngineClient) DeleteManagedDisk(resourceGroupName string, diskName string, cancel <-chan struct{}) (<-chan disk.OperationStatusResponse, <-chan error)

+ func (mc *MockACSEngineClient) ListManagedDisksByResourceGroup(resourceGroupName string) (result disk.ListType, err error)

Jul 7, 2017

Changes in this version

type AzureClient

+ func (az *AzureClient) CheckResourceGroupExistence(name string) (result autorest.Response, err error)

Jun 23, 2017

Changes in this version

type ACSEngineClient

+ AddAcceptLanguages func(languages []string)

type AzureClient

+ func NewAzureClientWithClientCertificateFile(env azure.Environment, ...) (*AzureClient, error)

+ func (az *AzureClient) AddAcceptLanguages(languages []string)

+ func (az *AzureClient) CheckDeploymentExistence(resourceGroupName string, deploymentName string) (result autorest.Response, err error)

+ func (az *AzureClient) ListDeploymentOperations(resourceGroupName string, deploymentName string, top *int32) (result resources.DeploymentOperationsListResult, err error)

+ func (az *AzureClient) ListDeploymentOperationsNextResults(lastResults resources.DeploymentOperationsListResult) (result resources.DeploymentOperationsListResult, err error)

type MockACSEngineClient

+ func (mc *MockACSEngineClient) AddAcceptLanguages(languages []string)

Jun 14, 2017

Changes in this version

type ACSEngineClient

+ ListVirtualMachineScaleSets func(resourceGroup string) (compute.VirtualMachineScaleSetListResult, error)

type AzureClient

+ func (az *AzureClient) ListVirtualMachineScaleSets(resourceGroup string) (compute.VirtualMachineScaleSetListResult, error)

type MockACSEngineClient

+ FailListVirtualMachineScaleSets bool

+ func (mc *MockACSEngineClient) ListVirtualMachineScaleSets(resourceGroup string) (compute.VirtualMachineScaleSetListResult, error)

Jun 8, 2017

Changes in this version

+ const AcsEngineClientID

+ const ApplicationDir

+ var RequiredResourceProviders = []string

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

+ func LinuxVMNameParts(vmName string) (orchestrator string, poolIdentifier string, nameSuffix string, agentIndex int, ...)

+ func ResourceName(ID string) (string, error)

+ func SplitBlobURI(URI string) (string, string, string, error)

+ func WindowsVMNameParts(vmName string) (poolPrefix string, acsStr string, poolIndex int, agentIndex int, err error)

+ type ACSEngineClient interface

+ DeleteNetworkInterface func(resourceGroup, nicName string, cancel <-chan struct{}) (<-chan autorest.Response, <-chan error)

+ DeleteVirtualMachine func(resourceGroup, name string, cancel <-chan struct{}) (<-chan compute.OperationStatusResponse, <-chan error)

+ DeployTemplate func(resourceGroup, name string, template, parameters map[string]interface{}, ...) (*resources.DeploymentExtended, error)

+ EnsureResourceGroup func(resourceGroup, location string) (*resources.Group, error)

+ GetStorageClient func(resourceGroup, accountName string) (ACSStorageClient, error)

+ GetVirtualMachine func(resourceGroup, name string) (compute.VirtualMachine, error)

+ ListVirtualMachines func(resourceGroup string) (compute.VirtualMachineListResult, error)

+ type ACSStorageClient interface

+ DeleteBlob func(container, blob string) error

+ type AzureClient struct

+ func NewAzureClientWithClientCertificate(env azure.Environment, ...) (*AzureClient, error)

+ func NewAzureClientWithClientSecret(env azure.Environment, subscriptionID, clientID, clientSecret string) (*AzureClient, error)

+ func NewAzureClientWithDeviceAuth(env azure.Environment, subscriptionID string) (*AzureClient, error)

+ func (az *AzureClient) DeleteNetworkInterface(resourceGroup, nicName string, cancel <-chan struct{}) (<-chan autorest.Response, <-chan error)

+ func (az *AzureClient) DeleteResourceGroup(name string, cancel chan struct{}) (<-chan autorest.Response, <-chan error)

+ func (az *AzureClient) DeleteVirtualMachine(resourceGroup, name string, cancel <-chan struct{}) (<-chan compute.OperationStatusResponse, <-chan error)

+ func (az *AzureClient) DeployTemplate(resourceGroupName, deploymentName string, template map[string]interface{}, ...) (*resources.DeploymentExtended, error)

+ func (az *AzureClient) EnsureResourceGroup(name, location string) (resourceGroup *resources.Group, err error)

+ func (az *AzureClient) GetDeployment(resourceGroupName, deploymentName string) (result resources.DeploymentExtended, err error)

+ func (az *AzureClient) GetStorageClient(resourceGroup, accountName string) (ACSStorageClient, error)

+ func (az *AzureClient) GetVirtualMachine(resourceGroup, name string) (compute.VirtualMachine, error)

+ func (az *AzureClient) ListVirtualMachines(resourceGroup string) (compute.VirtualMachineListResult, error)

+ func (az *AzureClient) ValidateTemplate(resourceGroupName string, deploymentName string, ...) (result resources.DeploymentValidateResult, err error)

+ type AzureStorageClient struct

+ func (as *AzureStorageClient) DeleteBlob(vhdContainer, vhdBlob string) error

+ type FailingMockClient struct

+ func (fmc *FailingMockClient) DeleteNetworkInterface(resourceGroup, nicName string, cancel <-chan struct{}) (<-chan autorest.Response, <-chan error)

+ func (fmc *FailingMockClient) DeleteVirtualMachine(resourceGroup, name string, cancel <-chan struct{}) (<-chan compute.OperationStatusResponse, <-chan error)

+ func (fmc *FailingMockClient) DeployTemplate(resourceGroup, name string, template, parameters map[string]interface{}, ...) (*resources.DeploymentExtended, error)

+ func (fmc *FailingMockClient) EnsureResourceGroup(resourceGroup, location string) (*resources.Group, error)

+ func (fmc *FailingMockClient) GetStorageClient(resourceGroup, accountName string) (ACSStorageClient, error)

+ func (fmc *FailingMockClient) GetVirtualMachine(resourceGroup, name string) (compute.VirtualMachine, error)

+ func (fmc *FailingMockClient) ListVirtualMachines(resourceGroup string) (compute.VirtualMachineListResult, error)

+ type MockACSEngineClient struct

+ FailDeleteNetworkInterface bool

+ FailDeleteVirtualMachine bool

+ FailDeployTemplate bool

+ FailEnsureResourceGroup bool

+ FailGetStorageClient bool

+ FailGetVirtualMachine bool

+ FailListVirtualMachines bool

+ func (mc *MockACSEngineClient) DeleteNetworkInterface(resourceGroup, nicName string, cancel <-chan struct{}) (<-chan autorest.Response, <-chan error)

+ func (mc *MockACSEngineClient) DeleteVirtualMachine(resourceGroup, name string, cancel <-chan struct{}) (<-chan compute.OperationStatusResponse, <-chan error)

+ func (mc *MockACSEngineClient) DeployTemplate(resourceGroup, name string, template, parameters map[string]interface{}, ...) (*resources.DeploymentExtended, error)

+ func (mc *MockACSEngineClient) EnsureResourceGroup(resourceGroup, location string) (*resources.Group, error)

+ func (mc *MockACSEngineClient) GetStorageClient(resourceGroup, accountName string) (ACSStorageClient, error)

+ func (mc *MockACSEngineClient) GetVirtualMachine(resourceGroup, name string) (compute.VirtualMachine, error)

+ func (mc *MockACSEngineClient) ListVirtualMachines(resourceGroup string) (compute.VirtualMachineListResult, error)

+ type MockClient struct

+ func (mc *MockClient) DeleteNetworkInterface(resourceGroup, nicName string, cancel <-chan struct{}) (<-chan autorest.Response, <-chan error)

+ func (mc *MockClient) DeleteVirtualMachine(resourceGroup, name string, cancel <-chan struct{}) (<-chan compute.OperationStatusResponse, <-chan error)

+ func (mc *MockClient) DeployTemplate(resourceGroup, name string, template, parameters map[string]interface{}, ...) (*resources.DeploymentExtended, error)

+ func (mc *MockClient) EnsureResourceGroup(resourceGroup, location string) (*resources.Group, error)

+ func (mc *MockClient) GetStorageClient(resourceGroup, accountName string) (ACSStorageClient, error)

+ func (mc *MockClient) GetVirtualMachine(resourceGroup, name string) (compute.VirtualMachine, error)

+ func (mc *MockClient) ListVirtualMachines(resourceGroup string) (compute.VirtualMachineListResult, error)

+ type MockStorageClient struct

+ func (msc *MockStorageClient) DeleteBlob(container, blob string) error