com.emc.vipr.services.s3

Class ViPRS3Client

java.lang.Object

com.amazonaws.AmazonWebServiceClient

com.amazonaws.services.s3.AmazonS3Client

com.emc.vipr.services.s3.ViPRS3Client

All Implemented Interfaces:

com.amazonaws.services.s3.AmazonS3, ViPRS3

public class ViPRS3Client
extends com.amazonaws.services.s3.AmazonS3Client
implements ViPRS3, com.amazonaws.services.s3.AmazonS3

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ViPRS3Client.GetFileAccessResultUnmarshaller
static class	ViPRS3Client.ListDataNodesResultUnmarshaller

Field Summary

Fields

Modifier and Type	Field and Description
protected static java.lang.String	IP_ADDRESS_PATTERN
protected java.lang.String	namespace

Fields inherited from class com.amazonaws.services.s3.AmazonS3Client

awsCredentialsProvider, clientOptions, errorResponseHandler, S3_SERVICE_NAME, voidResponseHandler

Fields inherited from class com.amazonaws.AmazonWebServiceClient

client, clientConfiguration, endpoint, LOGGING_AWS_REQUEST_METRIC, requestHandler2s, timeOffset

Constructor Summary

Constructors

Constructor and Description
ViPRS3Client(java.lang.String endpoint, com.amazonaws.auth.AWSCredentials awsCredentials) Constructs a new ViPR S3 client using the specified endpoint, AWS credentials to access the EMC ViPR S3 protocol.
ViPRS3Client(java.lang.String endpoint, com.amazonaws.auth.AWSCredentials awsCredentials, com.amazonaws.ClientConfiguration clientConfiguration) Constructs a new ViPR S3 client using the specified endpoint, AWS credentials and client configuration to access the EMC ViPR S3 protocol.
ViPRS3Client(java.lang.String endpoint, com.amazonaws.auth.AWSCredentialsProvider credentialsProvider) Constructs a new ViPR S3 client using the specified endpoint, AWS credentials provider to access the EMC ViPR S3 protocol.
ViPRS3Client(java.lang.String endpoint, com.amazonaws.auth.AWSCredentialsProvider credentialsProvider, com.amazonaws.ClientConfiguration clientConfiguration) Constructs a new ViPR S3 client using the specified endpoint, AWS credentials and client configuration to access the EMC ViPR S3 protocol.
ViPRS3Client(ViPRS3Config viprConfig) Constructs a client with all options specified in a ViPRS3Config instance.

Method Summary

Methods

Modifier and Type	Method and Description
AppendObjectResult	appendObject(AppendObjectRequest request) Appends to an existing object.
AppendObjectResult	appendObject(java.lang.String bucketName, java.lang.String key, java.io.File file) Appends to an existing object.
AppendObjectResult	appendObject(java.lang.String bucketName, java.lang.String key, java.io.InputStream input, com.amazonaws.services.s3.model.ObjectMetadata metadata) Appends to an existing object.
protected java.net.URI	convertToVirtualHostEndpoint(java.lang.String namespace, java.lang.String bucketName) Converts the current endpoint set for this client into virtual addressing style, by placing the name of the specified bucket and namespace before the S3 endpoint.
com.amazonaws.services.s3.model.Bucket	createBucket(ViPRCreateBucketRequest createBucketRequest) ViPR-specific create bucket command.
protected <X extends com.amazonaws.AmazonWebServiceRequest> com.amazonaws.Request<X>	createRequest(java.lang.String bucketName, java.lang.String key, X originalRequest, com.amazonaws.http.HttpMethodName httpMethod) Overridden to specify the namespace via vHost or header.
protected com.amazonaws.auth.Signer	createSigner(com.amazonaws.Request<?> request, java.lang.String bucketName, java.lang.String key) Overridden to provide our own signer, which will include x-emc headers and namespace in the signature.
protected com.amazonaws.services.s3.model.ObjectMetadata	doPut(com.amazonaws.services.s3.model.PutObjectRequest putObjectRequest) Executes a (Subclass of) PutObjectRequest.
BucketFileAccessModeResult	getBucketFileAccessMode(java.lang.String bucketName) Checks the current file access mode on a bucket.
GetFileAccessResult	getFileAccess(GetFileAccessRequest getFileAccessRequest) Gets file access information for the keys in a bucket.
com.netflix.loadbalancer.LoadBalancerStats	getLoadBalancerStats()
java.lang.String	getNamespace() Gets the current ViPR namespace for this client.
protected boolean	isVHostRequest(com.amazonaws.Request<?> request)
protected java.lang.String	join(java.lang.String delimiter, java.util.List<?> values)
protected java.lang.String	join(java.lang.String delimiter, java.lang.Object... values)
ListDataNodesResult	listDataNodes(ListDataNodesRequest listDataNodesRequest) Lists all active ViPR data services nodes (hosts) in the ViPR cluster.
BucketFileAccessModeResult	setBucketFileAccessMode(SetBucketFileAccessModeRequest putAccessModeRequest) Initiates a set file access mode request on a bucket.
void	setNamespace(java.lang.String namespace) Sets the ViPR namespace to use for this client.
UpdateObjectResult	updateObject(java.lang.String bucketName, java.lang.String key, java.io.File file, long startOffset) Updates an existing object.
UpdateObjectResult	updateObject(java.lang.String bucketName, java.lang.String key, java.io.InputStream input, com.amazonaws.services.s3.model.ObjectMetadata metadata, long startOffset) Updates an existing object.
UpdateObjectResult	updateObject(UpdateObjectRequest request) Updates an existing object.

