com.amazonaws.services.s3

Class UploadObjectObserver

java.lang.Object

com.amazonaws.services.s3.UploadObjectObserver

public class UploadObjectObserver
extends Object

An observer that gets notified of ciphertext file creation for the purpose of pipelined parallel multi-part uploads of encrypted data to S3. This observer is responsible for uploading the files to S3 via multi-part upload, including the multi-part upload initiation, individual part uploads, and multi-part upload completion.

This observer is designed for extension so that custom behavior can be provided. A customer observer can be configured via UploadObjectRequest.withUploadObjectObserver(UploadObjectObserver).

See Also:

UploadObjectRequest

Constructor Summary

Constructors

Constructor and Description
UploadObjectObserver()

Method Summary

Modifier and Type	Method and Description
List<Future<UploadPartResult>>	getFutures()
UploadObjectObserver	init(UploadObjectRequest req, S3DirectSpi s3direct, AmazonS3 s3, ExecutorService es) Used to initialized this observer.
void	onAbort() Notified from AmazonS3EncryptionClient.uploadObject(UploadObjectRequest) when failed to upload any part.
CompleteMultipartUploadResult	onCompletion(List<PartETag> partETags) Notified from AmazonS3EncryptionClient.uploadObject(UploadObjectRequest) when all parts have been successfully uploaded to S3.
void	onPartCreate(PartCreationEvent event) Notified from MultiFileOutputStream.fos() when a part ready for upload has been successfully created on disk.
String	onUploadInitiation(UploadObjectRequest req) Notified from AmazonS3EncryptionClient.uploadObject(UploadObjectRequest) to initiate a multi-part upload.

Methods inherited from class java.lang.Object

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

Constructor Detail

UploadObjectObserver

public UploadObjectObserver()

Method Detail

init

public UploadObjectObserver init(UploadObjectRequest req,
                                 S3DirectSpi s3direct,
                                 AmazonS3 s3,
                                 ExecutorService es)

Used to initialized this observer. This method is an SPI (service provider interface) that is called from AmazonS3EncryptionClient.

Implementation of this method should never block.

Parameters:

req - the upload object request

s3direct - used to perform non-encrypting s3 operation via the current instance of s3 (encryption) client

s3 - the current instance of s3 (encryption) client

es - the executor service to be used for concurrent uploads

Returns:

this object

onUploadInitiation

public String onUploadInitiation(UploadObjectRequest req)

Notified from AmazonS3EncryptionClient.uploadObject(UploadObjectRequest) to initiate a multi-part upload.

Parameters:

req - the upload object request

Returns:

the initiated multi-part uploadId

onPartCreate

public void onPartCreate(PartCreationEvent event)

Notified from MultiFileOutputStream.fos() when a part ready for upload has been successfully created on disk. By default, this method performs the following:

1. calls newUploadPartRequest(PartCreationEvent, File) to create an upload-part request for the newly created ciphertext file
2. call appendUserAgent(AmazonWebServiceRequest, String) to append the necessary user agent string to the request
3. and finally submit a concurrent task, which calls the method uploadPart(UploadPartRequest), to be performed

To enable parallel uploads, implementation of this method should never block.

Parameters:

event - to represent the completion of a ciphertext file creation which is ready for multipart upload to S3.

onCompletion

public CompleteMultipartUploadResult onCompletion(List<PartETag> partETags)

Notified from AmazonS3EncryptionClient.uploadObject(UploadObjectRequest) when all parts have been successfully uploaded to S3. This method is responsible for finishing off the upload by making a complete multi-part upload request to S3 with the given list of etags.

Parameters:

partETags - all the etags returned from S3 for the previous part uploads.

Returns:

the completed multi-part upload result

onAbort

public void onAbort()

Notified from AmazonS3EncryptionClient.uploadObject(UploadObjectRequest) when failed to upload any part. This method is responsible for cancelling ongoing uploads and aborting the multi-part upload request.

getFutures

public List<Future<UploadPartResult>> getFutures()