aks

Documentation

Index

• func Bool(b *bool) bool
• 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, ...) (armcontainerservice.ManagedClustersClientGetAccessProfileResponse, error)
• func GetEnvironment(env string) (cloud.Configuration, azure.Environment)
• func Int32(i *int32) int32
• func NewClientSecretCredential(cred *Credentials) (*azidentity.ClientSecretCredential, 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 String(s *string) string
• func StringMap(msp map[string]*string) map[string]string
• func StringMapPtr(ms map[string]string) map[string]*string
• func StringSlice(s *[]string) []string
• func UpdateCluster(ctx context.Context, cred *Credentials, ...) error
• func UpdateClusterTags(ctx context.Context, clusterClient services.ManagedClustersClientInterface, ...) (armcontainerservice.ManagedClustersClientUpdateTagsResponse, error)
• type Credentials
  • func GetSecrets(_ wranglerv1.SecretCache, secretClient wranglerv1.SecretClient, ...) (*Credentials, error)

Functions

func Bool

func Bool(b *bool) bool

Bool returns a bool value for the passed bool pointer. It returns false if the pointer is nil.

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) (armcontainerservice.ManagedClustersClientGetAccessProfileResponse, error)

func GetEnvironment

func GetEnvironment(env string) (cloud.Configuration, azure.Environment)

func Int32

func Int32(i *int32) int32

Int32 returns an int value for the passed int pointer. It returns 0 if the pointer is nil.

func NewClientSecretCredential

func NewClientSecretCredential(cred *Credentials) (*azidentity.ClientSecretCredential, 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 String

func String(s *string) string

String returns a string value for the passed string pointer. It returns the empty string if the pointer is nil.

func StringMap

func StringMap(msp map[string]*string) map[string]string

StringMap returns a map of strings built from the map of string pointers. The empty string is used for nil pointers.

func StringMapPtr

func StringMapPtr(ms map[string]string) map[string]*string

StringMapPtr returns a map of string pointers built from the passed map of strings.

func StringSlice

func StringSlice(s *[]string) []string

StringSlice returns a string slice value for the passed string slice pointer. It returns a nil slice if the pointer is nil.

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 armcontainerservice.TagsObject) (armcontainerservice.ManagedClustersClientUpdateTagsResponse, error)

Types

type Credentials

type Credentials struct {
	AuthBaseURL    *string
	BaseURL        *string
	SubscriptionID string
	TenantID       string
	ClientID       string
	ClientSecret   string
	Cloud          cloud.Configuration
}

func GetSecrets

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