Methods inherited from class com.amazonaws.services.s3.AmazonS3Client

abortMultipartUpload, addAclHeaders, assertParameterNotNull, changeObjectStorageClass, completeMultipartUpload, copyObject, copyObject, copyPart, createBucket, createBucket, createBucket, createBucket, createExecutionContext, deleteBucket, deleteBucket, deleteBucketCrossOriginConfiguration, deleteBucketCrossOriginConfiguration, deleteBucketLifecycleConfiguration, deleteBucketLifecycleConfiguration, deleteBucketPolicy, deleteBucketPolicy, deleteBucketTaggingConfiguration, deleteBucketTaggingConfiguration, deleteBucketWebsiteConfiguration, deleteBucketWebsiteConfiguration, deleteObject, deleteObject, deleteObjects, deleteVersion, deleteVersion, doesBucketExist, fireProgressEvent, generatePresignedUrl, generatePresignedUrl, generatePresignedUrl, getBucketAcl, getBucketAcl, getBucketCrossOriginConfiguration, getBucketLifecycleConfiguration, getBucketLocation, getBucketLocation, getBucketLoggingConfiguration, getBucketNotificationConfiguration, getBucketPolicy, getBucketPolicy, getBucketTaggingConfiguration, getBucketVersioningConfiguration, getBucketWebsiteConfiguration, getBucketWebsiteConfiguration, getCachedResponseMetadata, getObject, getObject, getObject, getObjectAcl, getObjectAcl, getObjectMetadata, getObjectMetadata, getRegion, getResourceUrl, getS3AccountOwner, getUrl, initiateMultipartUpload, invoke, listBuckets, listBuckets, listMultipartUploads, listNextBatchOfObjects, listNextBatchOfVersions, listObjects, listObjects, listObjects, listParts, listVersions, listVersions, listVersions, populateRequestMetadata, presignRequest, putObject, putObject, putObject, restoreObject, restoreObject, setBucketAcl, setBucketAcl, setBucketAcl, setBucketAcl, setBucketAcl, setBucketCrossOriginConfiguration, setBucketCrossOriginConfiguration, setBucketLifecycleConfiguration, setBucketLifecycleConfiguration, setBucketLoggingConfiguration, setBucketNotificationConfiguration, setBucketNotificationConfiguration, setBucketPolicy, setBucketPolicy, setBucketTaggingConfiguration, setBucketTaggingConfiguration, setBucketVersioningConfiguration, setBucketWebsiteConfiguration, setBucketWebsiteConfiguration, setEndpoint, setObjectAcl, setObjectAcl, setObjectAcl, setObjectAcl, setObjectAcl, setObjectAcl, setObjectRedirectLocation, setRegion, setS3ClientOptions, uploadPart

Methods inherited from class com.amazonaws.AmazonWebServiceClient

addRequestHandler, addRequestHandler, configSigner, configSigner, convertToHttpRequest, createExecutionContext, createExecutionContext, endClientExecution, endClientExecution, findRequestMetricCollector, getRequestMetricsCollector, getServiceAbbreviation, getServiceName, getServiceNameIntern, getSigner, getSignerByURI, getSignerRegionOverride, getTimeOffset, isProfilingEnabled, isRequestMetricsEnabled, removeRequestHandler, removeRequestHandler, requestMetricCollector, setConfiguration, setEndpoint, setServiceNameIntern, setSignerRegionOverride, setTimeOffset, shutdown, withTimeOffset

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.amazonaws.services.s3.AmazonS3

