| Modifier and Type | Method and Description | 
|---|---|
Blob | 
AtmosBlobStore.getBlob(String container,
       String key,
       GetOptions options)
This implementation invokes  
AtmosClient.readFile(java.lang.String, org.jclouds.http.options.GetOptions...) | 
| Modifier and Type | Method and Description | 
|---|---|
com.google.common.util.concurrent.ListenableFuture<Blob> | 
AtmosAsyncBlobStore.getBlob(String container,
       String key,
       GetOptions options)
This implementation invokes  
AtmosAsyncClient.readFile(java.lang.String, org.jclouds.http.options.GetOptions...) | 
| Modifier and Type | Method and Description | 
|---|---|
String | 
AtmosBlobStore.putBlob(String container,
       Blob blob)
This implementation invokes  
AtmosClient.createFile(java.lang.String, org.jclouds.atmos.domain.AtmosObject, org.jclouds.atmos.options.PutOptions...)
 
 Since there is no etag support in atmos, we just return the path. | 
com.google.common.util.concurrent.ListenableFuture<String> | 
AtmosAsyncBlobStore.putBlob(String container,
       Blob blob)
This implementation invokes  
AtmosAsyncClient.createFile(java.lang.String, org.jclouds.atmos.domain.AtmosObject, org.jclouds.atmos.options.PutOptions...)
 
 Since there is no etag support in atmos, we just return the path. | 
String | 
AtmosBlobStore.putBlob(String container,
       Blob blob,
       PutOptions options)
This implementation invokes  
AtmosClient.createFile(java.lang.String, org.jclouds.atmos.domain.AtmosObject, org.jclouds.atmos.options.PutOptions...)
 
 Since there is no etag support in atmos, we just return the path. | 
com.google.common.util.concurrent.ListenableFuture<String> | 
AtmosAsyncBlobStore.putBlob(String container,
       Blob blob,
       PutOptions options)  | 
HttpRequest | 
AtmosBlobRequestSigner.signPutBlob(String container,
           Blob blob)  | 
HttpRequest | 
AtmosBlobRequestSigner.signPutBlob(String container,
           Blob blob,
           long timeInSeconds)  | 
| Modifier and Type | Method and Description | 
|---|---|
Blob | 
ObjectToBlob.apply(AtmosObject from)  | 
| Modifier and Type | Method and Description | 
|---|---|
AtmosObject | 
BlobToObject.apply(Blob from)  | 
| Modifier and Type | Method and Description | 
|---|---|
static String | 
AtmosUtils.putBlob(AtmosClient sync,
       Crypto crypto,
       BlobToObject blob2Object,
       String container,
       Blob blob,
       PutOptions options)  | 
| Modifier and Type | Method and Description | 
|---|---|
String | 
AWSS3BlobStore.putBlob(String container,
       Blob blob,
       PutOptions options)  | 
com.google.common.util.concurrent.ListenableFuture<String> | 
AWSS3AsyncBlobStore.putBlob(String container,
       Blob blob,
       PutOptions options)  | 
| Modifier and Type | Method and Description | 
|---|---|
String | 
MultipartUploadStrategy.execute(String container,
       Blob blob,
       PutOptions options)  | 
com.google.common.util.concurrent.ListenableFuture<String> | 
AsyncMultipartUploadStrategy.execute(String container,
       Blob blob,
       PutOptions options)  | 
| Modifier and Type | Method and Description | 
|---|---|
String | 
SequentialMultipartUploadStrategy.execute(String container,
       Blob blob,
       PutOptions options)  | 
com.google.common.util.concurrent.ListenableFuture<String> | 
ParallelMultipartUploadStrategy.execute(String container,
       Blob blob,
       PutOptions options)  | 
| Modifier and Type | Method and Description | 
|---|---|
Blob | 
AzureBlobStore.getBlob(String container,
       String key,
       GetOptions options)
This implementation invokes  
AzureBlobClient.getBlob(java.lang.String, java.lang.String, org.jclouds.http.options.GetOptions...) | 
| Modifier and Type | Method and Description | 
|---|---|
com.google.common.util.concurrent.ListenableFuture<Blob> | 
AzureAsyncBlobStore.getBlob(String container,
       String key,
       GetOptions options)
This implementation invokes  
AzureBlobAsyncClient.getBlob(java.lang.String, java.lang.String, org.jclouds.http.options.GetOptions...) | 
| Modifier and Type | Method and Description | 
|---|---|
String | 
AzureBlobStore.putBlob(String container,
       Blob blob)
This implementation invokes  
AzureBlobClient#putObject | 
com.google.common.util.concurrent.ListenableFuture<String> | 
AzureAsyncBlobStore.putBlob(String container,
       Blob blob)
