Class BlobClientWrapper
- java.lang.Object
-
- org.apache.camel.component.azure.storage.blob.client.BlobClientWrapper
-
public class BlobClientWrapper extends Object
-
-
Constructor Summary
Constructors Constructor Description BlobClientWrapper(com.azure.storage.blob.BlobClient client)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description com.azure.core.http.rest.Response<com.azure.storage.blob.models.AppendBlobItem>
appendBlobBlock(InputStream data, long length, byte[] contentMd5, com.azure.storage.blob.models.AppendBlobRequestConditions appendBlobRequestConditions, Duration timeout)
boolean
appendBlobExists()
com.azure.core.http.rest.Response<com.azure.storage.blob.models.PageBlobItem>
clearPagesBlob(com.azure.storage.blob.models.PageRange pageRange, com.azure.storage.blob.models.PageBlobRequestConditions pageBlobRequestConditions, Duration timeout)
com.azure.core.http.rest.Response<com.azure.storage.blob.models.BlockBlobItem>
commitBlockBlob(List<String> base64BlockIds, com.azure.storage.blob.models.BlobHttpHeaders headers, Map<String,String> metadata, com.azure.storage.blob.models.AccessTier tier, com.azure.storage.blob.models.BlobRequestConditions requestConditions, Duration timeout)
com.azure.core.http.rest.Response<com.azure.storage.blob.models.AppendBlobItem>
createAppendBlob(com.azure.storage.blob.models.BlobHttpHeaders headers, Map<String,String> metadata, com.azure.storage.blob.models.BlobRequestConditions requestConditions, Duration timeout)
com.azure.core.http.rest.Response<com.azure.storage.blob.models.PageBlobItem>
createPageBlob(long size, Long sequenceNumber, com.azure.storage.blob.models.BlobHttpHeaders headers, Map<String,String> metadata, com.azure.storage.blob.models.BlobRequestConditions requestConditions, Duration timeout)
com.azure.core.http.rest.Response<Void>
delete(com.azure.storage.blob.models.DeleteSnapshotsOptionType deleteBlobSnapshotOptions, com.azure.storage.blob.models.BlobRequestConditions requestConditions, Duration timeout)
com.azure.core.http.rest.Response<com.azure.storage.blob.models.BlobProperties>
downloadToFileWithResponse(String filePath, com.azure.storage.blob.models.BlobRange range, com.azure.storage.blob.models.ParallelTransferOptions parallelTransferOptions, com.azure.storage.blob.models.DownloadRetryOptions downloadRetryOptions, com.azure.storage.blob.models.BlobRequestConditions requestConditions, boolean rangeGetContentMd5, Duration timeout)
com.azure.core.http.rest.ResponseBase<com.azure.storage.blob.models.BlobDownloadHeaders,Void>
downloadWithResponse(OutputStream stream, com.azure.storage.blob.models.BlobRange range, com.azure.storage.blob.models.DownloadRetryOptions options, com.azure.storage.blob.models.BlobRequestConditions requestConditions, boolean getRangeContentMd5, Duration timeout)
String
generateSas(com.azure.storage.blob.sas.BlobServiceSasSignatureValues blobServiceSasSignatureValues)
String
getBlobName()
String
getBlobUrl()
com.azure.core.http.rest.Response<com.azure.storage.blob.models.PageList>
getPageBlobRanges(com.azure.storage.blob.models.BlobRange blobRange, com.azure.storage.blob.models.BlobRequestConditions requestConditions, Duration timeout)
com.azure.core.http.rest.Response<com.azure.storage.blob.models.BlockList>
listBlobBlocks(com.azure.storage.blob.models.BlockListType listType, String leaseId, Duration timeout)
Map<String,Object>
openInputStream(com.azure.storage.blob.models.BlobRange blobRange, com.azure.storage.blob.models.BlobRequestConditions blobRequestConditions)
boolean
pageBlobExists()
com.azure.core.http.rest.Response<com.azure.storage.blob.models.PageBlobItem>
resizePageBlob(long size, com.azure.storage.blob.models.BlobRequestConditions requestConditions, Duration timeout)
com.azure.core.http.HttpHeaders
stageBlockBlob(String base64BlockId, InputStream data, long length, byte[] contentMd5, String leaseId, Duration timeout)
com.azure.core.http.rest.Response<com.azure.storage.blob.models.BlockBlobItem>
uploadBlockBlob(InputStream data, long length, com.azure.storage.blob.models.BlobHttpHeaders headers, Map<String,String> metadata, com.azure.storage.blob.models.AccessTier tier, byte[] contentMd5, com.azure.storage.blob.models.BlobRequestConditions requestConditions, Duration timeout)
com.azure.core.http.rest.Response<com.azure.storage.blob.models.PageBlobItem>
uploadPageBlob(com.azure.storage.blob.models.PageRange pageRange, InputStream body, byte[] contentMd5, com.azure.storage.blob.models.PageBlobRequestConditions pageBlobRequestConditions, Duration timeout)
-
-
-
Method Detail
-
getBlobName
public String getBlobName()
-
getBlobUrl
public String getBlobUrl()
-
delete
public com.azure.core.http.rest.Response<Void> delete(com.azure.storage.blob.models.DeleteSnapshotsOptionType deleteBlobSnapshotOptions, com.azure.storage.blob.models.BlobRequestConditions requestConditions, Duration timeout)
-
openInputStream
public Map<String,Object> openInputStream(com.azure.storage.blob.models.BlobRange blobRange, com.azure.storage.blob.models.BlobRequestConditions blobRequestConditions)
-
downloadWithResponse
public com.azure.core.http.rest.ResponseBase<com.azure.storage.blob.models.BlobDownloadHeaders,Void> downloadWithResponse(OutputStream stream, com.azure.storage.blob.models.BlobRange range, com.azure.storage.blob.models.DownloadRetryOptions options, com.azure.storage.blob.models.BlobRequestConditions requestConditions, boolean getRangeContentMd5, Duration timeout)
-
downloadToFileWithResponse
public com.azure.core.http.rest.Response<com.azure.storage.blob.models.BlobProperties> downloadToFileWithResponse(String filePath, com.azure.storage.blob.models.BlobRange range, com.azure.storage.blob.models.ParallelTransferOptions parallelTransferOptions, com.azure.storage.blob.models.DownloadRetryOptions downloadRetryOptions, com.azure.storage.blob.models.BlobRequestConditions requestConditions, boolean rangeGetContentMd5, Duration timeout)
-
uploadBlockBlob
public com.azure.core.http.rest.Response<com.azure.storage.blob.models.BlockBlobItem> uploadBlockBlob(InputStream data, long length, com.azure.storage.blob.models.BlobHttpHeaders headers, Map<String,String> metadata, com.azure.storage.blob.models.AccessTier tier, byte[] contentMd5, com.azure.storage.blob.models.BlobRequestConditions requestConditions, Duration timeout)
-
stageBlockBlob
public com.azure.core.http.HttpHeaders stageBlockBlob(String base64BlockId, InputStream data, long length, byte[] contentMd5, String leaseId, Duration timeout)
-
commitBlockBlob
public com.azure.core.http.rest.Response<com.azure.storage.blob.models.BlockBlobItem> commitBlockBlob(List<String> base64BlockIds, com.azure.storage.blob.models.BlobHttpHeaders headers, Map<String,String> metadata, com.azure.storage.blob.models.AccessTier tier, com.azure.storage.blob.models.BlobRequestConditions requestConditions, Duration timeout)
-
listBlobBlocks
public com.azure.core.http.rest.Response<com.azure.storage.blob.models.BlockList> listBlobBlocks(com.azure.storage.blob.models.BlockListType listType, String leaseId, Duration timeout)
-
createAppendBlob
public com.azure.core.http.rest.Response<com.azure.storage.blob.models.AppendBlobItem> createAppendBlob(com.azure.storage.blob.models.BlobHttpHeaders headers, Map<String,String> metadata, com.azure.storage.blob.models.BlobRequestConditions requestConditions, Duration timeout)
-
appendBlobBlock
public com.azure.core.http.rest.Response<com.azure.storage.blob.models.AppendBlobItem> appendBlobBlock(InputStream data, long length, byte[] contentMd5, com.azure.storage.blob.models.AppendBlobRequestConditions appendBlobRequestConditions, Duration timeout)
-
appendBlobExists
public boolean appendBlobExists()
-
createPageBlob
public com.azure.core.http.rest.Response<com.azure.storage.blob.models.PageBlobItem> createPageBlob(long size, Long sequenceNumber, com.azure.storage.blob.models.BlobHttpHeaders headers, Map<String,String> metadata, com.azure.storage.blob.models.BlobRequestConditions requestConditions, Duration timeout)
-
uploadPageBlob
public com.azure.core.http.rest.Response<com.azure.storage.blob.models.PageBlobItem> uploadPageBlob(com.azure.storage.blob.models.PageRange pageRange, InputStream body, byte[] contentMd5, com.azure.storage.blob.models.PageBlobRequestConditions pageBlobRequestConditions, Duration timeout)
-
resizePageBlob
public com.azure.core.http.rest.Response<com.azure.storage.blob.models.PageBlobItem> resizePageBlob(long size, com.azure.storage.blob.models.BlobRequestConditions requestConditions, Duration timeout)
-
clearPagesBlob
public com.azure.core.http.rest.Response<com.azure.storage.blob.models.PageBlobItem> clearPagesBlob(com.azure.storage.blob.models.PageRange pageRange, com.azure.storage.blob.models.PageBlobRequestConditions pageBlobRequestConditions, Duration timeout)
-
getPageBlobRanges
public com.azure.core.http.rest.Response<com.azure.storage.blob.models.PageList> getPageBlobRanges(com.azure.storage.blob.models.BlobRange blobRange, com.azure.storage.blob.models.BlobRequestConditions requestConditions, Duration timeout)
-
pageBlobExists
public boolean pageBlobExists()
-
generateSas
public String generateSas(com.azure.storage.blob.sas.BlobServiceSasSignatureValues blobServiceSasSignatureValues)
-
-