abortMultipartUpload, changeObjectStorageClass, completeMultipartUpload, copyObject, copyObject, copyPart, createBucket, createBucket, createBucket, createBucket, deleteBucket, deleteBucket, deleteBucketCrossOriginConfiguration, deleteBucketCrossOriginConfiguration, deleteBucketLifecycleConfiguration, deleteBucketLifecycleConfiguration, deleteBucketPolicy, deleteBucketPolicy, deleteBucketTaggingConfiguration, deleteBucketTaggingConfiguration, deleteBucketWebsiteConfiguration, deleteBucketWebsiteConfiguration, deleteObject, deleteObject, deleteObjects, deleteVersion, deleteVersion, doesBucketExist, generatePresignedUrl, generatePresignedUrl, generatePresignedUrl, getBucketAcl, getBucketAcl, getBucketCrossOriginConfiguration, getBucketLifecycleConfiguration, getBucketLocation, getBucketLocation, getBucketLoggingConfiguration, getBucketNotificationConfiguration, getBucketPolicy, getBucketPolicy, getBucketTaggingConfiguration, getBucketVersioningConfiguration, getBucketWebsiteConfiguration, getBucketWebsiteConfiguration, getCachedResponseMetadata, getObject, getObject, getObject, getObjectAcl, getObjectAcl, getObjectMetadata, getObjectMetadata, getS3AccountOwner, initiateMultipartUpload, listBuckets, listBuckets, listMultipartUploads, listNextBatchOfObjects, listNextBatchOfVersions, listObjects, listObjects, listObjects, listParts, listVersions, listVersions, listVersions, putObject, putObject, putObject, restoreObject, restoreObject, setBucketAcl, setBucketAcl, setBucketAcl, setBucketCrossOriginConfiguration, setBucketCrossOriginConfiguration, setBucketLifecycleConfiguration, setBucketLifecycleConfiguration, setBucketLoggingConfiguration, setBucketNotificationConfiguration, setBucketNotificationConfiguration, setBucketPolicy, setBucketPolicy, setBucketTaggingConfiguration, setBucketTaggingConfiguration, setBucketVersioningConfiguration, setBucketWebsiteConfiguration, setBucketWebsiteConfiguration, setEndpoint, setObjectAcl, setObjectAcl, setObjectAcl, setObjectAcl, setObjectRedirectLocation, setRegion, setS3ClientOptions, uploadPart

Field Detail

IP_ADDRESS_PATTERN

protected static final java.lang.String IP_ADDRESS_PATTERN

See Also:

Constant Field Values

namespace

protected java.lang.String namespace

Constructor Detail

ViPRS3Client

public ViPRS3Client(java.lang.String endpoint,
            com.amazonaws.auth.AWSCredentials awsCredentials)

Constructs a new ViPR S3 client using the specified endpoint, AWS credentials to access the EMC ViPR S3 protocol.

Parameters:

endpoint - The ViPR S3 endpoint (i.e. "https://vipr-data.emc.com:9021")

awsCredentials - The AWS credentials to use when making requests with this client.

See Also:

AmazonS3Client.AmazonS3Client(), AmazonS3Client.AmazonS3Client(AWSCredentials)

ViPRS3Client

public ViPRS3Client(java.lang.String endpoint,
            com.amazonaws.auth.AWSCredentials awsCredentials,
            com.amazonaws.ClientConfiguration clientConfiguration)

Constructs a new ViPR S3 client using the specified endpoint, AWS credentials and client configuration to access the EMC ViPR S3 protocol.

Parameters:

endpoint - The ViPR S3 endpoint (i.e. "https://vipr-data.emc.com:9021")

awsCredentials - The AWS credentials to use when making requests with this client.

clientConfiguration - The client configuration options controlling how this client connects (e.g. proxy settings, retry counts, etc).

See Also:

AmazonS3Client.AmazonS3Client(), AmazonS3Client.AmazonS3Client(AWSCredentials, ClientConfiguration)

ViPRS3Client

public ViPRS3Client(java.lang.String endpoint,
            com.amazonaws.auth.AWSCredentialsProvider credentialsProvider)

Constructs a new ViPR S3 client using the specified endpoint, AWS credentials provider to access the EMC ViPR S3 protocol.

Parameters:

endpoint - The ViPR S3 endpoint (i.e. "https://vipr-data.emc.com:9021")

