Package | Description |
---|---|
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 |
---|---|
abstract void |
ThreadedStorageService.ThreadGroupManager.fireIgnoredErrorsEvent(ThreadWatcher threadWatcher,
Throwable[] ignoredErrors) |
abstract void |
ThreadedStorageService.ThreadGroupManager.fireProgressEvent(ThreadWatcher threadWatcher,
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 | Method and Description |
---|---|
ThreadWatcher |
ServiceEvent.getThreadWatcher() |
Modifier and Type | Method and Description |
---|---|
static UpdateACLEvent |
UpdateACLEvent.newIgnoredErrorsEvent(ThreadWatcher threadWatcher,
Throwable[] ignoredErrors,
Object uniqueOperationId) |
static DownloadObjectsEvent |
DownloadObjectsEvent.newIgnoredErrorsEvent(ThreadWatcher threadWatcher,
Throwable[] ignoredErrors,
Object uniqueOperationId) |
static CreateObjectsEvent |
CreateObjectsEvent.newIgnoredErrorsEvent(ThreadWatcher threadWatcher,
Throwable[] ignoredErrors,
Object uniqueOperationId) |
static GetObjectHeadsEvent |
GetObjectHeadsEvent.newIgnoredErrorsEvent(ThreadWatcher threadWatcher,
Throwable[] ignoredErrors,
Object uniqueOperationId) |
static CreateBucketsEvent |
CreateBucketsEvent.newIgnoredErrorsEvent(ThreadWatcher threadWatcher,
Throwable[] ignoredErrors,
Object uniqueOperationId) |
static DeleteObjectsEvent |
DeleteObjectsEvent.newIgnoredErrorsEvent(ThreadWatcher threadWatcher,
Throwable[] ignoredErrors,
Object uniqueOperationId) |
static LookupACLEvent |
LookupACLEvent.newIgnoredErrorsEvent(ThreadWatcher threadWatcher,
Throwable[] ignoredErrors,
Object uniqueOperationId) |
static GetObjectsEvent |
GetObjectsEvent.newIgnoredErrorsEvent(ThreadWatcher threadWatcher,
Throwable[] ignoredErrors,
Object uniqueOperationId) |
static ListObjectsEvent |
ListObjectsEvent.newIgnoredErrorsEvent(ThreadWatcher threadWatcher,
Throwable[] ignoredErrors,
Object uniqueOperationId) |
static CopyObjectsEvent |
CopyObjectsEvent.newIgnoredErrorsEvent(ThreadWatcher threadWatcher,
Throwable[] ignoredErrors,
Object uniqueOperationId) |
static ListObjectsEvent |
ListObjectsEvent.newInProgressEvent(ThreadWatcher threadWatcher,
List<StorageObjectsChunk> chunkList,
Object uniqueOperationId) |
static CopyObjectsEvent |
CopyObjectsEvent.newInProgressEvent(ThreadWatcher threadWatcher,
Map[] completedResults,
Object uniqueOperationId) |
static CreateBucketsEvent |
CreateBucketsEvent.newInProgressEvent(ThreadWatcher threadWatcher,
StorageBucket[] completedBuckets,
Object uniqueOperationId) |
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) |
static UpdateACLEvent |
UpdateACLEvent.newStartedEvent(ThreadWatcher threadWatcher,
Object uniqueOperationId) |
static DownloadObjectsEvent |
DownloadObjectsEvent.newStartedEvent(ThreadWatcher threadWatcher,
Object uniqueOperationId) |
static CreateObjectsEvent |
CreateObjectsEvent.newStartedEvent(ThreadWatcher threadWatcher,
Object uniqueOperationId) |
static GetObjectHeadsEvent |
GetObjectHeadsEvent.newStartedEvent(ThreadWatcher threadWatcher,
Object uniqueOperationId) |
static CreateBucketsEvent |
CreateBucketsEvent.newStartedEvent(ThreadWatcher threadWatcher,
Object uniqueOperationId) |
static DeleteObjectsEvent |
DeleteObjectsEvent.newStartedEvent(ThreadWatcher threadWatcher,
Object uniqueOperationId) |
static LookupACLEvent |
LookupACLEvent.newStartedEvent(ThreadWatcher threadWatcher,
Object uniqueOperationId) |
static GetObjectsEvent |
GetObjectsEvent.newStartedEvent(ThreadWatcher threadWatcher,
Object uniqueOperationId) |
static ListObjectsEvent |
ListObjectsEvent.newStartedEvent(ThreadWatcher threadWatcher,
Object uniqueOperationId) |
static CopyObjectsEvent |
CopyObjectsEvent.newStartedEvent(ThreadWatcher threadWatcher,
Object uniqueOperationId) |
protected void |
ServiceEvent.setThreadWatcher(ThreadWatcher threadWatcher) |
Modifier and Type | Method and Description |
---|---|
static MultipartCompletesEvent |
MultipartCompletesEvent.newIgnoredErrorsEvent(ThreadWatcher threadWatcher,
Throwable[] ignoredErrors,
Object uniqueOperationId) |
static MultipartUploadsEvent |
MultipartUploadsEvent.newIgnoredErrorsEvent(ThreadWatcher threadWatcher,
Throwable[] ignoredErrors,
Object uniqueOperationId) |
static MultipartStartsEvent |
MultipartStartsEvent.newIgnoredErrorsEvent(ThreadWatcher threadWatcher,
Throwable[] ignoredErrors,
Object uniqueOperationId) |
static MultipartCompletesEvent |
MultipartCompletesEvent.newInProgressEvent(ThreadWatcher threadWatcher,
MultipartCompleted[] completedUploads,
Object uniqueOperationId) |
static MultipartStartsEvent |
MultipartStartsEvent.newInProgressEvent(ThreadWatcher threadWatcher,
MultipartUpload[] completedMultipartUploads,
Object uniqueOperationId) |
static MultipartUploadsEvent |
MultipartUploadsEvent.newInProgressEvent(ThreadWatcher threadWatcher,
StorageObject[] completedObjects,
Object uniqueOperationId) |
static MultipartCompletesEvent |
MultipartCompletesEvent.newStartedEvent(ThreadWatcher threadWatcher,
Object uniqueOperationId) |
static MultipartUploadsEvent |
MultipartUploadsEvent.newStartedEvent(ThreadWatcher threadWatcher,
Object uniqueOperationId) |
static MultipartStartsEvent |
MultipartStartsEvent.newStartedEvent(ThreadWatcher threadWatcher,
Object uniqueOperationId) |
Modifier and Type | Class and Description |
---|---|
class |
ThreadWatcher
Deprecated.
0.8.0 use
ThreadWatcher instead. |
Copyright © 2006–2018. All rights reserved.