This implementation invokes  
AzureBlobAsyncClient.putBlob(java.lang.String, org.jclouds.azureblob.domain.AzureBlob) | 
String | 
AzureBlobStore.putBlob(String container,
       Blob blob,
       PutOptions options)
This implementation invokes  
AzureBlobClient#putObject | 
com.google.common.util.concurrent.ListenableFuture<String> | 
AzureAsyncBlobStore.putBlob(String container,
       Blob blob,
       PutOptions options)  | 
HttpRequest | 
AzureBlobRequestSigner.signPutBlob(String container,
           Blob blob)  | 
HttpRequest | 
AzureBlobRequestSigner.signPutBlob(String container,
           Blob blob,
           long timeInSeconds)  | 
| Modifier and Type | Method and Description | 
|---|---|
Blob | 
AzureBlobToBlob.apply(AzureBlob from)  | 
| Modifier and Type | Method and Description | 
|---|---|
AzureBlob | 
BlobToAzureBlob.apply(Blob from)  | 
| Modifier and Type | Method and Description | 
|---|---|
Blob | 
TransientStorageStrategy.getBlob(String containerName,
       String blobName)  | 
Blob | 
LocalStorageStrategy.getBlob(String containerName,
       String blobName)
Load the blob with the given key belonging to the container with the given
 name. 
 | 
Blob | 
BlobStore.getBlob(String container,
       String name)
Retrieves a  
Blob representing the data at location container/name | 
Blob | 
BlobStore.getBlob(String container,
       String name,
       GetOptions options)
Retrieves a  
Blob representing the data at location container/name | 
| Modifier and Type | Method and Description | 
|---|---|
com.google.common.util.concurrent.ListenableFuture<Blob> | 
AsyncBlobStore.getBlob(String container,
       String key)  | 
com.google.common.util.concurrent.ListenableFuture<Blob> | 
LocalAsyncBlobStore.getBlob(String containerName,
       String key,
       GetOptions options) | 
com.google.common.util.concurrent.ListenableFuture<Blob> | 
AsyncBlobStore.getBlob(String container,
       String key,
       GetOptions options)  | 
| Modifier and Type | Method and Description | 
|---|---|
String | 
TransientStorageStrategy.putBlob(String containerName,
       Blob blob)  | 
String | 
LocalStorageStrategy.putBlob(String containerName,
       Blob blob)
Write a  
Blob into a file | 
com.google.common.util.concurrent.ListenableFuture<String> | 
LocalAsyncBlobStore.putBlob(String containerName,
       Blob blob) | 
String | 
BlobStore.putBlob(String container,
       Blob blob)
Adds a  
Blob representing the data at location container/blob.metadata.name | 
com.google.common.util.concurrent.ListenableFuture<String> | 
AsyncBlobStore.putBlob(String container,
       Blob blob)  | 
com.google.common.util.concurrent.ListenableFuture<String> | 
LocalAsyncBlobStore.putBlob(String container,
       Blob blob,
       PutOptions options)  | 
String | 
BlobStore.putBlob(String container,
       Blob blob,
       PutOptions options)
Adds a  
Blob representing the data at location container/blob.metadata.name
 options using multipart strategies. | 
com.google.common.util.concurrent.ListenableFuture<String> | 
AsyncBlobStore.putBlob(String container,
       Blob blob,
       PutOptions options)  | 
HttpRequest | 
TransientBlobRequestSigner.signPutBlob(String container,
           Blob blob)  | 
HttpRequest | 
BlobRequestSigner.signPutBlob(String container,
           Blob blob)
gets a signed request, including headers as necessary, to upload a blob from an external
 client. 
 | 
HttpRequest | 
TransientBlobRequestSigner.signPutBlob(String container,
           Blob blob,
           long timeInSeconds)  | 
HttpRequest | 
BlobRequestSigner.signPutBlob(String container,
           Blob blob,
           long timeInSeconds)
gets a signed request, including headers as necessary, to upload a blob from an
 external client for a limited period of time 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Blob | 
BlobBuilder.build()
This makes a blob from the currently configured parameters. 
 | 
Blob | 
Blob.Factory.create(MutableBlobMetadata metadata)
Creates a blob, optionally setting its metadata to a known value. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
BlobImpl
Value type for an HTTP Blob service. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Blob | 
BlobBuilderImpl.build()  | 
Blob | 
BlobBuilderImpl.PayloadBlobBuilderImpl.build()  | 
| Modifier and Type | Method and Description | 
|---|---|
int | 
BlobImpl.compareTo(Blob o) | 
| Modifier and Type | Method and Description | 
|---|---|
Blob | 
ParseBlobFromHeadersAndHttpContent.apply(HttpResponse from)  | 
| Modifier and Type | Method and Description | 
|---|---|
Blob | 
BlobMapImpl.CorrectBlobName.apply(Map.Entry<? extends String,? extends Blob> arg0)  | 
Blob | 
BlobMapImpl.CorrectBlobName.apply(String key,
     Blob blob)  | 