credentialsProvider - The AWS credentials provider which will provide credentials to authenticate requests.

See Also:

AmazonS3Client.AmazonS3Client(AWSCredentialsProvider)

ViPRS3Client

public ViPRS3Client(java.lang.String endpoint,
            com.amazonaws.auth.AWSCredentialsProvider credentialsProvider,
            com.amazonaws.ClientConfiguration clientConfiguration)

Constructs a new ViPR S3 client using the specified endpoint, AWS credentials and client configuration to access the EMC ViPR S3 protocol.

Parameters:

endpoint - The ViPR S3 endpoint (i.e. "https://vipr-data.emc.com:9021")

credentialsProvider - The AWS credentials provider which will provide credentials to authenticate requests.

clientConfiguration - The client configuration options controlling how this client connects (e.g. proxy settings, retry counts, etc).

ViPRS3Client

public ViPRS3Client(ViPRS3Config viprConfig)

Constructs a client with all options specified in a ViPRS3Config instance. Use this constructor to enable the smart client. Older constructors cannot differentiate between load balancing and virtual hosting (which is not supported by the smart client), so this constructor is required for the smart client. Note that when the smart client is enabled, you *cannot* use DNS (virtual host) style buckets or namespaces. Because of the nature of client-side load balancing, you must use path/header style requests.

Method Detail

getLoadBalancerStats

public com.netflix.loadbalancer.LoadBalancerStats getLoadBalancerStats()

updateObject

public UpdateObjectResult updateObject(java.lang.String bucketName,
                              java.lang.String key,
                              java.io.File file,
                              long startOffset)
                                throws com.amazonaws.AmazonClientException

Description copied from interface: ViPRS3

Updates an existing object. The given file will be overlaid on the existing object starting at startOffset.

Specified by:

updateObject in interface ViPRS3

Parameters:

bucketName - The name of an existing bucket, to which you have Permission.Write permission.

key - The key in the bucket to update.

file - The file containing the data to use for the update.

startOffset - The starting offset within the object to apply the update.

Returns:

A UpdateObjectResult containing the data returned from ViPR.

Throws:

com.amazonaws.AmazonClientException - If any errors are encountered in the client while making the request or handling the response.

com.amazonaws.AmazonServiceException - If any errors occurred in on the server while processing the request.

updateObject

public UpdateObjectResult updateObject(java.lang.String bucketName,
                              java.lang.String key,
                              java.io.InputStream input,
                              com.amazonaws.services.s3.model.ObjectMetadata metadata,
                              long startOffset)
                                throws com.amazonaws.AmazonClientException

Description copied from interface: ViPRS3

Updates an existing object. The given stream will be overlaid on the existing object starting at startOffset.

Specified by:

updateObject in interface ViPRS3

Parameters:

bucketName - The name of an existing bucket, to which you have Permission.Write permission.

key - The key in the bucket to update.

input - The input stream containing the data to be uploaded.

metadata - Additional metadata for the upload. Generally, the most important property here is the Content-Length of the input stream. If you do not size the input stream, the client will be forced to buffer the entire stream into memory and size it before uploading. This can lead to OutOfMemoryErrors.

startOffset - The starting offset within the object to apply the update.

Returns:

A UpdateObjectResult containing the data returned from ViPR.

Throws:

com.amazonaws.AmazonClientException - If any errors are encountered in the client while making the request or handling the response.

com.amazonaws.AmazonServiceException - If any errors occurred in on the server while processing the request.

updateObject

public UpdateObjectResult updateObject(UpdateObjectRequest request)
                                throws com.amazonaws.AmazonClientException

Description copied from interface: ViPRS3

Updates an existing object. The given data will be overlaid on the existing object starting at startOffset.

Specified by:

updateObject in interface ViPRS3

Parameters:

request - The configured UpdateObjectRequest to execute.

Returns:

A UpdateObjectResult containing the data returned from ViPR.

Throws:

com.amazonaws.AmazonClientException - If any errors are encountered in the client while making the request or handling the response.

com.amazonaws.AmazonServiceException - If any errors occurred in on the server while processing the request.

appendObject

public AppendObjectResult appendObject(java.lang.String bucketName,
                              java.lang.String key,
                              java.io.File file)
                                throws com.amazonaws.AmazonClientException

Description copied from interface: ViPRS3

Appends to an existing object. The given file will be appended to the end of the object. Note that multiple append requests may be executed concurrently and will be executed serially. Therefore, you must check the actual append offset in the response, see AppendObjectResult.getAppendOffset(). If you must append at an exact location, use updateObject but note in that case with concurrent writes, the last writer will "win".

