com.spectralogic.ds3client.helpers

Class Ds3ClientHelpers

java.lang.Object

com.spectralogic.ds3client.helpers.Ds3ClientHelpers

public abstract class Ds3ClientHelpers
extends java.lang.Object

A wrapper around the Ds3Client which automates common tasks.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	Ds3ClientHelpers.Job Represents a bulk job operation.
static interface	Ds3ClientHelpers.ObjectChannelBuilder

Constructor Summary

Constructors

Constructor and Description
Ds3ClientHelpers()

Method Summary

Methods

Modifier and Type	Method and Description
abstract void	ensureBucketExists(java.lang.String bucket) Ensures that a bucket exists.
abstract java.lang.Iterable<Contents>	listObjects(java.lang.String bucket) Returns information about all of the objects in the bucket, regardless of how many objects the bucket contains.
abstract java.lang.Iterable<Contents>	listObjects(java.lang.String bucket, java.lang.String keyPrefix) Returns information about all of the objects in the bucket, regardless of how many objects the bucket contains.
abstract java.lang.Iterable<Contents>	listObjects(java.lang.String bucket, java.lang.String keyPrefix, int maxKeys) Returns information about all of the objects in the bucket, regardless of how many objects the bucket contains.
abstract java.lang.Iterable<Ds3Object>	listObjectsForDirectory(java.nio.file.Path directory) Returns an object list with which you can call startWriteJob based on the files in a directory.
abstract Ds3ClientHelpers.Job	recoverReadJob(java.util.UUID jobId) Queries job information based on job id and returns a WriteJob that can resume the job.
abstract Ds3ClientHelpers.Job	recoverWriteJob(java.util.UUID jobId) Queries job information based on job id and returns a ReadJob that can resume the job.
abstract Ds3ClientHelpers.Job	startReadAllJob(java.lang.String bucket) Performs a bulk get job creation request for all of the objects in the given bucket and returns an ReadJob.
abstract Ds3ClientHelpers.Job	startReadAllJob(java.lang.String bucket, ReadJobOptions options) Performs a bulk get job creation request for all of the objects in the given bucket and returns an ReadJob.
abstract Ds3ClientHelpers.Job	startReadJob(java.lang.String bucket, java.lang.Iterable<Ds3Object> objectsToRead) Performs a bulk get job creation request and returns an ReadJob.
abstract Ds3ClientHelpers.Job	startReadJob(java.lang.String bucket, java.lang.Iterable<Ds3Object> objectsToRead, ReadJobOptions options) Performs a bulk get job creation request and returns an ReadJob.
abstract Ds3ClientHelpers.Job	startWriteJob(java.lang.String bucket, java.lang.Iterable<Ds3Object> objectsToWrite) Performs a bulk put job creation request and returns an WriteJob.
abstract Ds3ClientHelpers.Job	startWriteJob(java.lang.String bucket, java.lang.Iterable<Ds3Object> objectsToWrite, WriteJobOptions options) Performs a bulk put job creation request and returns an WriteJob.
static Ds3ClientHelpers	wrap(Ds3Client client) Wraps the given Ds3ClientImpl with helper methods.

Methods inherited from class java.lang.Object

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

Constructor Detail

Ds3ClientHelpers

public Ds3ClientHelpers()

Method Detail

wrap

public static Ds3ClientHelpers wrap(Ds3Client client)

Wraps the given Ds3ClientImpl with helper methods.

startWriteJob

public abstract Ds3ClientHelpers.Job startWriteJob(java.lang.String bucket,
                                 java.lang.Iterable<Ds3Object> objectsToWrite)
                                            throws java.security.SignatureException,
                                                   java.io.IOException,
                                                   XmlProcessingException

Performs a bulk put job creation request and returns an WriteJob. See WriteJob for information on how to write the objects for the job.

Throws:

java.security.SignatureException

java.io.IOException

XmlProcessingException

startWriteJob

public abstract Ds3ClientHelpers.Job startWriteJob(java.lang.String bucket,
                                 java.lang.Iterable<Ds3Object> objectsToWrite,
                                 WriteJobOptions options)
                                            throws java.security.SignatureException,
                                                   java.io.IOException,
                                                   XmlProcessingException

Performs a bulk put job creation request and returns an WriteJob. See WriteJob for information on how to write the objects for the job.

Throws:

java.security.SignatureException