Blob | 
BlobMapImpl.get(Object key)  | 
Blob | 
BaseBlobStore.getBlob(String container,
       String key)
This implementation invokes
  
BlobStore.getBlob(String,String,org.jclouds.blobstore.options.GetOptions) | 
Blob | 
BlobMapImpl.put(String key,
   Blob value)  | 
Blob | 
BlobMapImpl.remove(Object key)  | 
protected Blob | 
BaseBlobMap.stripPrefix(Blob from)  | 
| Modifier and Type | Method and Description | 
|---|---|
protected Iterable<Blob> | 
BaseBlobMap.getAllBlobs()  | 
com.google.common.util.concurrent.ListenableFuture<Blob> | 
BaseAsyncBlobStore.getBlob(String container,
       String key)
This implementation invokes
  
AsyncBlobStore.getBlob(String,String,org.jclouds.blobstore.options.GetOptions) | 
Collection<Blob> | 
BlobMapImpl.values()  | 
| Modifier and Type | Method and Description | 
|---|---|
Blob | 
BlobMapImpl.CorrectBlobName.apply(String key,
     Blob blob)  | 
Blob | 
BlobMapImpl.put(String key,
   Blob value)  | 
HttpRequest | 
RequestSigningUnsupported.signPutBlob(String container,
           Blob blob)  | 
HttpRequest | 
RequestSigningUnsupported.signPutBlob(String container,
           Blob blob,
           long timeInSeconds)  | 
protected Blob | 
BaseBlobMap.stripPrefix(Blob from)  | 
| Modifier and Type | Method and Description | 
|---|---|
Blob | 
BlobMapImpl.CorrectBlobName.apply(Map.Entry<? extends String,? extends Blob> arg0)  | 
void | 
BlobMapImpl.putAll(Map<? extends String,? extends Blob> map)  | 
| Modifier and Type | Method and Description | 
|---|---|
Iterable<Blob> | 
GetBlobsInListStrategy.execute(String containerName,
       ListContainerOptions options)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
PutBlobsStrategy.execute(String containerName,
       Iterable<? extends Blob> collection)  | 
| Modifier and Type | Method and Description | 
|---|---|
Iterable<Blob> | 
GetAllBlobsInListAndRetryOnFailure.execute(String container,
       ListContainerOptions options)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
PutBlobsStrategyImpl.execute(String containerName,
       Iterable<? extends Blob> blobs)  | 
| Modifier and Type | Method and Description | 
|---|---|
static Blob | 
BlobStoreUtils.newBlob(BlobStore blobStore,
       StorageMetadata blobMeta)  | 
| Modifier and Type | Method and Description | 
|---|---|
static com.google.common.util.concurrent.ListenableFuture<Void> | 
BlobStoreUtils.createParentIfNeededAsync(AsyncBlobStore asyncBlobStore,
                         String container,
                         Blob blob)  | 
static String | 
BlobStoreUtils.getContentAsStringOrNullAndClose(Blob blob)  | 
| Modifier and Type | Method and Description | 
|---|---|
Blob | 
FilesystemStorageStrategyImpl.getBlob(String container,
       String key)  | 
Blob | 
FilesystemStorageStrategyImpl.newBlob(String name)  | 
| Modifier and Type | Method and Description | 
|---|---|
String | 
FilesystemStorageStrategyImpl.putBlob(String containerName,
       Blob blob)  | 
| Modifier and Type | Method and Description | 
|---|---|
HttpRequest | 
HPCloudObjectStorageBlobRequestSigner.signPutBlob(String container,
           Blob blob)  | 
HttpRequest | 
HPCloudObjectStorageBlobRequestSigner.signPutBlob(String container,
           Blob blob,
           long timeInSeconds)  | 
| Modifier and Type | Method and Description | 
|---|---|
Blob | 
SwiftBlobStore.getBlob(String container,
       String key,
       GetOptions optionsList)
This implementation invokes  
CommonSwiftClient.getObject(java.lang.String, java.lang.String, org.jclouds.http.options.GetOptions...) | 
| Modifier and Type | Method and Description | 
|---|---|
com.google.common.util.concurrent.ListenableFuture<Blob> | 
SwiftAsyncBlobStore.getBlob(String container,
       String key,
       GetOptions options)
This implementation invokes  
CommonSwiftAsyncClient.getObject(java.lang.String, java.lang.String, org.jclouds.http.options.GetOptions...) | 
| Modifier and Type | Method and Description | 
|---|---|
String | 
SwiftBlobStore.putBlob(String container,
       Blob blob)
This implementation invokes  
CommonSwiftClient.putObject(java.lang.String, org.jclouds.openstack.swift.domain.SwiftObject) | 
com.google.common.util.concurrent.ListenableFuture<String> | 
SwiftAsyncBlobStore.putBlob(String container,
       Blob blob)
