com.spectralogic.ds3client.helpers

Class ResponseBuilders

java.lang.Object

com.spectralogic.ds3client.helpers.ResponseBuilders

public final class ResponseBuilders
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
ResponseBuilders()

Method Summary

Modifier and Type	Method and Description
static AllocateJobChunkSpectraS3Response	allocated(Objects chunk)
static GetJobChunksReadyForClientProcessingSpectraS3Response	availableJobChunks(MasterObjectList masterObjectList)
static JobNode	basicNode(java.util.UUID nodeId, java.lang.String endpoint)
static GetBulkJobSpectraS3Response	bulkGetResponse(MasterObjectList masterObjectList)
static PutBulkJobSpectraS3Response	bulkPutResponse(MasterObjectList masterObjectList)
static java.nio.channels.SeekableByteChannel	channelWithContents(java.lang.String contents)
static Objects	chunk(int chunkNumber, java.util.UUID chunkId, java.util.UUID nodeId, BulkObject... chunkList)
static <any>	getObjectAnswer(java.lang.String result)
static HeadBucketResponse	headBucket(HeadBucketResponse.Status status)
static MasterObjectList	jobResponse(java.util.UUID jobId, java.lang.String bucketName, JobRequestType requestType, long originalSizeInBytes, long cachedSizeInBytes, long completedSizeInBytes, JobChunkClientProcessingOrderGuarantee chunkClientProcessingOrderGuarantee, Priority priority, java.lang.String startDate, java.util.UUID userId, java.lang.String userName, java.util.List<JobNode> nodes, java.util.List<Objects> objects)
static ModifyJobSpectraS3Response	modifyJobResponse(MasterObjectList masterObjectList)
static JobNode	node(java.util.UUID nodeId, java.lang.String endpoint, int httpPort, int httpsPort)
static BulkObject	object(java.lang.String name, long offset, long length, boolean inCache)
static AllocateJobChunkSpectraS3Response	retryAllocateLater(int retryAfterInSeconds)
static GetJobChunksReadyForClientProcessingSpectraS3Response	retryGetAvailableAfter(int retryAfterInSeconds)

Methods inherited from class java.lang.Object

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

Constructor Detail

ResponseBuilders

public ResponseBuilders()

Method Detail

bulkGetResponse

public static GetBulkJobSpectraS3Response bulkGetResponse(MasterObjectList masterObjectList)

bulkPutResponse

public static PutBulkJobSpectraS3Response bulkPutResponse(MasterObjectList masterObjectList)

modifyJobResponse

public static ModifyJobSpectraS3Response modifyJobResponse(MasterObjectList masterObjectList)

availableJobChunks

public static GetJobChunksReadyForClientProcessingSpectraS3Response availableJobChunks(MasterObjectList masterObjectList)

retryGetAvailableAfter

public static GetJobChunksReadyForClientProcessingSpectraS3Response retryGetAvailableAfter(int retryAfterInSeconds)

allocated

public static AllocateJobChunkSpectraS3Response allocated(Objects chunk)

retryAllocateLater

public static AllocateJobChunkSpectraS3Response retryAllocateLater(int retryAfterInSeconds)

jobResponse

public static MasterObjectList jobResponse(java.util.UUID jobId,
                                           java.lang.String bucketName,
                                           JobRequestType requestType,
                                           long originalSizeInBytes,
                                           long cachedSizeInBytes,
                                           long completedSizeInBytes,
                                           JobChunkClientProcessingOrderGuarantee chunkClientProcessingOrderGuarantee,
                                           Priority priority,
                                           java.lang.String startDate,
                                           java.util.UUID userId,
                                           java.lang.String userName,
                                           java.util.List<JobNode> nodes,
                                           java.util.List<Objects> objects)
                                    throws java.text.ParseException

Throws:

java.text.ParseException

basicNode

public static JobNode basicNode(java.util.UUID nodeId,
                                java.lang.String endpoint)

node

public static JobNode node(java.util.UUID nodeId,
                           java.lang.String endpoint,
                           int httpPort,
                           int httpsPort)

chunk

public static Objects chunk(int chunkNumber,
                            java.util.UUID chunkId,
                            java.util.UUID nodeId,
                            BulkObject... chunkList)

object

public static BulkObject object(java.lang.String name,
                                long offset,
                                long length,
                                boolean inCache)

getObjectAnswer

public static <any> getObjectAnswer(java.lang.String result)

channelWithContents

public static java.nio.channels.SeekableByteChannel channelWithContents(java.lang.String contents)

headBucket

public static HeadBucketResponse headBucket(HeadBucketResponse.Status status)