add metadata in container creating

Author: umagnus

pkg/blob/controllerserver.go

@@ -61,6 +61,8 @@ const (
 	MSI                             = "MSI"
 	SPN                             = "SPN"
 	authorizationPermissionMismatch = "AuthorizationPermissionMismatch"
+
+	createdByMetadata = "createdBy"
 )
 
 // CreateVolume provisions a volume
@@ -312,6 +314,10 @@ func (d *Driver) CreateVolume(ctx context.Context, req *csi.CreateVolumeRequest)
 		return nil, status.Errorf(codes.InvalidArgument, err.Error())
 	}
 
+	if err != nil {
+		return nil, status.Errorf(codes.InvalidArgument, err.Error())
+	}
+
 	if strings.TrimSpace(storageEndpointSuffix) == "" {
 		storageEndpointSuffix = d.getStorageEndPointSuffix()
 	}
@@ -691,11 +697,17 @@ func (d *Driver) CreateBlobContainer(ctx context.Context, subsID, resourceGroupN
 			if getErr != nil {
 				return true, getErr
 			}
+			metadata := make(map[string]string)
+			metadata[createdByMetadata] = d.Name
+			container.Metadata = metadata
 			_, err = container.CreateIfNotExists(&azstorage.CreateContainerOptions{Access: azstorage.ContainerAccessTypePrivate})
 		} else {
+			metadataPtr := make(map[string]*string)
+			metadataPtr[createdByMetadata] = to.Ptr(d.Name)
 			blobContainer := armstorage.BlobContainer{
 				ContainerProperties: &armstorage.ContainerProperties{
 					PublicAccess: to.Ptr(armstorage.PublicAccessNone),
+					Metadata:     metadataPtr,
 				},
 			}
 			var blobClient blobcontainerclient.Interface