github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-25 04:33:26 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #91723 from ZeroMagic/newly-created

Browse Source 
check the azurefile if exists before creating
This commit is contained in:
Kubernetes Prow Robot 2020-06-08 03:27:46 -07:00 committed by GitHub
commit 3e923704c2
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 11 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
staging/src/k8s.io/legacy-cloud-providers/azure/clients/fileclient/azure_fileclient.go
View File

@ -21,6 +21,8 @@ package fileclient
import ( import (
"context" "context"
"fmt" "fmt"
"net/http"
"strings"
"github.com/Azure/azure-sdk-for-go/services/storage/mgmt/2019-06-01/storage" "github.com/Azure/azure-sdk-for-go/services/storage/mgmt/2019-06-01/storage"
@ -45,6 +47,14 @@ func New(config *azclients.ClientConfig) *Client {
// CreateFileShare creates a file share // CreateFileShare creates a file share
func (c *Client) CreateFileShare(resourceGroupName, accountName, name string, sizeGiB int) error { func (c *Client) CreateFileShare(resourceGroupName, accountName, name string, sizeGiB int) error {
result, err := c.GetFileShare(resourceGroupName, accountName, name)
if err == nil {
klog.V(2).Infof("file share(%s) under account(%s) rg(%s) already exists", name, accountName, resourceGroupName)
return nil
} else if err != nil && result.Response.StatusCode != http.StatusNotFound && !strings.Contains(err.Error(), "ShareNotFound") {
return fmt.Errorf("failed to get file share(%s), err: %v", name, err)
}
quota := int32(sizeGiB) quota := int32(sizeGiB)
fileShare := storage.FileShare{ fileShare := storage.FileShare{
Name: &name, Name: &name,
@ -52,7 +62,7 @@ func (c *Client) CreateFileShare(resourceGroupName, accountName, name string, si
ShareQuota: &quota, ShareQuota: &quota,
}, },
} }
_, err := c.fileSharesClient.Create(context.Background(), resourceGroupName, accountName, name, fileShare) _, err = c.fileSharesClient.Create(context.Background(), resourceGroupName, accountName, name, fileShare)
return err return err
} }