Package | Description |
---|---|
org.jets3t.apps.synchronize |
Provides the Synchronize application, a console application to synchronize the
local file system with Amazon S3.
|
org.jets3t.service |
Provides the main S3 Service interface, on which all JetS3t REST/HTTP or SOAP
implementations are based, and utilites applicable for all services.
|
org.jets3t.service.acl |
Access Control List (ACL) implementation classes and utilities.
|
org.jets3t.service.acl.gs | |
org.jets3t.service.impl.rest |
Contains utilties of use to any REST/HTTP S3 Service implementations, and specifically to
the HttpClient implementation provided with JetS3t.
|
org.jets3t.service.impl.rest.httpclient |
Provides a REST/HTTP S3 Service implementation based on the
Apache HttpClient library - this
implementation is the most reliable and efficient implementation provided with JetS3t.
|
org.jets3t.service.model |
Provides objects that model entities in S3 such as objects, buckets and owners.
|
org.jets3t.service.multi | |
org.jets3t.service.multi.s3 | |
org.jets3t.service.security |
Provides encryption/decryption facilities and the AWSCredentials credential container object.
|
org.jets3t.service.utils |
General purpose utilities used throughout the JetS3t toolkit and applications.
|
org.jets3t.service.utils.signedurl |
Utility classes used when generated or applying signed URLs.
|
Modifier and Type | Method and Description |
---|---|
protected org.jets3t.apps.synchronize.Synchronize.ComparisonResult |
Synchronize.compareLocalAndRemoteFiles(FileComparerResults mergedDiscrepancyResults,
String bucketName,
String rootObjectPath,
String priorLastKey,
Map<String,String> objectKeyToFilepathMap,
BytesProgressWatcher md5GenerationProgressWatcher) |
Modifier and Type | Class and Description |
---|---|
class |
S3ServiceException
Exception for use by
S3Service s and related utilities. |
Modifier and Type | Method and Description |
---|---|
protected void |
StorageService.sleepOnInternalError(int internalErrorCount,
ServiceException ex)
Sleeps for a period of time based on the number of Internal Server errors a request has
encountered, provided the number of errors does not exceed the value set with the
property
storage-service.internal-error-retry-max . |
Modifier and Type | Method and Description |
---|---|
protected void |
StorageService.assertAuthenticatedConnection(String action)
Throws an exception if this service is anonymous (that is, it was created without
an
ProviderCredentials object representing a user account. |
protected void |
StorageService.assertValidBucket(StorageBucket bucket,
String action)
Throws an exception if a bucket is null or contains a null/empty name.
|
protected void |
StorageService.assertValidObject(StorageObject object,
String action)
Throws an exception if an object is null or contains a null/empty key.
|
protected void |
StorageService.assertValidObject(String key,
String action)
Throws an exception if an object's key name is null or empty.
|
void |
CloudFrontService.authorizeHttpRequest(org.apache.http.client.methods.HttpUriRequest httpMethod,
org.apache.http.protocol.HttpContext context)
Sign the given HTTP method object using the AWS credentials provided
by
CloudFrontService.getAWSCredentials() . |
void |
CloudFrontService.authorizeHttpRequest(org.apache.http.client.methods.HttpUriRequest httpMethod,
org.apache.http.protocol.HttpContext context,
String forceRequestSignatureVersion) |
abstract int |
StorageService.checkBucketStatus(String bucketName)
Find out the status of a bucket with the given name.
|
Map<String,Object> |
StorageService.copyObject(String sourceBucketName,
String sourceObjectKey,
String destinationBucketName,
StorageObject destinationObject,
boolean replaceMetadata)
Copy an object.
|
Map<String,Object> |
StorageService.copyObject(String sourceBucketName,
String sourceObjectKey,
String destinationBucketName,
StorageObject destinationObject,
boolean replaceMetadata,
Calendar ifModifiedSince,
Calendar ifUnmodifiedSince,
String[] ifMatchTags,
String[] ifNoneMatchTags)
Copy an object.
|
protected abstract Map<String,Object> |
StorageService.copyObjectImpl(String sourceBucketName,
String sourceObjectKey,
String destinationBucketName,
String destinationObjectKey,
AccessControlList acl,
Map<String,Object> destinationMetadata,
Calendar ifModifiedSince,
Calendar ifUnmodifiedSince,
String[] ifMatchTags,
String[] ifNoneMatchTags,
String versionId,
String destinationObjectStorageClass,
String destinationObjectServerSideEncryptionAlgorithm)
Copy an object within your account.
|
StorageBucket |
StorageService.createBucket(StorageBucket bucket)
Create a bucket with the Access Control List settings of the bucket object (if any).
|
StorageBucket |
StorageService.createBucket(String bucketName)
Creates a bucket.
|
protected StorageBucket |
StorageService.createBucketImpl(String bucketName,
String location,
AccessControlList acl)
Creates a bucket.
|
protected abstract StorageBucket |
StorageService.createBucketImpl(String bucketName,
String location,
AccessControlList acl,
Map<String,Object> headers)
Creates a bucket.
|
void |
StorageService.deleteBucket(StorageBucket bucket)
Deletes a bucket.
|
void |
StorageService.deleteBucket(String bucketName)
Deletes a bucket.
|
protected abstract void |
StorageService.deleteBucketImpl(String bucketName) |
void |
StorageService.deleteObject(String bucketName,
String objectKey)
Deletes an object from a bucket.
|
protected abstract void |
StorageService.deleteObjectImpl(String bucketName,
String objectKey,
String versionId,
String multiFactorSerialNumber,
String multiFactorAuthCode) |
StorageOwner |
StorageService.getAccountOwner()
Returns the owner of an account, using information available in the
bucket listing response.
|
protected abstract StorageOwner |
StorageService.getAccountOwnerImpl() |
StorageBucket |
StorageService.getBucket(String bucketName)
Returns a bucket in your account by listing all your buckets
(using
StorageService.listAllBuckets() ), and looking for the named bucket in
this list. |
AccessControlList |
StorageService.getBucketAcl(String bucketName)
Retrieves the access control settings of a bucket.
|
protected abstract AccessControlList |
StorageService.getBucketAclImpl(String bucketName) |
StorageObject |
StorageService.getObject(String bucketName,
String objectKey)
Returns an object representing the details and data of an item in a service,
without applying any preconditions.
|
StorageObject |
StorageService.getObject(String bucketName,
String objectKey,
Calendar ifModifiedSince,
Calendar ifUnmodifiedSince,
String[] ifMatchTags,
String[] ifNoneMatchTags,
Long byteRangeStart,
Long byteRangeEnd)
Returns an object representing the details and data of an item that meets any given preconditions.
|
AccessControlList |
StorageService.getObjectAcl(String bucketName,
String objectKey)
Retrieves the access control settings of an object.
|
protected abstract AccessControlList |
StorageService.getObjectAclImpl(String bucketName,
String objectKey,
String versionId) |
StorageObject |
StorageService.getObjectDetails(String bucketName,
String objectKey)
Returns an object representing the details of an item in without the object's data, and
without applying any preconditions.
|
StorageObject |
StorageService.getObjectDetails(String bucketName,
String objectKey,
Calendar ifModifiedSince,
Calendar ifUnmodifiedSince,
String[] ifMatchTags,
String[] ifNoneMatchTags)
Returns an object representing the details of an item that meets any given preconditions.
|
protected abstract StorageObject |
StorageService.getObjectDetailsImpl(String bucketName,
String objectKey,
Calendar ifModifiedSince,
Calendar ifUnmodifiedSince,
String[] ifMatchTags,
String[] ifNoneMatchTags,
String versionId) |
protected abstract StorageObject |
StorageService.getObjectImpl(String bucketName,
String objectKey,
Calendar ifModifiedSince,
Calendar ifUnmodifiedSince,
String[] ifMatchTags,
String[] ifNoneMatchTags,
Long byteRangeStart,
Long byteRangeEnd,
String versionId) |
StorageBucket |
StorageService.getOrCreateBucket(String bucketName)
Returns a bucket in your account, and creates the bucket if
it does not yet exist.
|
protected abstract XmlResponsesSaxParser |
StorageService.getXmlResponseSaxParser() |
abstract boolean |
StorageService.isBucketAccessible(String bucketName)
Indicates whether a bucket exists and is accessible to a service user.
|
boolean |
StorageService.isObjectInBucket(String bucketName,
String objectKey)
Convenience method to check whether an object exists in a bucket.
|
StorageBucket[] |
StorageService.listAllBuckets()
Lists the buckets belonging to the service user.
|
protected StorageBucket[] |
StorageService.listAllBucketsImpl() |
protected abstract StorageBucket[] |
StorageService.listAllBucketsImpl(Map<String,Object> headers) |
StorageObject[] |
StorageService.listObjects(String bucketName)
Lists the objects in a bucket.
|
StorageObject[] |
StorageService.listObjects(String bucketName,
String prefix,
String delimiter)
Lists the objects in a bucket matching a prefix and delimiter.
|
StorageObject[] |
StorageService.listObjects(String bucketName,
String prefix,
String delimiter,
long maxListingLength)
Lists the objects in a bucket matching a prefix, while instructing the service
to send response messages containing no more than a given number of object
results.
|
StorageObjectsChunk |
StorageService.listObjectsChunked(String bucketName,
String prefix,
String delimiter,
long maxListingLength,
String priorLastKey)
Lists the objects in a bucket matching a prefix, chunking the results into batches of
a given size, and returning each chunk separately.
|
StorageObjectsChunk |
StorageService.listObjectsChunked(String bucketName,
String prefix,
String delimiter,
long maxListingLength,
String priorLastKey,
boolean completeListing)
Lists the objects in a bucket matching a prefix and also returns the
common prefixes.
|
protected abstract StorageObjectsChunk |
StorageService.listObjectsChunkedImpl(String bucketName,
String prefix,
String delimiter,
long maxListingLength,
String priorLastKey,
boolean completeListing)
Lists objects in a bucket up to the maximum listing length specified.
|
protected abstract StorageObject[] |
StorageService.listObjectsImpl(String bucketName,
String prefix,
String delimiter,
long maxListingLength)
Lists objects in a bucket.
|
Map<String,Object> |
StorageService.moveObject(String sourceBucketName,
String sourceObjectKey,
String destinationBucketName,
StorageObject destinationObject,
boolean replaceMetadata)
Move an object.
|
void |
StorageService.putBucketAcl(StorageBucket bucket)
Applies access control settings to a bucket.
|
void |
StorageService.putBucketAcl(String bucketName,
AccessControlList acl)
Applies access control settings to a bucket.
|
protected abstract void |
StorageService.putBucketAclImpl(String bucketName,
AccessControlList acl) |
StorageObject |
StorageService.putObject(String bucketName,
StorageObject object)
Puts an object inside an existing bucket, creating a new object or overwriting
an existing one with the same key.
|
void |
StorageService.putObjectAcl(String bucketName,
StorageObject object)
Applies access control settings to an object.
|
void |
StorageService.putObjectAcl(String bucketName,
String objectKey,
AccessControlList acl)
Applies access control settings to an object.
|
protected abstract void |
StorageService.putObjectAclImpl(String bucketName,
String objectKey,
AccessControlList acl,
String versionId) |
protected abstract StorageObject |
StorageService.putObjectImpl(String bucketName,
StorageObject object) |
void |
S3Service.putObjectMaybeAsMultipart(String bucketName,
StorageObject object,
long maxPartSize)
Convenience method that uploads a file-based object to a storage service using
the regular
StorageService.putObject(String, StorageObject) mechanism, or as a
multipart upload if the object's file data is larger than the given maximum
part size parameter. |
Map<String,Object> |
StorageService.renameObject(String bucketName,
String sourceObjectKey,
StorageObject destinationObject)
Rename an object.
|
void |
StorageService.shutdown()
Make a best-possible effort to shutdown and clean up any resources used by this
service such as HTTP connections, connection pools, threads etc, although there is
no guarantee that all such resources will indeed be fully cleaned up.
|
protected abstract void |
StorageService.shutdownImpl() |
protected void |
StorageService.sleepOnInternalError(int internalErrorCount,
ServiceException ex)
Sleeps for a period of time based on the number of Internal Server errors a request has
encountered, provided the number of errors does not exceed the value set with the
property
storage-service.internal-error-retry-max . |
Map<String,Object> |
StorageService.updateObjectMetadata(String bucketName,
StorageObject object)
Update an object's metadata.
|
Constructor and Description |
---|
S3ServiceException(ServiceException se)
Wrap a ServiceException as an S3ServiceException.
|
Modifier and Type | Method and Description |
---|---|
String |
AccessControlList.toXml() |
com.jamesmurty.utils.XMLBuilder |
AccessControlList.toXMLBuilder() |
Modifier and Type | Method and Description |
---|---|
com.jamesmurty.utils.XMLBuilder |
GSAccessControlList.toXMLBuilder() |
Modifier and Type | Method and Description |
---|---|
ServiceException |
XmlResponsesSaxParser.CompleteMultipartUploadResultHandler.getServiceException() |
ServiceException |
XmlResponsesSaxParser.CompleteMultipartUploadErrorHandler.getServiceException() |
Constructor and Description |
---|
CloudFrontXmlResponsesSaxParser(Jets3tProperties properties)
Constructs the XML SAX parser.
|
XmlResponsesSaxParser(Jets3tProperties properties,
boolean returnGoogleStorageObjects)
Constructs the XML SAX parser.
|
Modifier and Type | Method and Description |
---|---|
protected void |
RestStorageService.addMetadataToHeaders(org.apache.http.client.methods.HttpUriRequest httpMethod,
Map<String,Object> metadata)
Adds all valid metadata name and value pairs as HTTP headers to the given HTTP method.
|
protected String |
RestStorageService.addRequestParametersToUrlPath(String urlPath,
Map<String,String> requestParameters)
Adds all the provided request parameters to a URL in GET request format.
|
void |
JetS3tRequestAuthorizer.authorizeHttpRequest(org.apache.http.client.methods.HttpUriRequest httpMethod,
org.apache.http.protocol.HttpContext context) |
void |
GoogleStorageService.authorizeHttpRequest(org.apache.http.client.methods.HttpUriRequest httpMethod,
org.apache.http.protocol.HttpContext context)
Authorizes an HTTP/S request using the standard HMAC approach or OAuth 2,
whichever technique is appropriate.
|
void |
RestStorageService.authorizeHttpRequest(org.apache.http.client.methods.HttpUriRequest httpMethod,
org.apache.http.protocol.HttpContext context) |
void |
JetS3tRequestAuthorizer.authorizeHttpRequest(org.apache.http.client.methods.HttpUriRequest httpMethod,
org.apache.http.protocol.HttpContext context,
String forceRequestSignatureVersion) |
void |
RestStorageService.authorizeHttpRequest(org.apache.http.client.methods.HttpUriRequest httpMethod,
org.apache.http.protocol.HttpContext context,
String forceRequestSignatureVersion)
Authorizes an HTTP/S request by signing it with an HMAC signature compatible with
the S3 service and Google Storage (legacy) authorization techniques.
|
int |
RestStorageService.checkBucketStatus(String bucketName) |
protected Map<String,Object> |
RestStorageService.copyObjectImpl(String sourceBucketName,
String sourceObjectKey,
String destinationBucketName,
String destinationObjectKey,
AccessControlList acl,
Map<String,Object> destinationMetadata,
Calendar ifModifiedSince,
Calendar ifUnmodifiedSince,
String[] ifMatchTags,
String[] ifNoneMatchTags,
String versionId,
String destinationObjectStorageClass,
String destinationObjectServerSideEncryptionAlgorithm) |
GSBucket |
GoogleStorageService.createBucket(String bucketName) |
GSBucket |
GoogleStorageService.createBucket(String bucketName,
String location,
AccessControlList acl) |
GSBucket |
GoogleStorageService.createBucket(String bucketName,
String location,
AccessControlList acl,
String projectId)
Creates a bucket in a specific location, without checking whether the bucket already
exists.
|
protected StorageBucket |
RestStorageService.createBucketImpl(String bucketName,
String location,
AccessControlList acl,
Map<String,Object> headers) |
protected StorageBucket |
GoogleStorageService.createBucketImpl(String bucketName,
String location,
AccessControlList acl,
String projectId) |
protected Map<String,Object> |
RestStorageService.createObjectImpl(String bucketName,
String objectKey,
String contentType,
org.apache.http.HttpEntity requestEntity,
Map<String,Object> metadata,
Map<String,String> requestParams,
AccessControlList acl,
String storageClass,
String serverSideEncryptionAlgorithm) |
protected void |
RestStorageService.deleteBucketImpl(String bucketName) |
protected void |
RestStorageService.deleteObjectImpl(String bucketName,
String objectKey,
String versionId,
String multiFactorSerialNumber,
String multiFactorAuthCode) |
void |
RestStorageService.deleteObjectWithSignedUrl(String signedDeleteUrl)
Deletes an object using a pre-signed DELETE URL generated for that object.
|
void |
GoogleStorageService.deleteWebsiteConfig(String bucketName)
Delete a bucket's website configuration; removes the effect of any
previously-applied configuration.
|
protected void |
GoogleStorageService.deleteWebsiteConfigImpl(String bucketName) |
protected void |
RestStorageService.deleteWebsiteConfigImpl(String bucketName) |
protected StorageOwner |
RestStorageService.getAccountOwnerImpl() |
GSAccessControlList |
GoogleStorageService.getBucketAcl(String bucketName) |
protected AccessControlList |
RestStorageService.getBucketAclImpl(String bucketName) |
String |
GoogleStorageService.getBucketLocation(String bucketName) |
protected String |
RestStorageService.getBucketLocationImpl(String bucketName) |
GSBucketLoggingStatus |
GoogleStorageService.getBucketLoggingStatus(String bucketName) |
protected StorageBucketLoggingStatus |
RestStorageService.getBucketLoggingStatusImpl(String bucketName) |
GSObject |
GoogleStorageService.getObject(String bucketName,
String objectKey) |
GSObject |
GoogleStorageService.getObject(String bucketName,
String objectKey,
Calendar ifModifiedSince,
Calendar ifUnmodifiedSince,
String[] ifMatchTags,
String[] ifNoneMatchTags,
Long byteRangeStart,
Long byteRangeEnd) |
protected AccessControlList |
RestStorageService.getObjectAclImpl(String bucketName,
String objectKey) |
protected AccessControlList |
RestStorageService.getObjectAclImpl(String bucketName,
String objectKey,
String versionId) |
AccessControlList |
RestStorageService.getObjectAclWithSignedUrl(String signedAclUrl)
Gets an object's ACL details using a pre-signed GET URL generated for that object.
|
GSObject |
GoogleStorageService.getObjectDetails(String bucketName,
String objectKey) |
protected StorageObject |
RestStorageService.getObjectDetailsImpl(String bucketName,
String objectKey,
Calendar ifModifiedSince,
Calendar ifUnmodifiedSince,
String[] ifMatchTags,
String[] ifNoneMatchTags,
String versionId) |
S3Object |
RestStorageService.getObjectDetailsWithSignedUrl(String signedHeadUrl)
Gets an object's details using a pre-signed HEAD URL generated for that object.
|
protected StorageObject |
RestStorageService.getObjectImpl(String bucketName,
String objectKey,
Calendar ifModifiedSince,
Calendar ifUnmodifiedSince,
String[] ifMatchTags,
String[] ifNoneMatchTags,
Long byteRangeStart,
Long byteRangeEnd,
String versionId) |
S3Object |
RestStorageService.getObjectWithSignedUrl(String signedGetUrl)
Gets an object using a pre-signed GET URL generated for that object.
|
GSWebsiteConfig |
GoogleStorageService.getWebsiteConfig(String bucketName) |
protected WebsiteConfig |
RestStorageService.getWebsiteConfigImpl(String bucketName) |
protected XmlResponsesSaxParser |
RestS3Service.getXmlResponseSaxParser() |
protected XmlResponsesSaxParser |
GoogleStorageService.getXmlResponseSaxParser() |
boolean |
RestStorageService.isBucketAccessible(String bucketName) |
GSBucket[] |
GoogleStorageService.listAllBuckets() |
GSBucket[] |
GoogleStorageService.listAllBuckets(String projectId)
List all buckets in a given project
|
protected StorageBucket[] |
RestStorageService.listAllBucketsImpl(Map<String,Object> headers) |
protected StorageBucket[] |
GoogleStorageService.listAllBucketsImpl(String projectId) |
GSObject[] |
GoogleStorageService.listObjects(String bucketName) |
GSObject[] |
GoogleStorageService.listObjects(String bucketName,
String prefix,
String delimiter) |
protected StorageObjectsChunk |
RestStorageService.listObjectsChunkedImpl(String bucketName,
String prefix,
String delimiter,
long maxListingLength,
String priorLastKey,
boolean completeListing) |
protected StorageObject[] |
RestStorageService.listObjectsImpl(String bucketName,
String prefix,
String delimiter,
long maxListingLength) |
protected StorageObjectsChunk |
RestStorageService.listObjectsInternal(String bucketName,
String prefix,
String delimiter,
long maxListingLength,
boolean automaticallyMergeChunks,
String priorLastKey) |
protected org.apache.http.HttpResponse |
RestStorageService.performRequest(org.apache.http.client.methods.HttpUriRequest httpMethod,
int[] expectedResponseCodes) |
protected org.apache.http.HttpResponse |
RestStorageService.performRequest(org.apache.http.client.methods.HttpUriRequest httpMethod,
int[] expectedResponseCodes,
org.apache.http.protocol.HttpContext context)
Performs an HTTP/S request by invoking the provided HttpMethod object.
|
protected org.apache.http.HttpResponse |
RestStorageService.performRestDelete(String bucketName,
String objectKey,
Map<String,String> requestParameters,
String multiFactorSerialNumber,
String multiFactorAuthCode)
Performs an HTTP DELETE request using the
RestStorageService.performRequest(org.apache.http.client.methods.HttpUriRequest, int[]) method. |
protected org.apache.http.HttpResponse |
RestStorageService.performRestGet(String bucketName,
String objectKey,
Map<String,String> requestParameters,
Map<String,Object> requestHeaders)
Performs an HTTP GET request using the
RestStorageService.performRequest(org.apache.http.client.methods.HttpUriRequest, int[]) method. |
protected org.apache.http.HttpResponse |
RestStorageService.performRestGet(String bucketName,
String objectKey,
Map<String,String> requestParameters,
Map<String,Object> requestHeaders,
int[] expectedStatusCodes)
Performs an HTTP GET request using the
RestStorageService.performRequest(org.apache.http.client.methods.HttpUriRequest, int[]) method. |
protected org.apache.http.HttpResponse |
RestStorageService.performRestHead(String bucketName,
String objectKey,
Map<String,String> requestParameters,
Map<String,Object> requestHeaders)
Performs an HTTP HEAD request using the
RestStorageService.performRequest(org.apache.http.client.methods.HttpUriRequest, int[]) method. |
protected org.apache.http.HttpResponse |
RestStorageService.performRestPost(String bucketName,
String objectKey,
Map<String,Object> metadata,
Map<String,String> requestParameters,
org.apache.http.HttpEntity requestEntity,
boolean autoRelease)
Performs an HTTP POST request using the
RestStorageService.performRequest(org.apache.http.client.methods.HttpUriRequest, int[]) method. |
protected org.apache.http.HttpResponse |
RestStorageService.performRestPostWithXmlBuilder(String bucketName,
String objectKey,
Map<String,Object> metadata,
Map<String,String> requestParameters,
com.jamesmurty.utils.XMLBuilder builder) |
protected HttpResponseAndByteCount |
RestStorageService.performRestPut(String bucketName,
String objectKey,
Map<String,Object> metadata,
Map<String,String> requestParameters,
org.apache.http.HttpEntity requestEntity,
boolean autoRelease)
Performs an HTTP PUT request using the
RestStorageService.performRequest(org.apache.http.client.methods.HttpUriRequest, int[]) method. |
protected HttpResponseAndByteCount |
RestStorageService.performRestPutWithXmlBuilder(String bucketName,
String objectKey,
Map<String,Object> metadata,
Map<String,String> requestParameters,
com.jamesmurty.utils.XMLBuilder builder) |
protected void |
RestStorageService.putAclImpl(String bucketName,
String objectKey,
AccessControlList acl,
String versionId) |
void |
GoogleStorageService.putBucketAcl(GSBucket bucket)
Applies access control settings to a bucket.
|
void |
GoogleStorageService.putBucketAcl(String bucketName,
GSAccessControlList acl)
Applies access control settings to a bucket.
|
protected void |
RestStorageService.putBucketAclImpl(String bucketName,
AccessControlList acl) |
GSObject |
GoogleStorageService.putObject(String bucketName,
GSObject object) |
protected void |
RestStorageService.putObjectAclImpl(String bucketName,
String objectKey,
AccessControlList acl,
String versionId) |
void |
RestStorageService.putObjectAclWithSignedUrl(String signedAclUrl,
AccessControlList acl)
Sets an object's ACL details using a pre-signed PUT URL generated for that object.
|
protected StorageObject |
RestStorageService.putObjectImpl(String bucketName,
StorageObject object)
Beware of high memory requirements when creating large S3 objects when the Content-Length
is not set in the object.
|
protected void |
RestStorageService.putObjectWithRequestEntityImpl(String bucketName,
StorageObject object,
org.apache.http.HttpEntity requestEntity,
Map<String,String> requestParams) |
S3Object |
RestStorageService.putObjectWithSignedUrl(String signedPutUrl,
S3Object object)
Puts an object using a pre-signed PUT URL generated for that object.
|
void |
GoogleStorageService.setBucketLoggingStatus(String bucketName,
GSBucketLoggingStatus status) |
protected void |
RestStorageService.setBucketLoggingStatusImpl(String bucketName,
StorageBucketLoggingStatus status) |
protected org.apache.http.client.methods.HttpUriRequest |
GoogleStorageService.setupConnection(RestStorageService.HTTP_METHOD method,
String bucketName,
String objectKey,
Map<String,String> requestParameters) |
protected org.apache.http.client.methods.HttpUriRequest |
RestStorageService.setupConnection(RestStorageService.HTTP_METHOD method,
String bucketName,
String objectKey,
Map<String,String> requestParameters)
Creates an
HttpRequest object to handle a particular connection method. |
void |
GoogleStorageService.setWebsiteConfig(String bucketName,
GSWebsiteConfig config)
Apply a website configuration to a bucket.
|
protected void |
RestStorageService.setWebsiteConfigImpl(String bucketName,
WebsiteConfig config) |
protected void |
RestStorageService.shutdownImpl()
Shut down all connections managed by the underlying HttpConnectionManager.
|
protected void |
RestStorageService.verifyExpectedAndActualETagValues(String expectedETag,
StorageObject uploadedObject)
Compares the expected and actual ETag value for an uploaded object, and throws an
ServiceException if these values do not match.
|
Constructor and Description |
---|
GoogleStorageService(ProviderCredentials credentials)
Constructs the service and initialises the properties.
|
GoogleStorageService(ProviderCredentials credentials,
String invokingApplicationDescription,
org.apache.http.client.CredentialsProvider credentialsProvider)
Constructs the service and initialises the properties.
|
GoogleStorageService(ProviderCredentials credentials,
String invokingApplicationDescription,
org.apache.http.client.CredentialsProvider credentialsProvider,
Jets3tProperties jets3tProperties)
Constructs the service and initialises the properties.
|
Modifier and Type | Method and Description |
---|---|
InputStream |
StorageObject.getDataInputStream()
Returns an input stream containing this object's data, or null if there is
no data associated with the object.
|
String |
StorageBucketLoggingStatus.toXml() |
Modifier and Type | Method and Description |
---|---|
boolean |
ErrorPermitter.isPermitted(ServiceException serviceException)
Returns true in all cases.
|
Modifier and Type | Method and Description |
---|---|
Map[] |
SimpleThreadedStorageService.copyObjects(String sourceBucketName,
String destinationBucketName,
String[] sourceObjectKeys,
StorageObject[] destinationObjects,
boolean replaceMetadata)
Copies multiple objects within or between buckets.
|
StorageBucket[] |
SimpleThreadedStorageService.createBuckets(String[] bucketNames)
Creates multiple buckets.
|
void |
SimpleThreadedStorageService.deleteObjects(String bucketName,
StorageObject[] objects)
Deletes multiple objects
|
void |
SimpleThreadedStorageService.downloadObjects(String bucketName,
DownloadPackage[] downloadPackages)
A convenience method to download multiple objects from S3 to pre-existing output streams, which
is particularly useful for downloading objects to files.
|
boolean |
ThreadedStorageService.downloadObjects(String bucketName,
DownloadPackage[] downloadPackages)
A convenience method to download multiple objects to pre-existing
output streams, which is particularly useful for downloading objects to files.
|
void |
SimpleThreadedStorageService.downloadObjects(String bucketName,
DownloadPackage[] downloadPackages,
ErrorPermitter errorPermitter)
A convenience method to download multiple objects from S3 to pre-existing output streams, which
is particularly useful for downloading objects to files.
|
boolean |
ThreadedStorageService.downloadObjects(String bucketName,
DownloadPackage[] downloadPackages,
ErrorPermitter errorPermitter)
A convenience method to download multiple objects to pre-existing
output streams, which is particularly useful for downloading objects to files.
|
StorageObject[] |
SimpleThreadedStorageService.getObjectACLs(String bucketName,
StorageObject[] objects)
Retrieves Access Control List (ACL) settings for multiple objects.
|
StorageObject[] |
SimpleThreadedStorageService.getObjects(String bucketName,
StorageObject[] objects)
Retrieves multiple objects (including details and data).
|
StorageObject[] |
SimpleThreadedStorageService.getObjects(String bucketName,
StorageObject[] objects,
ErrorPermitter errorPermitter)
Retrieves multiple objects (including details and data).
|
StorageObject[] |
SimpleThreadedStorageService.getObjects(String bucketName,
String[] objectKeys)
Retrieves multiple objects (including details and data).
|
StorageObject[] |
SimpleThreadedStorageService.getObjectsHeads(String bucketName,
StorageObject[] objects)
Retrieves details of multiple objects (details only, no data)
|
StorageObject[] |
SimpleThreadedStorageService.getObjectsHeads(String bucketName,
String[] objectKeys)
Retrieves details of multiple objects (details only, no data)
|
StorageObject[] |
SimpleThreadedStorageService.getObjectsHeads(String bucketName,
String[] objectKeys,
ErrorPermitter errorPermitter)
Retrieves details of multiple objects (details only, no data)
|
StorageObject[] |
SimpleThreadedStorageService.putACLs(String bucketName,
StorageObject[] objects)
Updates/sets Access Control List (ACL) settings for multiple objects.
|
StorageObject[] |
SimpleThreadedStorageService.putObjects(String bucketName,
StorageObject[] objects)
Creates/uploads multiple objects.
|
void |
ThreadedStorageService.shutdown()
Make a best-possible effort to shutdown and clean up any resources used by this
service such as HTTP connections, connection pools, threads etc.
|
protected void |
SimpleThreadedStorageService.throwError(StorageServiceEventAdaptor adaptor)
Utility method to check an
StorageServiceEventAdaptor for the occurrence of an error,
and if one is present to throw it. |
Constructor and Description |
---|
ThreadedStorageService(StorageService service,
StorageServiceEventListener listener)
Construct a multi-threaded service based on a StorageService and which sends event notifications
to an event listening class.
|
ThreadedStorageService(StorageService service,
StorageServiceEventListener listener,
long threadSleepTimeMS)
Construct a multi-threaded service based on an storage service and which sends event notifications
to an event listening class, and which will send EVENT_IN_PROGRESS events at the specified
time interval.
|
Constructor and Description |
---|
ThreadedS3Service(S3Service service,
StorageServiceEventListener listener) |
Modifier and Type | Method and Description |
---|---|
static ProviderCredentials |
ProviderCredentials.load(String password,
BufferedInputStream inputStream)
Loads encrypted credentials from a data input stream.
|
static ProviderCredentials |
GSCredentials.load(String password,
BufferedInputStream inputStream) |
static ProviderCredentials |
ProviderCredentials.load(String password,
File file)
Loads encrypted credentials from a file.
|
static ProviderCredentials |
GSCredentials.load(String password,
File file) |
Modifier and Type | Method and Description |
---|---|
Map<String,StorageObject> |
FileComparer.buildObjectMap(StorageService service,
String bucketName,
String targetPath,
Map<String,String> objectKeyToFilepathMap,
boolean forceMetadataDownload,
boolean isForceUpload,
BytesProgressWatcher progressWatcher,
StorageServiceEventListener eventListener)
Builds a service Object Map containing all the objects within the given target path,
where the map's key for each object is the relative path to the object.
|
FileComparer.PartialObjectListing |
FileComparer.buildObjectMapPartial(StorageService service,
String bucketName,
String targetPath,
String priorLastKey,
Map<String,String> objectKeyToFilepathMap,
boolean completeListing,
boolean forceMetadataDownload,
boolean isForceUpload,
BytesProgressWatcher progressWatcher,
StorageServiceEventListener eventListener)
Builds a service Object Map containing a partial set of objects within the given target path,
where the map's key for each object is the relative path to the object.
|
StorageObject[] |
FileComparer.listObjectsThreaded(StorageService service,
String bucketName,
String targetPath)
Lists the objects in a bucket using a partitioning technique to divide
the object namespace into separate partitions that can be listed by
multiple simultaneous threads.
|
StorageObject[] |
FileComparer.listObjectsThreaded(StorageService service,
String bucketName,
String targetPath,
String delimiter,
int toDepth)
Lists the objects in a bucket using a partitioning technique to divide
the object namespace into separate partitions that can be listed by
multiple simultaneous threads.
|
static XMLReader |
ServiceUtils.loadXMLReader()
Find a SAX XMLReader by hook or by crook, with work-arounds for
non-standard platforms.
|
Map<String,StorageObject> |
FileComparer.lookupObjectMetadataForPotentialClashes(StorageService service,
String bucketName,
String targetPath,
StorageObject[] objectsWithoutMetadata,
Map<String,String> objectKeyToFilepathMap,
boolean forceMetadataDownload,
boolean isForceUpload,
BytesProgressWatcher progressWatcher,
StorageServiceEventListener eventListener)
Given a set of storage objects for which only minimal information is available,
retrieve metadata information for any objects that potentially clash with
local files.
|
Modifier and Type | Method and Description |
---|---|
void |
SignedUrlHandler.deleteObjectWithSignedUrl(String signedDeleteUrl)
Deletes an object using a pre-signed DELETE URL generated for that object.
|
AccessControlList |
SignedUrlHandler.getObjectAclWithSignedUrl(String signedAclUrl)
Gets an object's ACL details using a pre-signed GET URL generated for that object.
|
S3Object |
SignedUrlHandler.getObjectDetailsWithSignedUrl(String signedHeadUrl)
Gets an object's details using a pre-signed HEAD URL generated for that object.
|
S3Object |
SignedUrlHandler.getObjectWithSignedUrl(String signedGetUrl)
Gets an object using a pre-signed GET URL generated for that object.
|
void |
SignedUrlHandler.putObjectAclWithSignedUrl(String signedAclUrl,
AccessControlList acl)
Sets an object's ACL details using a pre-signed PUT URL generated for that object.
|
S3Object |
SignedUrlHandler.putObjectWithSignedUrl(String signedPutUrl,
S3Object object)
Puts an object using a pre-signed PUT URL generated for that object.
|
Copyright © 2006–2018. All rights reserved.