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) |
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) |
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 | Field and Description |
---|---|
protected ConcurrentMap<String,ConcurrentMap<String,Blob>> |
TransientAsyncBlobStore.containerToBlobs |
Modifier and Type | Method and Description |
---|---|
protected Blob |
TransientAsyncBlobStore.createUpdatedCopyOfBlobInContainer(String containerName,
Blob in) |
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> |
TransientAsyncBlobStore.getBlob(String containerName,
String key,
GetOptions options) |
com.google.common.util.concurrent.ListenableFuture<Blob> |
AsyncBlobStore.getBlob(String container,
String key,
GetOptions options) |
ConcurrentMap<String,ConcurrentMap<String,Blob>> |
TransientAsyncBlobStore.getContainerToBlobs() |
com.google.common.util.concurrent.ListenableFuture<Blob> |
TransientAsyncBlobStore.putBlobAndReturnOld(String containerName,
Blob in) |
com.google.common.util.concurrent.ListenableFuture<Blob> |
TransientAsyncBlobStore.removeBlobAndReturnOld(String container,
String key) |
Modifier and Type | Method and Description |
---|---|
protected Blob |
TransientAsyncBlobStore.createUpdatedCopyOfBlobInContainer(String containerName,
Blob in) |
com.google.common.util.concurrent.ListenableFuture<String> |
TransientAsyncBlobStore.putBlob(String containerName,
Blob in) |
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> |
TransientAsyncBlobStore.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) |
com.google.common.util.concurrent.ListenableFuture<Blob> |
TransientAsyncBlobStore.putBlobAndReturnOld(String containerName,
Blob in) |
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.
|
Constructor and Description |
---|
TransientAsyncBlobStore(BlobStoreContext context,
DateService dateService,
Crypto crypto,
ConcurrentMap<String,ConcurrentMap<String,Blob>> containerToBlobs,
Provider<UriBuilder> uriBuilders,
ConcurrentMap<String,Location> containerToLocation,
HttpGetOptionsListToGetOptions httpGetOptionsConverter,
IfDirectoryReturnNameStrategy ifDirectoryReturnName,
Blob.Factory blobFactory,
BlobUtils blobUtils,
ExecutorService service,
com.google.common.base.Supplier<Location> defaultLocation,
com.google.common.base.Supplier<Set<? extends Location>> locations) |
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) |
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 |
---|---|
com.google.common.util.concurrent.ListenableFuture<Blob> |
FilesystemAsyncBlobStore.getBlob(String containerName,
String key,
GetOptions options) |
Modifier and Type | Method and Description |
---|---|
com.google.common.util.concurrent.ListenableFuture<String> |
FilesystemAsyncBlobStore.putBlob(String containerName,
Blob object) |
com.google.common.util.concurrent.ListenableFuture<String> |
FilesystemAsyncBlobStore.putBlob(String container,
Blob blob,
PutOptions options) |
Modifier and Type | Method and Description |
---|---|
Blob |
FilesystemStorageStrategy.newBlob(String name)
Creates a new blob
|
Modifier and Type | Method and Description |
---|---|
Blob |
FilesystemStorageStrategyImpl.newBlob(String name) |
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 |
SwiftBlobRequestSigner.signPutBlob(String container,
Blob blob) |
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 |
---|---|
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) |
Modifier and Type | Method and Description |
---|---|
Blob |
ObjectToBlob.apply(S3Object from) |
Modifier and Type | Method and Description |
---|---|
S3Object |
BlobToObject.apply(Blob from) |
Copyright © 2009-2012 jclouds. All Rights Reserved.