@@ -312,6 +312,13 @@ func (d *Driver) CreateVolume(ctx context.Context, req *csi.CreateVolumeRequest)
312
312
GetLatestAccountKey : getLatestAccountKey ,
313
313
}
314
314
315
+ var volumeID string
316
+ mc := metrics .NewMetricContext (blobCSIDriverName , "controller_create_volume" , d .cloud .ResourceGroup , d .cloud .SubscriptionID , d .Name )
317
+ isOperationSucceeded := false
318
+ defer func () {
319
+ mc .ObserveOperationWithResult (isOperationSucceeded , VolumeID , volumeID )
320
+ }()
321
+
315
322
var accountKey string
316
323
accountName := account
317
324
secrets := req .GetSecrets ()
@@ -380,13 +387,6 @@ func (d *Driver) CreateVolume(ctx context.Context, req *csi.CreateVolumeRequest)
380
387
setKeyValueInMap (parameters , containerNameField , validContainerName )
381
388
}
382
389
383
- var volumeID string
384
- mc := metrics .NewMetricContext (blobCSIDriverName , "controller_create_volume" , d .cloud .ResourceGroup , d .cloud .SubscriptionID , d .Name )
385
- isOperationSucceeded := false
386
- defer func () {
387
- mc .ObserveOperationWithResult (isOperationSucceeded , VolumeID , volumeID )
388
- }()
389
-
390
390
klog .V (2 ).Infof ("begin to create container(%s) on account(%s) type(%s) subsID(%s) rg(%s) location(%s) size(%d)" , validContainerName , accountName , storageAccountType , subsID , resourceGroup , location , requestGiB )
391
391
if err := d .CreateBlobContainer (ctx , subsID , resourceGroup , accountName , validContainerName , secrets ); err != nil {
392
392
return nil , status .Errorf (codes .Internal , "failed to create container(%s) on account(%s) type(%s) rg(%s) location(%s) size(%d), error: %v" , validContainerName , accountName , storageAccountType , resourceGroup , location , requestGiB , err )
0 commit comments