public static interface Ds3ClientHelpers.Job
Modifier and Type | Method and Description |
---|---|
void |
attachChecksumListener(ChecksumListener listener)
Attaches an event handler that is invoked when an object checksum is received.
|
void |
attachDataTransferredListener(DataTransferredListener listener)
Attaches an event handler that is invoked when a blob is successfully
transferred to Spectra S3.
|
void |
attachFailureEventListener(FailureEventListener listener)
Attaches an event handler when an object transfer fails
|
void |
attachMetadataReceivedListener(MetadataReceivedListener listener)
Attaches an event handler that is invoked when metadata is received for
an object.
|
void |
attachObjectCompletedListener(ObjectCompletedListener listener)
Attaches an event handler that is invoked when a full object is
successfully transferred to Spectra S3.
|
void |
attachWaitingForChunksListener(WaitingForChunksListener listener)
Attaches an event handler that will be invoked only when there are no chunks available
for processing.
|
java.lang.String |
getBucketName() |
java.util.UUID |
getJobId() |
void |
removeChecksumListener(ChecksumListener listener) |
void |
removeDataTransferredListener(DataTransferredListener listener) |
void |
removeFailureEventListener(FailureEventListener listener) |
void |
removeMetadataReceivedListener(MetadataReceivedListener listener) |
void |
removeObjectCompletedListener(ObjectCompletedListener listener) |
void |
removeWaitingForChunksListener(WaitingForChunksListener listener) |
void |
transfer(Ds3ClientHelpers.ObjectChannelBuilder channelBuilder)
Transfers the files in this job using the given seekable channel creator.
|
Ds3ClientHelpers.Job |
withChecksum(ChecksumFunction checksumFunction)
Register a handler that is invoked when an object checksum is requested for a blob
|
Ds3ClientHelpers.Job |
withMaxParallelRequests(int maxParallelRequests)
Sets the maximum number of requests to execute at a time when fulfilling the job.
|
Ds3ClientHelpers.Job |
withMetadata(Ds3ClientHelpers.MetadataAccess access)
Register a handler that is invoked when metadata is requested for an object
|
java.util.UUID getJobId()
java.lang.String getBucketName()
void attachDataTransferredListener(DataTransferredListener listener)
void removeDataTransferredListener(DataTransferredListener listener)
void attachObjectCompletedListener(ObjectCompletedListener listener)
void removeObjectCompletedListener(ObjectCompletedListener listener)
void attachMetadataReceivedListener(MetadataReceivedListener listener)
void removeMetadataReceivedListener(MetadataReceivedListener listener)
void attachChecksumListener(ChecksumListener listener)
void removeChecksumListener(ChecksumListener listener)
void attachWaitingForChunksListener(WaitingForChunksListener listener)
void removeWaitingForChunksListener(WaitingForChunksListener listener)
void attachFailureEventListener(FailureEventListener listener)
void removeFailureEventListener(FailureEventListener listener)
Ds3ClientHelpers.Job withMaxParallelRequests(int maxParallelRequests)
Ds3ClientHelpers.Job withMetadata(Ds3ClientHelpers.MetadataAccess access)
Ds3ClientHelpers.Job withChecksum(ChecksumFunction checksumFunction)
void transfer(Ds3ClientHelpers.ObjectChannelBuilder channelBuilder) throws java.io.IOException
java.io.IOException