Package software.amazon.encryption.s3.internal

Class UploadObjectObserver

java.lang.Object

software.amazon.encryption.s3.internal.UploadObjectObserver

public class UploadObjectObserver
extends Object

Constructor Summary

Constructors

Constructor	Description
UploadObjectObserver()

Method Summary

Modifier and Type	Method	Description
List<Future<Map<Integer,software.amazon.awssdk.services.s3.model.UploadPartResponse>>>	futures()
UploadObjectObserver	init(software.amazon.awssdk.services.s3.model.PutObjectRequest req, software.amazon.awssdk.services.s3.S3AsyncClient s3AsyncClient, S3EncryptionClient s3EncryptionClient, ExecutorService es)
protected software.amazon.awssdk.services.s3.model.CreateMultipartUploadRequest	newCreateMultipartUploadRequest(software.amazon.awssdk.services.s3.model.PutObjectRequest request)
protected software.amazon.awssdk.services.s3.model.UploadPartRequest	newUploadPartRequest(PartCreationEvent event)
void	onAbort()
software.amazon.awssdk.services.s3.model.CompleteMultipartUploadResponse	onCompletion(List<software.amazon.awssdk.services.s3.model.CompletedPart> partETags)
void	onPartCreate(PartCreationEvent event)
String	onUploadCreation(software.amazon.awssdk.services.s3.model.PutObjectRequest req)
protected Map<Integer,software.amazon.awssdk.services.s3.model.UploadPartResponse>	uploadPart(software.amazon.awssdk.services.s3.model.UploadPartRequest reqUploadPart, software.amazon.awssdk.core.async.AsyncRequestBody requestBody)

Methods inherited from class java.lang.Object

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

Constructor Detail

UploadObjectObserver

public UploadObjectObserver()

Method Detail

init

public UploadObjectObserver init(software.amazon.awssdk.services.s3.model.PutObjectRequest req,
                                 software.amazon.awssdk.services.s3.S3AsyncClient s3AsyncClient,
                                 S3EncryptionClient s3EncryptionClient,
                                 ExecutorService es)

newCreateMultipartUploadRequest

protected software.amazon.awssdk.services.s3.model.CreateMultipartUploadRequest newCreateMultipartUploadRequest(software.amazon.awssdk.services.s3.model.PutObjectRequest request)

onUploadCreation

public String onUploadCreation(software.amazon.awssdk.services.s3.model.PutObjectRequest req)

onPartCreate

public void onPartCreate(PartCreationEvent event)

onCompletion

public software.amazon.awssdk.services.s3.model.CompleteMultipartUploadResponse onCompletion(List<software.amazon.awssdk.services.s3.model.CompletedPart> partETags)

onAbort

public void onAbort()

newUploadPartRequest

protected software.amazon.awssdk.services.s3.model.UploadPartRequest newUploadPartRequest(PartCreationEvent event)

uploadPart

protected Map<Integer,software.amazon.awssdk.services.s3.model.UploadPartResponse> uploadPart(software.amazon.awssdk.services.s3.model.UploadPartRequest reqUploadPart,
                                                                                                    software.amazon.awssdk.core.async.AsyncRequestBody requestBody)

futures

public List<Future<Map<Integer,software.amazon.awssdk.services.s3.model.UploadPartResponse>>> futures()