in pkg/providers/instance/azure_client.go [72:101]
func NewAZClient(cfg *auth.Config, env *azure.Environment) (*AZClient, error) {
authorizer, err := auth.NewAuthorizer(cfg, env)
if err != nil {
return nil, err
}
azClientConfig := cfg.GetAzureClientConfig(authorizer, env)
azClientConfig.UserAgent = auth.GetUserAgentExtension()
cred, err := auth.NewCredential(cfg, azClientConfig.Authorizer)
if err != nil {
return nil, err
}
isE2E := utils.WithDefaultBool("E2E_TEST_MODE", false)
// If not E2E, we use the default options
opts := armopts.DefaultArmOpts()
if isE2E {
opts = setArmClientOptions()
}
agentPoolClient, err := armcontainerservice.NewAgentPoolsClient(cfg.SubscriptionID, cred, opts)
if err != nil {
return nil, err
}
klog.V(5).Infof("Created agent pool client %v using token credential", agentPoolClient)
return &AZClient{
agentPoolsClient: agentPoolClient,
}, nil
}