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,
                    PayloadSlicer slicer,
                    S3Client sync,
                    com.google.common.base.Function<Set<BucketMetadata>,PageSet<? extends StorageMetadata>> convertBucketsToStorageMetadata,
                    ContainerToBucketListOptions container2BucketListOptions,
                    BucketToResourceList bucket2ResourceList,
                    ObjectToBlob object2Blob,
                    BlobToHttpGetOptions blob2ObjectGetOptions,
                    BlobToObject blob2Object,
                    BlobToObjectMetadata blob2ObjectMetadata,
                    ObjectToBlobMetadata object2BlobMd,
                    javax.inject.Provider<FetchBlobMetadata> fetchBlobMetadataProvider)

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.

• getContainerAccess

  public ContainerAccess getContainerAccess(String container)

• setContainerAccess

  public void setContainerAccess(String container,
                        ContainerAccess access)

• 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

• copyBlob

  public String copyBlob(String fromContainer,
                String fromName,
                String toContainer,
                String toName,
                CopyOptions options)

  Description copied from interface: BlobStore
  Copy blob from one container to another. Some providers implement this more efficiently than corresponding getBlob and putBlob operations. Note: options are currently ignored

  Specified by:

  copyBlob in interface BlobStore

  Overrides:

  copyBlob in class BaseBlobStore

  Returns:

  ETag of new blob

• 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

• removeBlobs

  public void removeBlobs(String container,
                 Iterable<String> keys)

  Description copied from interface: BlobStore
  Deletes multiple Blobs representing the data at location container/name

  Specified by:

  removeBlobs in interface BlobStore

  Overrides:

  removeBlobs in class BaseBlobStore

  Parameters:

  container - container where this exists.

  keys - fully qualified names relative to the container.

• getBlobAccess

  public BlobAccess getBlobAccess(String container,
                         String name)

• setBlobAccess

  public void setBlobAccess(String container,
                   String name,
                   BlobAccess access)

• initiateMultipartUpload

  public MultipartUpload initiateMultipartUpload(String container,
                                        BlobMetadata blobMetadata,
                                        PutOptions overrides)

• abortMultipartUpload

  public void abortMultipartUpload(MultipartUpload mpu)

• completeMultipartUpload

  public String completeMultipartUpload(MultipartUpload mpu,
                               List<MultipartPart> parts)

• uploadMultipartPart

  public MultipartPart uploadMultipartPart(MultipartUpload mpu,
                                  int partNumber,
                                  Payload payload)

• listMultipartUpload

  public List<MultipartPart> listMultipartUpload(MultipartUpload mpu)

• listMultipartUploads

  public List<MultipartUpload> listMultipartUploads(String container)

• getMinimumMultipartPartSize

  public long getMinimumMultipartPartSize()

• getMaximumMultipartPartSize

  public long getMaximumMultipartPartSize()

• getMaximumNumberOfParts

  public int getMaximumNumberOfParts()

• 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)