| 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.multi | |
| org.jets3t.service.multi.event | |
| org.jets3t.service.multi.s3 | |
| org.jets3t.service.multithread |
A multi-threading utility that manages multiple S3 interactions at once by wrapping an S3Service
implementation and running this service with multiple threads.
|
| Modifier and Type | Method and Description |
|---|---|
private void |
Synchronize.displayProgressStatus(java.lang.String prefix,
ThreadWatcher watcher) |
private java.lang.String |
Synchronize.formatTransferDetails(ThreadWatcher watcher) |
| Modifier and Type | Field and Description |
|---|---|
private ThreadWatcher |
ThreadedStorageService.ThreadGroupManager.threadWatcher |
| Modifier and Type | Method and Description |
|---|---|
abstract void |
ThreadedStorageService.ThreadGroupManager.fireIgnoredErrorsEvent(ThreadWatcher threadWatcher,
java.lang.Throwable[] ignoredErrors) |
abstract void |
ThreadedStorageService.ThreadGroupManager.fireProgressEvent(ThreadWatcher threadWatcher,
java.util.List completedResults) |
abstract void |
ThreadedStorageService.ThreadGroupManager.fireStartEvent(ThreadWatcher threadWatcher) |
| Constructor and Description |
|---|
ThreadGroupManager(ThreadedStorageService.AbstractRunnable[] runnables,
ThreadWatcher threadWatcher,
Jets3tProperties jets3tProperties,
boolean isAdminTask) |
| Modifier and Type | Field and Description |
|---|---|
private ThreadWatcher |
ServiceEvent.threadWatcher |
| Modifier and Type | Method and Description |
|---|---|
ThreadWatcher |
ServiceEvent.getThreadWatcher() |
| Modifier and Type | Method and Description |
|---|---|
static DownloadObjectsEvent |
DownloadObjectsEvent.newIgnoredErrorsEvent(ThreadWatcher threadWatcher,
java.lang.Throwable[] ignoredErrors,
java.lang.Object uniqueOperationId) |
static ListObjectsEvent |
ListObjectsEvent.newIgnoredErrorsEvent(ThreadWatcher threadWatcher,
java.lang.Throwable[] ignoredErrors,
java.lang.Object uniqueOperationId) |
static CopyObjectsEvent |
CopyObjectsEvent.newIgnoredErrorsEvent(ThreadWatcher threadWatcher,
java.lang.Throwable[] ignoredErrors,
java.lang.Object uniqueOperationId) |
static LookupACLEvent |
LookupACLEvent.newIgnoredErrorsEvent(ThreadWatcher threadWatcher,
java.lang.Throwable[] ignoredErrors,
java.lang.Object uniqueOperationId) |
static CreateBucketsEvent |
CreateBucketsEvent.newIgnoredErrorsEvent(ThreadWatcher threadWatcher,
java.lang.Throwable[] ignoredErrors,
java.lang.Object uniqueOperationId) |
static CreateObjectsEvent |
CreateObjectsEvent.newIgnoredErrorsEvent(ThreadWatcher threadWatcher,
java.lang.Throwable[] ignoredErrors,
java.lang.Object uniqueOperationId) |
static DeleteObjectsEvent |
DeleteObjectsEvent.newIgnoredErrorsEvent(ThreadWatcher threadWatcher,
java.lang.Throwable[] ignoredErrors,
java.lang.Object uniqueOperationId) |
static GetObjectHeadsEvent |
GetObjectHeadsEvent.newIgnoredErrorsEvent(ThreadWatcher threadWatcher,
java.lang.Throwable[] ignoredErrors,
java.lang.Object uniqueOperationId) |
static UpdateACLEvent |
UpdateACLEvent.newIgnoredErrorsEvent(ThreadWatcher threadWatcher,
java.lang.Throwable[] ignoredErrors,
java.lang.Object uniqueOperationId) |
static GetObjectsEvent |
GetObjectsEvent.newIgnoredErrorsEvent(ThreadWatcher threadWatcher,
java.lang.Throwable[] ignoredErrors,
java.lang.Object uniqueOperationId) |
static ListObjectsEvent |
ListObjectsEvent.newInProgressEvent(ThreadWatcher threadWatcher,
java.util.List<StorageObjectsChunk> chunkList,
java.lang.Object uniqueOperationId) |
static CopyObjectsEvent |
CopyObjectsEvent.newInProgressEvent(ThreadWatcher threadWatcher,
java.util.Map[] completedResults,
java.lang.Object uniqueOperationId) |
static CreateBucketsEvent |
CreateBucketsEvent.newInProgressEvent(ThreadWatcher threadWatcher,
StorageBucket[] completedBuckets,
java.lang.Object uniqueOperationId) |
static DownloadObjectsEvent |
DownloadObjectsEvent.newInProgressEvent(ThreadWatcher threadWatcher,
StorageObject[] completedObjects,
java.lang.Object uniqueOperationId) |
static LookupACLEvent |
LookupACLEvent.newInProgressEvent(ThreadWatcher threadWatcher,
StorageObject[] completedObjects,
java.lang.Object uniqueOperationId) |
static CreateObjectsEvent |
CreateObjectsEvent.newInProgressEvent(ThreadWatcher threadWatcher,
StorageObject[] completedObjects,
java.lang.Object uniqueOperationId) |
static DeleteObjectsEvent |
DeleteObjectsEvent.newInProgressEvent(ThreadWatcher threadWatcher,
StorageObject[] deletedObjects,
java.lang.Object uniqueOperationId) |
static GetObjectHeadsEvent |
GetObjectHeadsEvent.newInProgressEvent(ThreadWatcher threadWatcher,
StorageObject[] completedObjects,
java.lang.Object uniqueOperationId) |
static UpdateACLEvent |
UpdateACLEvent.newInProgressEvent(ThreadWatcher threadWatcher,
StorageObject[] completedObjects,
java.lang.Object uniqueOperationId) |
static GetObjectsEvent |
GetObjectsEvent.newInProgressEvent(ThreadWatcher threadWatcher,
StorageObject[] completedObjects,
java.lang.Object uniqueOperationId) |
static DownloadObjectsEvent |
DownloadObjectsEvent.newStartedEvent(ThreadWatcher threadWatcher,
java.lang.Object uniqueOperationId) |
static ListObjectsEvent |
ListObjectsEvent.newStartedEvent(ThreadWatcher threadWatcher,
java.lang.Object uniqueOperationId) |
static CopyObjectsEvent |
CopyObjectsEvent.newStartedEvent(ThreadWatcher threadWatcher,
java.lang.Object uniqueOperationId) |
static LookupACLEvent |
LookupACLEvent.newStartedEvent(ThreadWatcher threadWatcher,
java.lang.Object uniqueOperationId) |
static CreateBucketsEvent |
CreateBucketsEvent.newStartedEvent(ThreadWatcher threadWatcher,
java.lang.Object uniqueOperationId) |
static CreateObjectsEvent |
CreateObjectsEvent.newStartedEvent(ThreadWatcher threadWatcher,
java.lang.Object uniqueOperationId) |
static DeleteObjectsEvent |
DeleteObjectsEvent.newStartedEvent(ThreadWatcher threadWatcher,
java.lang.Object uniqueOperationId) |
static GetObjectHeadsEvent |
GetObjectHeadsEvent.newStartedEvent(ThreadWatcher threadWatcher,
java.lang.Object uniqueOperationId) |
static UpdateACLEvent |
UpdateACLEvent.newStartedEvent(ThreadWatcher threadWatcher,
java.lang.Object uniqueOperationId) |
static GetObjectsEvent |
GetObjectsEvent.newStartedEvent(ThreadWatcher threadWatcher,
java.lang.Object uniqueOperationId) |
protected void |
ServiceEvent.setThreadWatcher(ThreadWatcher threadWatcher) |
| Modifier and Type | Method and Description |
|---|---|
static MultipartCompletesEvent |
MultipartCompletesEvent.newIgnoredErrorsEvent(ThreadWatcher threadWatcher,
java.lang.Throwable[] ignoredErrors,
java.lang.Object uniqueOperationId) |
static MultipartUploadsEvent |
MultipartUploadsEvent.newIgnoredErrorsEvent(ThreadWatcher threadWatcher,
java.lang.Throwable[] ignoredErrors,
java.lang.Object uniqueOperationId) |
static MultipartStartsEvent |
MultipartStartsEvent.newIgnoredErrorsEvent(ThreadWatcher threadWatcher,
java.lang.Throwable[] ignoredErrors,
java.lang.Object uniqueOperationId) |
static MultipartCompletesEvent |
MultipartCompletesEvent.newInProgressEvent(ThreadWatcher threadWatcher,
MultipartCompleted[] completedUploads,
java.lang.Object uniqueOperationId) |
static MultipartStartsEvent |
MultipartStartsEvent.newInProgressEvent(ThreadWatcher threadWatcher,
MultipartUpload[] completedMultipartUploads,
java.lang.Object uniqueOperationId) |
static MultipartUploadsEvent |
MultipartUploadsEvent.newInProgressEvent(ThreadWatcher threadWatcher,
StorageObject[] completedObjects,
java.lang.Object uniqueOperationId) |
static MultipartCompletesEvent |
MultipartCompletesEvent.newStartedEvent(ThreadWatcher threadWatcher,
java.lang.Object uniqueOperationId) |
static MultipartUploadsEvent |
MultipartUploadsEvent.newStartedEvent(ThreadWatcher threadWatcher,
java.lang.Object uniqueOperationId) |
static MultipartStartsEvent |
MultipartStartsEvent.newStartedEvent(ThreadWatcher threadWatcher,
java.lang.Object uniqueOperationId) |
| Modifier and Type | Class and Description |
|---|---|
class |
ThreadWatcher
Deprecated.
0.8.0 use
ThreadWatcher instead. |