org.jclouds.s3.blobstore
Class S3AsyncBlobStore

java.lang.Object
  org.jclouds.blobstore.internal.BaseAsyncBlobStore
      org.jclouds.s3.blobstore.S3AsyncBlobStore

All Implemented Interfaces:

org.jclouds.blobstore.AsyncBlobStore

Deprecated. will be removed in jclouds 1.7, as async interfaces are no longer supported. Please use S3BlobStore

@Deprecated
@Singleton
public class S3AsyncBlobStore
extends org.jclouds.blobstore.internal.BaseAsyncBlobStore

Field Summary

Fields inherited from class org.jclouds.blobstore.internal.BaseAsyncBlobStore

blobUtils, context, defaultLocation, locations, userExecutor

Constructor Summary

protected

S3AsyncBlobStore(org.jclouds.blobstore.BlobStoreContext context, org.jclouds.blobstore.util.BlobUtils blobUtils, com.google.common.util.concurrent.ListeningExecutorService userExecutor, com.google.common.base.Supplier<org.jclouds.domain.Location> defaultLocation, com.google.common.base.Supplier<Set<? extends org.jclouds.domain.Location>> locations, S3AsyncClient async, S3Client sync, com.google.common.base.Function<Set<BucketMetadata>,org.jclouds.blobstore.domain.PageSet<? extends org.jclouds.blobstore.domain.StorageMetadata>> convertBucketsToStorageMetadata, ContainerToBucketListOptions container2BucketListOptions, BucketToResourceList bucket2ResourceList, ObjectToBlob object2Blob, org.jclouds.blobstore.functions.BlobToHttpGetOptions blob2ObjectGetOptions, BlobToObject blob2Object, ObjectToBlobMetadata object2BlobMd, javax.inject.Provider<org.jclouds.blobstore.strategy.internal.FetchBlobMetadata> fetchBlobMetadataProvider, com.google.common.cache.LoadingCache<String,AccessControlList> bucketAcls) Deprecated.

Method Summary

com.google.common.util.concurrent.ListenableFuture<Boolean>	blobExists(String container, String key) Deprecated. This implementation invokes S3AsyncClient.objectExists(java.lang.String, java.lang.String)
com.google.common.util.concurrent.ListenableFuture<org.jclouds.blobstore.domain.BlobMetadata>	blobMetadata(String container, String key) Deprecated. This implementation invokes S3AsyncClient.headObject(java.lang.String, java.lang.String)
com.google.common.util.concurrent.ListenableFuture<Boolean>	containerExists(String container) Deprecated. This implementation invokes S3AsyncClient.bucketExists(java.lang.String)
com.google.common.util.concurrent.ListenableFuture<Boolean>	createContainerInLocation(org.jclouds.domain.Location location, String container) Deprecated. This implementation invokes S3AsyncClient.putBucketInRegion(java.lang.String, java.lang.String, org.jclouds.s3.options.PutBucketOptions...)
com.google.common.util.concurrent.ListenableFuture<Boolean>	createContainerInLocation(org.jclouds.domain.Location location, String container, org.jclouds.blobstore.options.CreateContainerOptions options) Deprecated.
protected boolean	deleteAndVerifyContainerGone(String container) Deprecated. This implementation invokes S3Utils.deleteAndVerifyContainerGone(org.jclouds.s3.S3Client, java.lang.String)
com.google.common.util.concurrent.ListenableFuture<org.jclouds.blobstore.domain.Blob>	getBlob(String container, String key, org.jclouds.blobstore.options.GetOptions options) Deprecated. This implementation invokes S3AsyncClient.getObject(java.lang.String, java.lang.String, org.jclouds.http.options.GetOptions...)
com.google.common.util.concurrent.ListenableFuture<org.jclouds.blobstore.domain.PageSet<? extends org.jclouds.blobstore.domain.StorageMetadata>>	list() Deprecated. This implementation invokes S3AsyncClient.listOwnedBuckets()
com.google.common.util.concurrent.ListenableFuture<org.jclouds.blobstore.domain.PageSet<? extends org.jclouds.blobstore.domain.StorageMetadata>>	list(String container, org.jclouds.blobstore.options.ListContainerOptions options) Deprecated. This implementation invokes S3AsyncClient.listBucket(java.lang.String, org.jclouds.s3.options.ListBucketOptions...)
com.google.common.util.concurrent.ListenableFuture<String>	putBlob(String container, org.jclouds.blobstore.domain.Blob blob) Deprecated. This implementation invokes S3AsyncClient.putObject(java.lang.String, org.jclouds.s3.domain.S3Object, org.jclouds.s3.options.PutObjectOptions...)
com.google.common.util.concurrent.ListenableFuture<String>	putBlob(String container, org.jclouds.blobstore.domain.Blob blob, org.jclouds.blobstore.options.PutOptions overrides) Deprecated.
com.google.common.util.concurrent.ListenableFuture<Void>	removeBlob(String container, String key) Deprecated. This implementation invokes S3AsyncClient.deleteObject(java.lang.String, java.lang.String)

Methods inherited from class org.jclouds.blobstore.internal.BaseAsyncBlobStore

blobBuilder, clearContainer, clearContainer, countBlobs, countBlobs, createDirectory, deleteContainer, deleteContainerIfEmpty, deleteDirectory, deletePathAndEnsureGone, directoryExists, getBlob, getContext, list, listAssignableLocations

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

S3AsyncBlobStore

