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.