in internal/output/azureblobstorage/azure_blob_storage.go [50:62]
func (o *Output) Write(b []byte) (int, error) {
cType := "application/json"
options := azblob.UploadBufferOptions{
HTTPHeaders: &blobalias.HTTPHeaders{
BlobContentType: &cType,
},
}
_, err := o.client.UploadBuffer(context.Background(), o.opts.AzureBlobStorageOptions.Container, o.opts.AzureBlobStorageOptions.Blob, b, &options)
if err != nil {
return 0, fmt.Errorf("failed to upload file to blob: %w", err)
}
return len(b), nil
}