Specified by:

appendObject in interface ViPRS3

Parameters:

bucketName - The name of an existing bucket, to which you have Permission.Write permission.

key - The key in the bucket to append to.

file - The file containing the data to use for the append.

Returns:

A AppendObjectResult containing the data returned from ViPR including the actual append offset.

Throws:

com.amazonaws.AmazonClientException - If any errors are encountered in the client while making the request or handling the response.

com.amazonaws.AmazonServiceException - If any errors occurred in on the server while processing the request.

appendObject

public AppendObjectResult appendObject(java.lang.String bucketName,
                              java.lang.String key,
                              java.io.InputStream input,
                              com.amazonaws.services.s3.model.ObjectMetadata metadata)
                                throws com.amazonaws.AmazonClientException

Description copied from interface: ViPRS3

Appends to an existing object. The given stream will be appended to the end of the object. Note that multiple append requests may be executed concurrently and will be executed serially. Therefore, you must check the actual append offset in the response, see AppendObjectResult.getAppendOffset(). If you must append at an exact location, use updateObject but note in that case with concurrent writes, the last writer will "win".

Specified by:

appendObject in interface ViPRS3

Parameters:

bucketName - The name of an existing bucket, to which you have Permission.Write permission.

key - The key in the bucket to append to.

input - The input stream containing the data to be appended.

metadata - Additional metadata for the upload. Generally, the most important property here is the Content-Length of the input stream. If you do not size the input stream, the client will be forced to buffer the entire stream into memory and size it before sending. This can lead to OutOfMemoryErrors.

Returns:

A AppendObjectResult containing the data returned from ViPR including the actual append offset.

Throws:

com.amazonaws.AmazonClientException - If any errors are encountered in the client while making the request or handling the response.

com.amazonaws.AmazonServiceException - If any errors occurred in on the server while processing the request.

appendObject

public AppendObjectResult appendObject(AppendObjectRequest request)
                                throws com.amazonaws.AmazonClientException

Description copied from interface: ViPRS3

Appends to an existing object. The given data will be appended to the end of the object. Note that multiple append requests may be executed concurrently and will be executed serially. Therefore, you must check the actual append offset in the response, see AppendObjectResult.getAppendOffset(). If you must append at an exact location, use updateObject but note in that case with concurrent writes, the last writer will "win".

Specified by:

appendObject in interface ViPRS3

Parameters:

request - the configured AppendObjectRequest to execute.

Returns:

A AppendObjectResult containing the data returned from ViPR including the actual append offset.

Throws:

com.amazonaws.AmazonClientException - If any errors are encountered in the client while making the request or handling the response.

com.amazonaws.AmazonServiceException - If any errors occurred in on the server while processing the request.

setBucketFileAccessMode

public BucketFileAccessModeResult setBucketFileAccessMode(SetBucketFileAccessModeRequest putAccessModeRequest)
                                                   throws com.amazonaws.AmazonClientException

Description copied from interface: ViPRS3

Initiates a set file access mode request on a bucket.

Specified by:

setBucketFileAccessMode in interface ViPRS3

Parameters:

putAccessModeRequest - The configured SetBucketFileAccessModeRequest request to execute.

Returns:

A BucketFileAccessModeResult containing the results of the access mode change.

Throws:

com.amazonaws.AmazonClientException - If any errors are encountered in the client while making the request or handling the response.

com.amazonaws.AmazonServiceException - If any errors occurred in on the server while processing the request. Generally, this will happen if the given transition is not valid.

getBucketFileAccessMode

public BucketFileAccessModeResult getBucketFileAccessMode(java.lang.String bucketName)
                                                   throws com.amazonaws.AmazonClientException

Description copied from interface: ViPRS3

Checks the current file access mode on a bucket.

Specified by:

getBucketFileAccessMode in interface ViPRS3

Parameters:

bucketName - the name of the bucket to check.

Returns:

a BucketFileAccessModeResult object containing the current file access mode for the bucket.

Throws:

com.amazonaws.AmazonClientException - If any errors are encountered in the client while making the request or handling the response.

com.amazonaws.AmazonServiceException - If any errors occurred in on the server while processing the request.

getFileAccess

public GetFileAccessResult getFileAccess(GetFileAccessRequest getFileAccessRequest)
                                  throws com.amazonaws.AmazonClientException

Description copied from interface: ViPRS3