This implementation invokes  
CommonSwiftAsyncClient.putObject(java.lang.String, org.jclouds.openstack.swift.domain.SwiftObject) | 
String | 
SwiftBlobStore.putBlob(String container,
       Blob blob,
       PutOptions options)
This implementation invokes  
CommonSwiftClient.putObject(java.lang.String, org.jclouds.openstack.swift.domain.SwiftObject) | 
com.google.common.util.concurrent.ListenableFuture<String> | 
SwiftAsyncBlobStore.putBlob(String container,
       Blob blob,
       PutOptions options)  | 
HttpRequest | 
SwiftBlobSigner.signPutBlob(String container,
           Blob blob)  | 
HttpRequest | 
SwiftBlobSigner.signPutBlob(String container,
           Blob blob,
           long timeInSeconds)  | 
| Modifier and Type | Method and Description | 
|---|---|
Blob | 
ObjectToBlob.apply(SwiftObject from)  | 
| Modifier and Type | Method and Description | 
|---|---|
SwiftObject | 
BlobToObject.apply(Blob from)  | 
| Modifier and Type | Method and Description | 
|---|---|
String | 
SequentialMultipartUploadStrategy.execute(String container,
       Blob blob,
       PutOptions options,
       BlobToObject blob2Object)  | 
com.google.common.util.concurrent.ListenableFuture<String> | 
ParallelMultipartUploadStrategy.execute(String container,
       Blob blob,
       PutOptions options,
       BlobToObject blob2Object)  | 
String | 
MultipartUploadStrategy.execute(String container,
       Blob blob,
       PutOptions options,
       BlobToObject blob2Object)  | 
com.google.common.util.concurrent.ListenableFuture<String> | 
AsyncMultipartUploadStrategy.execute(String container,
       Blob blob,
       PutOptions options,
       BlobToObject blob2Object)  | 
protected void | 
ParallelMultipartUploadStrategy.prepareUploadPart(String container,
                 Blob blob,
                 String key,
                 Integer part,
                 Payload payload,
                 long offset,
                 long size,
                 SortedMap<Integer,String> etags,
                 BlockingQueue<Integer> activeParts,
                 Map<Integer,com.google.common.util.concurrent.ListenableFuture<String>> futureParts,
                 AtomicInteger errors,
                 int maxRetries,
                 Map<Integer,Exception> errorMap,
                 Queue<org.jclouds.openstack.swift.blobstore.strategy.internal.ParallelMultipartUploadStrategy.Part> toRetry,
                 CountDownLatch latch,
                 BlobToObject blob2Object)  | 
| Modifier and Type | Method and Description | 
|---|---|
Blob | 
S3BlobStore.getBlob(String container,
       String key,
       GetOptions optionsList)
This implementation invokes  
S3Client.getObject(java.lang.String, java.lang.String, org.jclouds.http.options.GetOptions...) | 
| Modifier and Type | Method and Description | 
|---|---|
com.google.common.util.concurrent.ListenableFuture<Blob> | 
S3AsyncBlobStore.getBlob(String container,
       String key,
       GetOptions options)
This implementation invokes  
S3AsyncClient.getObject(java.lang.String, java.lang.String, org.jclouds.http.options.GetOptions...) | 
| Modifier and Type | Method and Description | 
|---|---|
String | 
S3BlobStore.putBlob(String container,
       Blob blob)
This implementation invokes  
S3Client.putObject(java.lang.String, org.jclouds.s3.domain.S3Object, org.jclouds.s3.options.PutObjectOptions...) | 
com.google.common.util.concurrent.ListenableFuture<String> | 
S3AsyncBlobStore.putBlob(String container,
       Blob blob)
 | 
String | 
S3BlobStore.putBlob(String container,
       Blob blob,
       PutOptions overrides)
This implementation invokes  
S3Client.putObject(java.lang.String, org.jclouds.s3.domain.S3Object, org.jclouds.s3.options.PutObjectOptions...) | 
com.google.common.util.concurrent.ListenableFuture<String> | 
S3AsyncBlobStore.putBlob(String container,
       Blob blob,
       PutOptions overrides)  | 
HttpRequest | 
S3BlobRequestSigner.signPutBlob(String container,
           Blob blob)  | 
HttpRequest | 
S3BlobRequestSigner.signPutBlob(String container,
           Blob blob,
           long timeInSeconds)  | 
| Modifier and Type | Method and Description | 
|---|---|
Blob | 
ObjectToBlob.apply(S3Object from)  | 
| Modifier and Type | Method and Description | 
|---|---|
S3Object | 
BlobToObject.apply(Blob from)  | 
Copyright © 2009-2013 jclouds. All Rights Reserved.