com.spectralogic.ds3client.helpers.strategy

Class PutStreamerStrategy

java.lang.Object

com.spectralogic.ds3client.helpers.strategy.BlobStrategy

com.spectralogic.ds3client.helpers.strategy.PutStreamerStrategy

public class PutStreamerStrategy
extends BlobStrategy

Nested Class Summary

Nested classes/interfaces inherited from class com.spectralogic.ds3client.helpers.strategy.BlobStrategy

BlobStrategy.ChunkEventHandler

Constructor Summary

Constructors

Constructor and Description
PutStreamerStrategy(Ds3Client client, MasterObjectList masterObjectList, int retryAfter, int retryDelay, BlobStrategy.ChunkEventHandler chunkEventHandler)

Method Summary

Modifier and Type	Method and Description
void	blobCompleted(BulkObject bulkObject)
java.lang.Iterable<JobPart>	getWork()

Methods inherited from class com.spectralogic.ds3client.helpers.strategy.BlobStrategy

computeDelay, getChunkEventHandler, getClient, getMasterObjectList, getRetryAfter, getRetryDelay

Methods inherited from class java.lang.Object

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

Constructor Detail

PutStreamerStrategy

public PutStreamerStrategy(Ds3Client client,
                           MasterObjectList masterObjectList,
                           int retryAfter,
                           int retryDelay,
                           BlobStrategy.ChunkEventHandler chunkEventHandler)

Method Detail

getWork

public java.lang.Iterable<JobPart> getWork()
                                    throws java.io.IOException,
                                           java.lang.InterruptedException

Specified by:

getWork in class BlobStrategy

Throws:

java.io.IOException

java.lang.InterruptedException

blobCompleted

public void blobCompleted(BulkObject bulkObject)

Specified by:

blobCompleted in class BlobStrategy