Gets file access information for the keys in a bucket. This includes the current state of the key and the location on the file server to access the object. Note that this request is paginated so be sure to check the results to see if there are more results with GetFileAccessResult.isTruncated().

Specified by:

getFileAccess in interface ViPRS3

Parameters:

getFileAccessRequest - the configured GetFileAccessRequest request to execute.

Returns:

a GetFileAccessResult object containing the object file access information.

Throws:

com.amazonaws.AmazonClientException - If any errors are encountered in the client while making the request or handling the response.

com.amazonaws.AmazonServiceException - If any errors occurred in on the server while processing the request.

listDataNodes

public ListDataNodesResult listDataNodes(ListDataNodesRequest listDataNodesRequest)
                                  throws com.amazonaws.AmazonClientException

Description copied from interface: ViPRS3

Lists all active ViPR data services nodes (hosts) in the ViPR cluster. Useful for load balancing.

Specified by:

listDataNodes in interface ViPRS3

Parameters:

listDataNodesRequest - the configured ListDataNodesRequest request to execute.

Returns:

a ListDataNodesResult object containing the list of data services endpoints (hosts).

Throws:

com.amazonaws.AmazonClientException - If any errors are encountered in the client while making the request or handling the response.

com.amazonaws.AmazonServiceException - If any errors occurred in on the server while processing the request.

createRequest

protected <X extends com.amazonaws.AmazonWebServiceRequest> com.amazonaws.Request<X> createRequest(java.lang.String bucketName,
                                                                                       java.lang.String key,
                                                                                       X originalRequest,
                                                                                       com.amazonaws.http.HttpMethodName httpMethod)

Overridden to specify the namespace via vHost or header. This choice is consistent with the bucket convention used in the standard AWS client. vHost buckets implies vHost namespace, otherwise the namespace is specified in a header.

Overrides:

createRequest in class com.amazonaws.services.s3.AmazonS3Client

createSigner

protected com.amazonaws.auth.Signer createSigner(com.amazonaws.Request<?> request,
                                     java.lang.String bucketName,
                                     java.lang.String key)

Overridden to provide our own signer, which will include x-emc headers and namespace in the signature.

Overrides:

createSigner in class com.amazonaws.services.s3.AmazonS3Client

isVHostRequest

protected boolean isVHostRequest(com.amazonaws.Request<?> request)

convertToVirtualHostEndpoint

protected java.net.URI convertToVirtualHostEndpoint(java.lang.String namespace,
                                        java.lang.String bucketName)

Converts the current endpoint set for this client into virtual addressing style, by placing the name of the specified bucket and namespace before the S3 endpoint. Convention is bucket.namespace.root-host (i.e. my-bucket.my-namespace.vipr-s3.my-company.com)

Parameters:

namespace - The namespace to use in the virtual addressing style of the returned URI.

bucketName - The name of the bucket to use in the virtual addressing style of the returned URI.

Returns:

A new URI, creating from the current service endpoint URI and the specified namespace and bucket.

doPut

protected com.amazonaws.services.s3.model.ObjectMetadata doPut(com.amazonaws.services.s3.model.PutObjectRequest putObjectRequest)

Executes a (Subclass of) PutObjectRequest. In particular, we check for subclasses of the UpdateObjectRequest and inject the value of the Range header. This version also returns the raw ObjectMetadata for the response so callers can construct their own result objects.

Parameters:

putObjectRequest - the request to execute

Returns:

an ObjectMetadata containing the response headers.

getNamespace

public java.lang.String getNamespace()

Gets the current ViPR namespace for this client.

Returns:

the ViPR namespace associated with this client

setNamespace

public void setNamespace(java.lang.String namespace)

Sets the ViPR namespace to use for this client.

Parameters:

namespace - the namespace to set

createBucket

public com.amazonaws.services.s3.model.Bucket createBucket(ViPRCreateBucketRequest createBucketRequest)
                                                    throws com.amazonaws.AmazonClientException,
                                                           com.amazonaws.AmazonServiceException

ViPR-specific create bucket command. This version of the command adds some options specific to EMC ViPR, specifically the ability to set the ViPR project ID and Object Virtual Pool ID on the new bucket.

Parameters:

createBucketRequest - the configuration parameters for the new bucket.

Throws:

com.amazonaws.AmazonClientException

com.amazonaws.AmazonServiceException

join

protected java.lang.String join(java.lang.String delimiter,
                    java.util.List<?> values)

join

protected java.lang.String join(java.lang.String delimiter,
                    java.lang.Object... values)