aks

Documentation

Index

• func CheckLogAnalyticsWorkspaceForMonitoring(ctx context.Context, client services.WorkplacesClientInterface, ...) (workspaceID string, err error)
• func CreateCluster(ctx context.Context, cred *Credentials, ...) error
• func CreateOrUpdateAgentPool(ctx context.Context, agentPoolClient services.AgentPoolsClientInterface, ...) error
• func CreateResourceGroup(ctx context.Context, groupsClient services.ResourceGroupsClientInterface, ...) error
• func ExistsCluster(ctx context.Context, clusterClient services.ManagedClustersClientInterface, ...) (bool, error)
• func ExistsResourceGroup(ctx context.Context, groupsClient services.ResourceGroupsClientInterface, ...) (bool, error)
• func FindTenantID(ctx context.Context, env azure.Environment, subscriptionID string) (string, error)
• func GetCachedTenantID(secretClient secretClient, subscriptionID string, secret *corev1.Secret) (string, error)
• func GetClusterAccessProfile(ctx context.Context, clusterClient services.ManagedClustersClientInterface, ...) (containerservice.ManagedClusterAccessProfile, error)
• func GetEnvironment(env string) azure.Environment
• func NewClientAuthorizer(cred *Credentials) (autorest.Authorizer, error)
• func NewClusterClient(cred *Credentials) (*containerservice.ManagedClustersClient, error)
• func NewSubscriptionsClient(baseURI string) subscriptions.Client
• func RemoveAgentPool(ctx context.Context, agentPoolClient services.AgentPoolsClientInterface, ...) error
• func RemoveCluster(ctx context.Context, clusterClient services.ManagedClustersClientInterface, ...) error
• func UpdateCluster(ctx context.Context, cred *Credentials, ...) error
• func UpdateClusterTags(ctx context.Context, clusterClient services.ManagedClustersClientInterface, ...) (containerservice.ManagedClustersUpdateTagsFuture, error)
• type Credentials
  • func GetSecrets(_ wranglerv1.SecretCache, secretClient wranglerv1.SecretClient, ...) (*Credentials, error)

Functions

func CheckLogAnalyticsWorkspaceForMonitoring

func CheckLogAnalyticsWorkspaceForMonitoring(ctx context.Context, client services.WorkplacesClientInterface,
	location string, group string, wsg string, wsn string) (workspaceID string, err error)

func CreateCluster

func CreateCluster(ctx context.Context, cred *Credentials, clusterClient services.ManagedClustersClientInterface, workplaceClient services.WorkplacesClientInterface,
	spec *aksv1.AKSClusterConfigSpec, phase string) error

CreateCluster creates a new managed Kubernetes cluster. In this case, there will be no existing upstream cluster. We are provisioning a brand new one.

func CreateOrUpdateAgentPool

func CreateOrUpdateAgentPool(ctx context.Context, agentPoolClient services.AgentPoolsClientInterface, spec *aksv1.AKSClusterConfigSpec, np *aksv1.AKSNodePool) error

CreateOrUpdateAgentPool creates a new pool(s) in AKS. If one already exists it updates the upstream node pool with any provided updates.

func CreateResourceGroup

func CreateResourceGroup(ctx context.Context, groupsClient services.ResourceGroupsClientInterface, spec *aksv1.AKSClusterConfigSpec) error

func ExistsCluster

func ExistsCluster(ctx context.Context, clusterClient services.ManagedClustersClientInterface, spec *aksv1.AKSClusterConfigSpec) (bool, error)

ExistsCluster Check if AKS managed Kubernetes cluster exist

func ExistsResourceGroup

func ExistsResourceGroup(ctx context.Context, groupsClient services.ResourceGroupsClientInterface, resourceGroup string) (bool, error)

func FindTenantID

func FindTenantID(ctx context.Context, env azure.Environment, subscriptionID string) (string, error)

This function is used to find the tenant ID for the subscription ID. It will send an unauthenticated request to the Azure Resource Manager endpoint to get the tenant ID from the WWW-Authenticate header. Example header:

  Bearer authorization_uri="https://login.windows.net/996fe9d1-6171-40aa-945b-4c64b63bf655",
		error="invalid_token", error_description="The authentication failed because of missing 'Authorization' header."

func GetCachedTenantID

func GetCachedTenantID(secretClient secretClient, subscriptionID string, secret *corev1.Secret) (string, error)

func GetClusterAccessProfile

func GetClusterAccessProfile(ctx context.Context, clusterClient services.ManagedClustersClientInterface, resourceGroupName string, resourceName string, roleName string) (containerservice.ManagedClusterAccessProfile, error)

func GetEnvironment

func GetEnvironment(env string) azure.Environment

func NewClientAuthorizer

func NewClientAuthorizer(cred *Credentials) (autorest.Authorizer, error)

func NewClusterClient

func NewClusterClient(cred *Credentials) (*containerservice.ManagedClustersClient, error)

func NewSubscriptionsClient

func NewSubscriptionsClient(baseURI string) subscriptions.Client

This function is used to create a new SubscriptionsClient with the given base URI. It is used to make unauthenticated requests to the Azure Resource Manager endpoint.

func RemoveAgentPool

func RemoveAgentPool(ctx context.Context, agentPoolClient services.AgentPoolsClientInterface, spec *aksv1.AKSClusterConfigSpec, np *aksv1.AKSNodePool) error

RemoveAgentPool Delete AKS Agent Pool

func RemoveCluster

func RemoveCluster(ctx context.Context, clusterClient services.ManagedClustersClientInterface, spec *aksv1.AKSClusterConfigSpec) error

RemoveCluster Delete AKS managed Kubernetes cluster

func UpdateCluster

func UpdateCluster(ctx context.Context, cred *Credentials, clusterClient services.ManagedClustersClientInterface, workplaceClient services.WorkplacesClientInterface,
	spec *aksv1.AKSClusterConfigSpec, phase string) error

UpdateCluster updates an existing managed Kubernetes cluster. Before updating, it pulls any existing configuration and then only updates managed fields.

func UpdateClusterTags

func UpdateClusterTags(ctx context.Context, clusterClient services.ManagedClustersClientInterface, resourceGroupName string, resourceName string, parameters containerservice.TagsObject) (containerservice.ManagedClustersUpdateTagsFuture, error)

Types

type Credentials

type Credentials struct {
	AuthBaseURL    *string
	BaseURL        *string
	SubscriptionID string
	TenantID       string
	ClientID       string
	ClientSecret   string
}

func GetSecrets

func GetSecrets(_ wranglerv1.SecretCache, secretClient wranglerv1.SecretClient, spec *aksv1.AKSClusterConfigSpec) (*Credentials, error)