com.spectralogic.ds3client.helpers.strategy

Class BlobStrategy

java.lang.Object

com.spectralogic.ds3client.helpers.strategy.BlobStrategy

Direct Known Subclasses:

GetStreamerStrategy, PutStreamerStrategy

public abstract class BlobStrategy
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	BlobStrategy.ChunkEventHandler

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
abstract void	blobCompleted(BulkObject bulkObject)
protected int	computeDelay(int retryAfterSeconds)
BlobStrategy.ChunkEventHandler	getChunkEventHandler()
Ds3Client	getClient()
MasterObjectList	getMasterObjectList()
int	getRetryAfter()
int	getRetryDelay()
abstract java.lang.Iterable<JobPart>	getWork()

Methods inherited from class java.lang.Object

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

Constructor Detail

BlobStrategy

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

Method Detail

getWork

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

Throws:

java.io.IOException

java.lang.InterruptedException

blobCompleted

public abstract void blobCompleted(BulkObject bulkObject)

getClient

public Ds3Client getClient()

getRetryAfter

public int getRetryAfter()

getRetryDelay

public int getRetryDelay()

getChunkEventHandler

public BlobStrategy.ChunkEventHandler getChunkEventHandler()

getMasterObjectList

public MasterObjectList getMasterObjectList()

computeDelay

protected int computeDelay(int retryAfterSeconds)