java.io.IOException

XmlProcessingException

startReadJob

public abstract Ds3ClientHelpers.Job startReadJob(java.lang.String bucket,
                                java.lang.Iterable<Ds3Object> objectsToRead)
                                           throws java.security.SignatureException,
                                                  java.io.IOException,
                                                  XmlProcessingException

Performs a bulk get job creation request and returns an ReadJob. See ReadJob for information on how to read the objects for the job.

Throws:

java.security.SignatureException

java.io.IOException

XmlProcessingException

startReadJob

public abstract Ds3ClientHelpers.Job startReadJob(java.lang.String bucket,
                                java.lang.Iterable<Ds3Object> objectsToRead,
                                ReadJobOptions options)
                                           throws java.security.SignatureException,
                                                  java.io.IOException,
                                                  XmlProcessingException

Performs a bulk get job creation request and returns an ReadJob. See ReadJob for information on how to read the objects for the job.

Throws:

java.security.SignatureException

java.io.IOException

XmlProcessingException

startReadAllJob

public abstract Ds3ClientHelpers.Job startReadAllJob(java.lang.String bucket)
                                              throws java.security.SignatureException,
                                                     java.io.IOException,
                                                     XmlProcessingException

Performs a bulk get job creation request for all of the objects in the given bucket and returns an ReadJob.

Throws:

java.security.SignatureException

java.io.IOException

XmlProcessingException

startReadAllJob

public abstract Ds3ClientHelpers.Job startReadAllJob(java.lang.String bucket,
                                   ReadJobOptions options)
                                              throws java.security.SignatureException,
                                                     java.io.IOException,
                                                     XmlProcessingException

Performs a bulk get job creation request for all of the objects in the given bucket and returns an ReadJob.

Throws:

java.security.SignatureException

java.io.IOException

XmlProcessingException

recoverWriteJob

public abstract Ds3ClientHelpers.Job recoverWriteJob(java.util.UUID jobId)
                                              throws java.security.SignatureException,
                                                     java.io.IOException,
                                                     XmlProcessingException,
                                                     JobRecoveryException

Queries job information based on job id and returns a ReadJob that can resume the job.

Throws:

java.security.SignatureException

java.io.IOException

XmlProcessingException

JobRecoveryException

recoverReadJob

public abstract Ds3ClientHelpers.Job recoverReadJob(java.util.UUID jobId)
                                             throws java.security.SignatureException,
                                                    java.io.IOException,
                                                    XmlProcessingException,
                                                    JobRecoveryException

Queries job information based on job id and returns a WriteJob that can resume the job.

Throws:

java.security.SignatureException

java.io.IOException

XmlProcessingException

JobRecoveryException

ensureBucketExists

public abstract void ensureBucketExists(java.lang.String bucket)
                                 throws java.io.IOException,
                                        java.security.SignatureException

Ensures that a bucket exists. The the bucket does not exist, it will be created.

Parameters:

bucket - The name of the bucket to check that it exists.

Throws:

java.io.IOException

java.security.SignatureException

listObjects

public abstract java.lang.Iterable<Contents> listObjects(java.lang.String bucket)
                                                  throws java.security.SignatureException,
                                                         java.io.IOException

Returns information about all of the objects in the bucket, regardless of how many objects the bucket contains.

Throws:

java.security.SignatureException

java.io.IOException

listObjects

public abstract java.lang.Iterable<Contents> listObjects(java.lang.String bucket,
                                       java.lang.String keyPrefix)
                                                  throws java.security.SignatureException,
                                                         java.io.IOException

Returns information about all of the objects in the bucket, regardless of how many objects the bucket contains.

Throws:

java.security.SignatureException

java.io.IOException

listObjects

public abstract java.lang.Iterable<Contents> listObjects(java.lang.String bucket,
                                       java.lang.String keyPrefix,
                                       int maxKeys)
                                                  throws java.security.SignatureException,
                                                         java.io.IOException

Returns information about all of the objects in the bucket, regardless of how many objects the bucket contains.

Throws:

java.security.SignatureException

java.io.IOException

listObjectsForDirectory

public abstract java.lang.Iterable<Ds3Object> listObjectsForDirectory(java.nio.file.Path directory)
                                                               throws java.io.IOException

Returns an object list with which you can call startWriteJob based on the files in a directory. This method traverses the directory recursively.

Throws:

java.io.IOException