@Singleton public class S3AsyncBlobStore extends BaseAsyncBlobStore
blobUtils, context, defaultLocation, locations, service
Modifier | Constructor and Description |
---|---|
protected |
S3AsyncBlobStore(BlobStoreContext context,
BlobUtils blobUtils,
ExecutorService service,
com.google.common.base.Supplier<Location> defaultLocation,
com.google.common.base.Supplier<Set<? extends Location>> locations,
S3AsyncClient async,
S3Client sync,
BucketToResourceMetadata bucket2ResourceMd,
ContainerToBucketListOptions container2BucketListOptions,
BucketToResourceList bucket2ResourceList,
ObjectToBlob object2Blob,
BlobToHttpGetOptions blob2ObjectGetOptions,
BlobToObject blob2Object,
ObjectToBlobMetadata object2BlobMd,
Provider<FetchBlobMetadata> fetchBlobMetadataProvider,
com.google.common.cache.LoadingCache<String,AccessControlList> bucketAcls) |
Modifier and Type | Method and Description |
---|---|
com.google.common.util.concurrent.ListenableFuture<Boolean> |
blobExists(String container,
String key)
This implementation invokes
S3AsyncClient.objectExists(java.lang.String, java.lang.String) |
com.google.common.util.concurrent.ListenableFuture<BlobMetadata> |
blobMetadata(String container,
String key)
This implementation invokes
S3AsyncClient.headObject(java.lang.String, java.lang.String) |
com.google.common.util.concurrent.ListenableFuture<Boolean> |
containerExists(String container)
This implementation invokes
S3AsyncClient.bucketExists(java.lang.String) |
com.google.common.util.concurrent.ListenableFuture<Boolean> |
createContainerInLocation(Location location,
String container)
This implementation invokes
S3AsyncClient.putBucketInRegion(java.lang.String, java.lang.String, org.jclouds.s3.options.PutBucketOptions...) |
com.google.common.util.concurrent.ListenableFuture<Boolean> |
createContainerInLocation(Location location,
String container,
CreateContainerOptions options) |
protected boolean |
deleteAndVerifyContainerGone(String container)
This implementation invokes
S3Utils.deleteAndVerifyContainerGone(org.jclouds.s3.S3Client, java.lang.String) |
com.google.common.util.concurrent.ListenableFuture<Blob> |
getBlob(String container,
String key,
GetOptions options)
This implementation invokes
S3AsyncClient.getObject(java.lang.String, java.lang.String, org.jclouds.http.options.GetOptions...) |
com.google.common.util.concurrent.ListenableFuture<PageSet<? extends StorageMetadata>> |
list()
This implementation invokes
S3AsyncClient.listOwnedBuckets() |
com.google.common.util.concurrent.ListenableFuture<PageSet<? extends StorageMetadata>> |
list(String container,
ListContainerOptions options)
This implementation invokes
S3AsyncClient.listBucket(java.lang.String, org.jclouds.s3.options.ListBucketOptions...) |
com.google.common.util.concurrent.ListenableFuture<String> |
putBlob(String container,
Blob blob)
|
com.google.common.util.concurrent.ListenableFuture<String> |
putBlob(String container,
Blob blob,
PutOptions overrides) |
com.google.common.util.concurrent.ListenableFuture<Void> |
removeBlob(String container,
String key)
This implementation invokes
S3AsyncClient.deleteObject(java.lang.String, java.lang.String) |
blobBuilder, clearContainer, clearContainer, countBlobs, countBlobs, createDirectory, deleteAndEnsurePathGone, deleteContainer, deleteDirectory, directoryExists, getBlob, getContext, list, listAssignableLocations
@Inject protected S3AsyncBlobStore(BlobStoreContext context, BlobUtils blobUtils, @Named(value="jclouds.user-threads") ExecutorService service, com.google.common.base.Supplier<Location> defaultLocation, com.google.common.base.Supplier<Set<? extends Location>> locations, S3AsyncClient async, S3Client sync, BucketToResourceMetadata bucket2ResourceMd, ContainerToBucketListOptions container2BucketListOptions, BucketToResourceList bucket2ResourceList, ObjectToBlob object2Blob, BlobToHttpGetOptions blob2ObjectGetOptions, BlobToObject blob2Object, ObjectToBlobMetadata object2BlobMd, Provider<FetchBlobMetadata> fetchBlobMetadataProvider, com.google.common.cache.LoadingCache<String,AccessControlList> bucketAcls)
public com.google.common.util.concurrent.ListenableFuture<PageSet<? extends StorageMetadata>> list()
S3AsyncClient.listOwnedBuckets()
BlobStore.list()
public com.google.common.util.concurrent.ListenableFuture<Boolean> containerExists(String container)
S3AsyncClient.bucketExists(java.lang.String)
container
- bucket nameBlobStore.containerExists(java.lang.String)
public com.google.common.util.concurrent.ListenableFuture<Boolean> createContainerInLocation(Location location, String container)
S3AsyncClient.putBucketInRegion(java.lang.String, java.lang.String, org.jclouds.s3.options.PutBucketOptions...)
location
- corresponds to Regioncontainer
- bucket nameBlobStore.createContainerInLocation(Location, String)
public com.google.common.util.concurrent.ListenableFuture<PageSet<? extends StorageMetadata>> list(String container, ListContainerOptions options)
S3AsyncClient.listBucket(java.lang.String, org.jclouds.s3.options.ListBucketOptions...)
container
- bucket nameBlobStore.list(String, ListContainerOptions)
protected boolean deleteAndVerifyContainerGone(String container)
S3Utils.deleteAndVerifyContainerGone(org.jclouds.s3.S3Client, java.lang.String)
deleteAndVerifyContainerGone
in class BaseAsyncBlobStore
public com.google.common.util.concurrent.ListenableFuture<Boolean> blobExists(String container, String key)
S3AsyncClient.objectExists(java.lang.String, java.lang.String)
container
- bucket namekey
- object keyBlobStore.blobExists(java.lang.String, java.lang.String)
public com.google.common.util.concurrent.ListenableFuture<BlobMetadata> blobMetadata(String container, String key)
S3AsyncClient.headObject(java.lang.String, java.lang.String)
container
- bucket namekey
- object keyBlobStore.blobMetadata(java.lang.String, java.lang.String)
public com.google.common.util.concurrent.ListenableFuture<Blob> getBlob(String container, String key, GetOptions options)
S3AsyncClient.getObject(java.lang.String, java.lang.String, org.jclouds.http.options.GetOptions...)
container
- bucket namekey
- object keyBlobStore.getBlob(String, String, GetOptions)
public com.google.common.util.concurrent.ListenableFuture<String> putBlob(String container, Blob blob)
S3AsyncClient.putObject(java.lang.String, org.jclouds.s3.domain.S3Object, org.jclouds.s3.options.PutObjectOptions...)
container
- bucket nameblob
- objectBlobStore.putBlob(String,Blob)
public com.google.common.util.concurrent.ListenableFuture<String> putBlob(String container, Blob blob, PutOptions overrides)
public com.google.common.util.concurrent.ListenableFuture<Void> removeBlob(String container, String key)
S3AsyncClient.deleteObject(java.lang.String, java.lang.String)
container
- bucket namekey
- object keyBlobStore.removeBlob(java.lang.String, java.lang.String)
public com.google.common.util.concurrent.ListenableFuture<Boolean> createContainerInLocation(Location location, String container, CreateContainerOptions options)
Copyright © 2009-2012 jclouds. All Rights Reserved.