Constructor Detail

• S3BlobStore

  @Inject
  protected S3BlobStore(BlobStoreContext context,
                    BlobUtils blobUtils,
                    com.google.common.base.Supplier<Location> defaultLocation,
                    com.google.common.base.Supplier<Set<? extends Location>> locations,
                    S3Client sync,
                    com.google.common.base.Function<Set<BucketMetadata>,PageSet<? extends StorageMetadata>> convertBucketsToStorageMetadata,
                    ContainerToBucketListOptions container2BucketListOptions,
                    BucketToResourceList bucket2ResourceList,
                    ObjectToBlob object2Blob,
                    BlobToHttpGetOptions blob2ObjectGetOptions,
                    BlobToObject blob2Object,
                    ObjectToBlobMetadata object2BlobMd,
                    javax.inject.Provider<FetchBlobMetadata> fetchBlobMetadataProvider,
                    com.google.common.cache.LoadingCache<String,AccessControlList> bucketAcls)

Method Detail

• list

  public PageSet<? extends StorageMetadata> list()

  This implementation invokes S3Client.listOwnedBuckets()

• containerExists

  public boolean containerExists(String container)

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

  Parameters:

  container - bucket name

• createContainerInLocation

  public boolean createContainerInLocation(Location location,
                                  String container)

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

  Parameters:

  location - corresponds to a Region

  container - bucket name

  Returns:

  true if the container was created, false if it already existed.

• list

  public PageSet<? extends StorageMetadata> list(String container,
                                        ListContainerOptions options)

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

  Parameters:

  container - bucket name

  options - size, recursion, and context of the list

  Returns:

  a list that may be incomplete, depending on whether PageSet#getNextMarker is set

• deletePathAndEnsureGone

  protected void deletePathAndEnsureGone(String path)

  This implementation invokes BaseBlobStore.clearContainer(java.lang.String) then S3Client.deleteBucketIfEmpty(java.lang.String) until it is true.

  Overrides:

  deletePathAndEnsureGone in class BaseBlobStore

• blobExists

  public boolean blobExists(String container,
                   String key)

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

  Parameters:

  container - bucket name

  key - object key

• blobMetadata

  public BlobMetadata blobMetadata(String container,
                          String key)

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

  Parameters:

  container - bucket name

  key - object key

  Returns:

  null if name isn't present or the blob you intended to receive.

• getBlob

  public Blob getBlob(String container,
             String key,
             GetOptions optionsList)

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

  Parameters:

  container - bucket name

  key - object key

  optionsList - byte range or condition options

  Returns:

  the blob you intended to receive or null, if it doesn't exist.

• putBlob

  public String putBlob(String container,
               Blob blob)

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

  Parameters:

  container - bucket name

  blob - object

  Returns:

  etag of the blob you uploaded, possibly null where etags are unsupported

• putBlob

  public String 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...)

  Parameters:

  container - bucket name

  blob - object

  overrides - byte range options

  Returns:

  etag of the blob you uploaded, possibly null where etags are unsupported

• removeBlob

  public void removeBlob(String container,
                String key)

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

  Parameters:

  container - bucket name

  key - object key

• deleteAndVerifyContainerGone

  protected boolean deleteAndVerifyContainerGone(String container)

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

  Specified by:

  deleteAndVerifyContainerGone in class BaseBlobStore

  Parameters:

  container - what to delete

  Returns:

  whether container was deleted

• createContainerInLocation

  public boolean createContainerInLocation(Location location,
                                  String container,
                                  CreateContainerOptions options)

  options - controls default access control

  See Also:

  BlobStore.createContainerInLocation(Location,String)