kubernetes
/
kops
mirror of https://github.com/kubernetes/kops.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

azure: Remove unused VFS client code

This commit is contained in:
Ciprian Hacman 2024-04-28 08:48:02 +03:00
parent 305860c02b
commit 017f98c906
1 changed files with 0 additions and 40 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

40
util/pkg/vfs/azureclient.go
View File

@ -18,22 +18,14 @@ package vfs
import ( import (
"context" "context"
"encoding/json"
"fmt" "fmt"
"io"
"net/http"
"os" "os"
"github.com/Azure/azure-sdk-for-go/sdk/azidentity" "github.com/Azure/azure-sdk-for-go/sdk/azidentity"
"github.com/Azure/azure-sdk-for-go/sdk/storage/azblob" "github.com/Azure/azure-sdk-for-go/sdk/storage/azblob"
"golang.org/x/oauth2"
"k8s.io/klog/v2" "k8s.io/klog/v2"
) )
const (
storageResourceID = "https://storage.azure.com/"
)
func newAzureClient(ctx context.Context) (*azblob.Client, error) { func newAzureClient(ctx context.Context) (*azblob.Client, error) {
klog.Infof("New Azure Blob client") klog.Infof("New Azure Blob client")
accountName := os.Getenv("AZURE_STORAGE_ACCOUNT") accountName := os.Getenv("AZURE_STORAGE_ACCOUNT")
@ -55,35 +47,3 @@ func newAzureClient(ctx context.Context) (*azblob.Client, error) {
return client, nil return client, nil
} }
// getAccessTokenFromInstanceMetadataService obtains the access token from Instance Metadata Service.
func getAccessTokenFromInstanceMetadataService(ctx context.Context) (string, error) {
client := &http.Client{}
req, err := http.NewRequestWithContext(ctx, "GET", "http://169.254.169.254/metadata/identity/oauth2/token", nil)
if err != nil {
return "", fmt.Errorf("error creating a new request: %s", err)
}
req.Header.Add("Metadata", "True")
q := req.URL.Query()
q.Add("resource", storageResourceID)
q.Add("api-version", "2020-06-01")
req.URL.RawQuery = q.Encode()
resp, err := client.Do(req)
if err != nil {
return "", fmt.Errorf("error sending request to the metadata server: %s", err)
}
defer resp.Body.Close()
body, err := io.ReadAll(resp.Body)
if err != nil {
return "", fmt.Errorf("error reading a response from the metadata server: %s", err)
}
token := &oauth2.Token{}
if err := json.Unmarshal(body, token); err != nil {
return "", fmt.Errorf("error unmarsharlling token: %s", err)
}
return token.AccessToken, nil
}