dapr
/
components-contrib
mirror of https://github.com/dapr/components-contrib.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Add blob url to azure blob create (#474) 

* add blob url to azure blob create

* add missing err statement
This commit is contained in:
Yaron Schneider 2020-09-23 17:42:46 -07:00 committed by GitHub
parent d2dcd8e508
commit 1e92e0e8e1
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 19 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
bindings/azure/blobstorage/blobstorage.go
View File

@ -48,6 +48,10 @@ type blobStorageMetadata struct {
GetBlobRetryCount int `json:"getBlobRetryCount"`
}
type createResponse struct {
BlobURL string `json:"blobURL"`
}
// NewAzureBlobStorage returns a new Azure Blob Storage instance
func NewAzureBlobStorage(logger logger.Logger) *AzureBlobStorage {
return &AzureBlobStorage{logger: logger}
@ -156,7 +160,21 @@ func (a *AzureBlobStorage) create(blobURL azblob.BlockBlobURL, req *bindings.Inv
Metadata: req.Metadata,
BlobHTTPHeaders: blobHTTPHeaders,
})
return nil, err
if err != nil {
return nil, fmt.Errorf("error uploading az blob: %s", err)
}
resp := createResponse{
BlobURL: blobURL.String(),
}
b, err := json.Marshal(resp)
if err != nil {
return nil, fmt.Errorf("error marshalling create response for azure blob: %s", err)
}
return &bindings.InvokeResponse{
Data: b,
}, nil
}
func (a *AzureBlobStorage) get(blobURL azblob.BlockBlobURL, req *bindings.InvokeRequest) (*bindings.InvokeResponse, error) {