Package | Description |
---|---|
contribs.mx |
A JMX Instrumentation module for tracking important events that occur in your
S3 service.
|
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.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.event | |
org.jets3t.service.multi.s3 | |
org.jets3t.service.mx | |
org.jets3t.service.utils |
General purpose utilities used throughout the JetS3t toolkit and applications.
|
Modifier and Type | Method and Description |
---|---|
static void |
S3ObjectMx.registerMBeans(String bucketName,
StorageObject[] objects) |
void |
MxImpl.registerStorageObjectMBean(String bucketName,
StorageObject[] objects) |
Modifier and Type | Field and Description |
---|---|
protected StorageObject[] |
StorageObjectsChunk.objects |
Modifier and Type | Method and Description |
---|---|
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.
|
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) |
StorageObject[] |
StorageObjectsChunk.getObjects() |
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.
|
protected abstract StorageObject[] |
StorageService.listObjectsImpl(String bucketName,
String prefix,
String delimiter,
long maxListingLength)
Lists objects in a bucket.
|
protected abstract StorageObject |
StorageService.newObject() |
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.
|
protected abstract StorageObject |
StorageService.putObjectImpl(String bucketName,
StorageObject object) |
Modifier and Type | Method and Description |
---|---|
protected void |
StorageService.assertValidObject(StorageObject object,
String action)
Throws an exception if an object is null or contains a null/empty key.
|
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.
|
Map<String,Object> |
StorageService.moveObject(String sourceBucketName,
String sourceObjectKey,
String destinationBucketName,
StorageObject destinationObject,
boolean replaceMetadata)
Move an object.
|
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.
|
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.
|
Map<String,Object> |
StorageService.updateObjectMetadata(String bucketName,
StorageObject object)
Update an object's metadata.
|
Constructor and Description |
---|
StorageObjectsChunk(String prefix,
String delimiter,
StorageObject[] objects,
String[] commonPrefixes,
String priorLastKey) |
Modifier and Type | Method and Description |
---|---|
StorageObject[] |
XmlResponsesSaxParser.ListBucketHandler.getObjects() |
protected StorageObject |
XmlResponsesSaxParser.newObject() |
Modifier and Type | Method and Description |
---|---|
protected StorageObject |
RestStorageService.getObjectDetailsImpl(String bucketName,
String objectKey,
Calendar ifModifiedSince,
Calendar ifUnmodifiedSince,
String[] ifMatchTags,
String[] ifNoneMatchTags,
String versionId) |
protected StorageObject |
RestStorageService.getObjectImpl(String bucketName,
String objectKey,
Calendar ifModifiedSince,
Calendar ifUnmodifiedSince,
String[] ifMatchTags,
String[] ifNoneMatchTags,
Long byteRangeStart,
Long byteRangeEnd,
String versionId) |
protected StorageObject[] |
RestStorageService.listObjectsImpl(String bucketName,
String prefix,
String delimiter,
long maxListingLength) |
protected StorageObject |
RestS3Service.newObject() |
protected StorageObject |
GoogleStorageService.newObject() |
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.
|
Modifier and Type | Method and Description |
---|---|
protected boolean |
RestStorageService.isLiveMD5HashingRequired(StorageObject 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) |
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.
|
Modifier and Type | Class and Description |
---|---|
class |
GSObject
A Google Storage object.
|
class |
MissingStorageObject |
class |
S3Object
An S3 object.
|
class |
ThrowableBearingStorageObject
A perverted StorageObject subclass intended to error information along
with basic object data through the existing JetS3t "plumbing", such as
for cases where we need to return error information from low level
methods without failing an operation by throwing an exception.
|
Modifier and Type | Method and Description |
---|---|
static GSObject[] |
GSObject.cast(StorageObject[] objects) |
static S3Object[] |
S3Object.cast(StorageObject[] objects) |
Modifier and Type | Field and Description |
---|---|
protected StorageObject |
DownloadPackage.object |
Modifier and Type | Method and Description |
---|---|
StorageObject |
DownloadPackage.getObject() |
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.
|
static StorageObject[] |
SimpleThreadedStorageService.reorderStorageObjects(String[] objectKeys,
List<StorageObject> unorderedObjects)
Re-order a list of
StorageObject s to match the ordering of an array of
object key names. |
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.
|
boolean |
ThreadedStorageService.copyObjects(String sourceBucketName,
String destinationBucketName,
String[] sourceObjectKeys,
StorageObject[] destinationObjects,
boolean replaceMetadata)
Copies multiple objects within or between buckets, while sending
CopyObjectsEvent notification events. |
void |
SimpleThreadedStorageService.deleteObjects(String bucketName,
StorageObject[] objects)
Deletes multiple objects
|
boolean |
ThreadedStorageService.deleteObjects(String bucketName,
StorageObject[] objects)
Deletes multiple objects from a bucket, and sends
DeleteObjectsEvent notification events. |
StorageObject[] |
SimpleThreadedStorageService.getObjectACLs(String bucketName,
StorageObject[] objects)
Retrieves Access Control List (ACL) settings for multiple objects.
|
boolean |
ThreadedStorageService.getObjectACLs(String bucketName,
StorageObject[] objects)
Retrieves Access Control List (ACL) information for multiple objects from a bucket, and sends
LookupACLEvent notification events. |
StorageObject[] |
SimpleThreadedStorageService.getObjects(String bucketName,
StorageObject[] objects)
Retrieves multiple objects (including details and data).
|
boolean |
ThreadedStorageService.getObjects(String bucketName,
StorageObject[] objects)
Retrieves multiple objects (details and data) from a bucket, and sends
GetObjectsEvent notification events. |
StorageObject[] |
SimpleThreadedStorageService.getObjects(String bucketName,
StorageObject[] objects,
ErrorPermitter errorPermitter)
Retrieves multiple objects (including details and data).
|
StorageObject[] |
SimpleThreadedStorageService.getObjectsHeads(String bucketName,
StorageObject[] objects)
Retrieves details of multiple objects (details only, no data)
|
boolean |
ThreadedStorageService.getObjectsHeads(String bucketName,
StorageObject[] objects)
Retrieves details (but no data) about multiple objects from a bucket, and sends
GetObjectHeadsEvent notification events. |
StorageObject[] |
SimpleThreadedStorageService.putACLs(String bucketName,
StorageObject[] objects)
Updates/sets Access Control List (ACL) settings for multiple objects.
|
boolean |
ThreadedStorageService.putACLs(String bucketName,
StorageObject[] objects)
Updates/sets Access Control List (ACL) information for multiple objects in a bucket, and sends
UpdateACLEvent notification events. |
StorageObject[] |
SimpleThreadedStorageService.putObjects(String bucketName,
StorageObject[] objects)
Creates/uploads multiple objects.
|
boolean |
ThreadedStorageService.putObjects(String bucketName,
StorageObject[] objects)
Creates multiple objects in a bucket, and sends
CreateObjectsEvent notification events. |
void |
DownloadPackage.setObject(StorageObject object) |
Modifier and Type | Method and Description |
---|---|
static StorageObject[] |
SimpleThreadedStorageService.reorderStorageObjects(String[] objectKeys,
List<StorageObject> unorderedObjects)
Re-order a list of
StorageObject s to match the ordering of an array of
object key names. |
Constructor and Description |
---|
DownloadPackage(StorageObject object,
File outputFile) |
DownloadPackage(StorageObject object,
File outputFile,
boolean isUnzipping,
EncryptionUtil encryptionUtil) |
DownloadPackage(StorageObject object,
OutputStream outputStream) |
DownloadPackage(StorageObject object,
OutputStream outputStream,
boolean isUnzipping,
EncryptionUtil encryptionUtil) |
Modifier and Type | Method and Description |
---|---|
StorageObject[] |
UpdateACLEvent.getCancelledObjects() |
StorageObject[] |
DownloadObjectsEvent.getCancelledObjects() |
StorageObject[] |
CreateObjectsEvent.getCancelledObjects() |
StorageObject[] |
GetObjectHeadsEvent.getCancelledObjects() |
StorageObject[] |
DeleteObjectsEvent.getCancelledObjects() |
StorageObject[] |
LookupACLEvent.getCancelledObjects() |
StorageObject[] |
GetObjectsEvent.getCancelledObjects() |
StorageObject[] |
CopyObjectsEvent.getCancelledObjects() |
StorageObject[] |
GetObjectHeadsEvent.getCompletedObjects() |
StorageObject[] |
GetObjectsEvent.getCompletedObjects() |
StorageObject[] |
CopyObjectsEvent.getCopiedObjects() |
StorageObject[] |
CreateObjectsEvent.getCreatedObjects() |
StorageObject[] |
DeleteObjectsEvent.getDeletedObjects() |
StorageObject[] |
DownloadObjectsEvent.getDownloadedObjects() |
StorageObject[] |
LookupACLEvent.getObjectsWithACL() |
StorageObject[] |
UpdateACLEvent.getObjectsWithUpdatedACL() |
Modifier and Type | Method and Description |
---|---|
static UpdateACLEvent |
UpdateACLEvent.newCancelledEvent(StorageObject[] incompletedObjects,
Object uniqueOperationId) |
static DownloadObjectsEvent |
DownloadObjectsEvent.newCancelledEvent(StorageObject[] incompletedObjects,
Object uniqueOperationId) |
static CreateObjectsEvent |
CreateObjectsEvent.newCancelledEvent(StorageObject[] incompletedObjects,
Object uniqueOperationId) |
static GetObjectHeadsEvent |
GetObjectHeadsEvent.newCancelledEvent(StorageObject[] incompletedObjects,
Object uniqueOperationId) |
static DeleteObjectsEvent |
DeleteObjectsEvent.newCancelledEvent(StorageObject[] remainingObjects,
Object uniqueOperationId) |
static LookupACLEvent |
LookupACLEvent.newCancelledEvent(StorageObject[] incompletedObjects,
Object uniqueOperationId) |
static GetObjectsEvent |
GetObjectsEvent.newCancelledEvent(StorageObject[] incompletedObjects,
Object uniqueOperationId) |
static CopyObjectsEvent |
CopyObjectsEvent.newCancelledEvent(StorageObject[] incompletedObjects,
Object uniqueOperationId) |
static CopyObjectsEvent |
CopyObjectsEvent.newCompletedEvent(Object uniqueOperationId,
String[] sourceObjectKeys,
StorageObject[] destinationObjects) |
static UpdateACLEvent |
UpdateACLEvent.newInProgressEvent(ThreadWatcher threadWatcher,
StorageObject[] completedObjects,
Object uniqueOperationId) |
static DownloadObjectsEvent |
DownloadObjectsEvent.newInProgressEvent(ThreadWatcher threadWatcher,
StorageObject[] completedObjects,
Object uniqueOperationId) |
static CreateObjectsEvent |
CreateObjectsEvent.newInProgressEvent(ThreadWatcher threadWatcher,
StorageObject[] completedObjects,
Object uniqueOperationId) |
static GetObjectHeadsEvent |
GetObjectHeadsEvent.newInProgressEvent(ThreadWatcher threadWatcher,
StorageObject[] completedObjects,
Object uniqueOperationId) |
static DeleteObjectsEvent |
DeleteObjectsEvent.newInProgressEvent(ThreadWatcher threadWatcher,
StorageObject[] deletedObjects,
Object uniqueOperationId) |
static LookupACLEvent |
LookupACLEvent.newInProgressEvent(ThreadWatcher threadWatcher,
StorageObject[] completedObjects,
Object uniqueOperationId) |
static GetObjectsEvent |
GetObjectsEvent.newInProgressEvent(ThreadWatcher threadWatcher,
StorageObject[] completedObjects,
Object uniqueOperationId) |
Modifier and Type | Method and Description |
---|---|
StorageObject[] |
MultipartUploadsEvent.getCancelledObjects() |
StorageObject[] |
MultipartStartsEvent.getCancelledObjects() |
StorageObject[] |
MultipartUploadsEvent.getUploadedObjects() |
Modifier and Type | Method and Description |
---|---|
static MultipartUploadsEvent |
MultipartUploadsEvent.newCancelledEvent(StorageObject[] incompletedObjects,
Object uniqueOperationId) |
static MultipartStartsEvent |
MultipartStartsEvent.newCancelledEvent(StorageObject[] incompletedObjects,
Object uniqueOperationId) |
static MultipartUploadsEvent |
MultipartUploadsEvent.newInProgressEvent(ThreadWatcher threadWatcher,
StorageObject[] completedObjects,
Object uniqueOperationId) |
Modifier and Type | Method and Description |
---|---|
boolean |
ThreadedS3Service.multipartStartUploads(String bucketName,
List<StorageObject> objects)
Starts multiple multipart uploads and sends
MultipartStartsEvent notification events. |
Modifier and Type | Method and Description |
---|---|
void |
MxDelegate.registerStorageObjectMBean(String bucketName,
StorageObject[] objects) |
void |
MxInterface.registerStorageObjectMBean(String bucketName,
StorageObject[] objects) |
Modifier and Type | Method and Description |
---|---|
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.
|
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.
|
Map<String,StorageObject> |
FileComparer.PartialObjectListing.getObjectsMap() |
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.
|
Map<String,StorageObject> |
FileComparer.populateObjectMap(String targetPath,
StorageObject[] objects)
Builds a map of key/object pairs each object is associated with a key based on its location
in the service target path.
|
Modifier and Type | Method and Description |
---|---|
static DownloadPackage |
ObjectUtils.createPackageForDownload(StorageObject object,
File fileTarget,
boolean automaticUnzip,
boolean automaticDecrypt,
String encryptionPassword)
Creates a download package representing an S3Object that will be downloaded, and the
target file the downloaded data will be written to.
|
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.
|
Map<String,StorageObject> |
FileComparer.populateObjectMap(String targetPath,
StorageObject[] objects)
Builds a map of key/object pairs each object is associated with a key based on its location
in the service target path.
|
Modifier and Type | Method and Description |
---|---|
FileComparerResults |
FileComparer.buildDiscrepancyLists(Map<String,String> objectKeyToFilepathMap,
Map<String,StorageObject> objectsMap)
Compares the contents of a directory on the local file system with the contents of a service
resource.
|
FileComparerResults |
FileComparer.buildDiscrepancyLists(Map<String,String> objectKeyToFilepathMap,
Map<String,StorageObject> objectsMap,
BytesProgressWatcher progressWatcher)
Compares the contents of a directory on the local file system with the contents of a service
resource.
|
FileComparerResults |
FileComparer.buildDiscrepancyLists(Map<String,String> objectKeyToFilepathMap,
Map<String,StorageObject> objectsMap,
BytesProgressWatcher progressWatcher,
boolean isForceUpload)
Compares the contents of a directory on the local file system with the contents of a service
resource.
|
void |
MultipartUtils.uploadObjects(String bucketName,
S3Service s3Service,
List<StorageObject> objectsForMultipartUpload,
S3ServiceEventListener eventListener)
Upload one or more file-based objects to S3 as multipart uploads, where each
object's underlying file is split into parts based on the value of
MultipartUtils.maxPartSize . |
Constructor and Description |
---|
PartialObjectListing(Map<String,StorageObject> objectsMap,
String priorLastKey) |
Copyright © 2006–2018. All rights reserved.