@Inject
protected S3AsyncBlobStore(org.jclouds.blobstore.BlobStoreContext context,
                                  org.jclouds.blobstore.util.BlobUtils blobUtils,
                                  @Named(value="jclouds.user-threads")
                                  com.google.common.util.concurrent.ListeningExecutorService userExecutor,
                                  com.google.common.base.Supplier<org.jclouds.domain.Location> defaultLocation,
                                  com.google.common.base.Supplier<Set<? extends org.jclouds.domain.Location>> locations,
                                  S3AsyncClient async,
                                  S3Client sync,
                                  com.google.common.base.Function<Set<BucketMetadata>,org.jclouds.blobstore.domain.PageSet<? extends org.jclouds.blobstore.domain.StorageMetadata>> convertBucketsToStorageMetadata,
                                  ContainerToBucketListOptions container2BucketListOptions,
                                  BucketToResourceList bucket2ResourceList,
                                  ObjectToBlob object2Blob,
                                  org.jclouds.blobstore.functions.BlobToHttpGetOptions blob2ObjectGetOptions,
                                  BlobToObject blob2Object,
                                  ObjectToBlobMetadata object2BlobMd,
                                  javax.inject.Provider<org.jclouds.blobstore.strategy.internal.FetchBlobMetadata> fetchBlobMetadataProvider,
                                  com.google.common.cache.LoadingCache<String,AccessControlList> bucketAcls)

Deprecated.

Method Detail

list

public com.google.common.util.concurrent.ListenableFuture<org.jclouds.blobstore.domain.PageSet<? extends org.jclouds.blobstore.domain.StorageMetadata>> list()

Deprecated.

This implementation invokes S3AsyncClient.listOwnedBuckets()

containerExists

public com.google.common.util.concurrent.ListenableFuture<Boolean> containerExists(String container)

Deprecated.

This implementation invokes S3AsyncClient.bucketExists(java.lang.String)

Parameters:

container - bucket name

createContainerInLocation

public com.google.common.util.concurrent.ListenableFuture<Boolean> createContainerInLocation(org.jclouds.domain.Location location,
                                                                                             String container)

Deprecated.

This implementation invokes S3AsyncClient.putBucketInRegion(java.lang.String, java.lang.String, org.jclouds.s3.options.PutBucketOptions...)

Parameters:

location - corresponds to Region

container - bucket name

list

public com.google.common.util.concurrent.ListenableFuture<org.jclouds.blobstore.domain.PageSet<? extends org.jclouds.blobstore.domain.StorageMetadata>> list(String container,
                                                                                                                                                             org.jclouds.blobstore.options.ListContainerOptions options)

Deprecated.

This implementation invokes S3AsyncClient.listBucket(java.lang.String, org.jclouds.s3.options.ListBucketOptions...)

Parameters:

container - bucket name

deleteAndVerifyContainerGone

protected boolean deleteAndVerifyContainerGone(String container)

Deprecated.

This implementation invokes S3Utils.deleteAndVerifyContainerGone(org.jclouds.s3.S3Client, java.lang.String)

Specified by:

deleteAndVerifyContainerGone in class org.jclouds.blobstore.internal.BaseAsyncBlobStore

blobExists

public com.google.common.util.concurrent.ListenableFuture<Boolean> blobExists(String container,
                                                                              String key)

Deprecated.

This implementation invokes S3AsyncClient.objectExists(java.lang.String, java.lang.String)

Parameters:

container - bucket name

key - object key

blobMetadata

public com.google.common.util.concurrent.ListenableFuture<org.jclouds.blobstore.domain.BlobMetadata> blobMetadata(String container,
                                                                                                                  String key)

Deprecated.

This implementation invokes S3AsyncClient.headObject(java.lang.String, java.lang.String)

Parameters:

container - bucket name

key - object key

getBlob

public com.google.common.util.concurrent.ListenableFuture<org.jclouds.blobstore.domain.Blob> getBlob(String container,
                                                                                                     String key,
                                                                                                     org.jclouds.blobstore.options.GetOptions options)

Deprecated.

This implementation invokes S3AsyncClient.getObject(java.lang.String, java.lang.String, org.jclouds.http.options.GetOptions...)

Parameters:

container - bucket name

key - object key

putBlob

public com.google.common.util.concurrent.ListenableFuture<String> putBlob(String container,
                                                                          org.jclouds.blobstore.domain.Blob blob)

Deprecated.

This implementation invokes S3AsyncClient.putObject(java.lang.String, org.jclouds.s3.domain.S3Object, org.jclouds.s3.options.PutObjectOptions...)

Parameters:

container - bucket name

blob - object

putBlob

public com.google.common.util.concurrent.ListenableFuture<String> putBlob(String container,
                                                                          org.jclouds.blobstore.domain.Blob blob,
                                                                          org.jclouds.blobstore.options.PutOptions overrides)

Deprecated.

removeBlob

public com.google.common.util.concurrent.ListenableFuture<Void> removeBlob(String container,
                                                                           String key)

Deprecated.

This implementation invokes S3AsyncClient.deleteObject(java.lang.String, java.lang.String)

Parameters:

container - bucket name

key - object key

createContainerInLocation

public com.google.common.util.concurrent.ListenableFuture<Boolean> createContainerInLocation(org.jclouds.domain.Location location,
                                                                                             String container,
                                                                                             org.jclouds.blobstore.options.CreateContainerOptions options)

Deprecated.