Modifier and Type | Class and Description |
---|---|
class |
BinaryMetadataWork
Work handling binary metadata updates.
|
Modifier and Type | Class and Description |
---|---|
class |
PermissionsPurgeWork
Work archiving ACEs based on a query.
|
Modifier and Type | Class and Description |
---|---|
class |
DuplicateCollectionMemberWork |
class |
RemovedAbstractWork |
class |
RemovedCollectionMemberWork |
class |
RemovedCollectionWork |
class |
RemoveFromCollectionWork |
Modifier and Type | Class and Description |
---|---|
class |
ConversionWork
Work executing a given conversion.
|
Modifier and Type | Class and Description |
---|---|
protected static class |
AsyncEventExecutor.ListenerWork |
Modifier and Type | Method and Description |
---|---|
protected Work |
RedisWorkQueuing.deserializeWork(byte[] workBytes) |
Work |
RedisWorkQueuing.find(String workId,
Work.State state) |
protected Work |
RedisWorkQueuing.getWork(byte[] workIdBytes) |
protected Work |
RedisWorkQueuing.getWorkData(byte[] workIdBytes) |
Work |
RedisWorkQueuing.removeScheduled(String queueId,
String workId) |
protected Work |
RedisWorkQueuing.removeScheduledWork(String queueId)
Removes first work from scheduled queue.
|
protected Work |
RedisWorkQueuing.removeScheduledWork(String queueId,
String workId)
Removes a given work from scheduled queue and set state to completed.
|
Modifier and Type | Method and Description |
---|---|
protected List<Work> |
RedisWorkQueuing.listCompleted(String queueId) |
protected List<Work> |
RedisWorkQueuing.listRunning(String queueId) |
protected List<Work> |
RedisWorkQueuing.listScheduled(String queueId) |
List<Work> |
RedisWorkQueuing.listWork(String queueId,
Work.State state) |
protected List<Work> |
RedisWorkQueuing.listWorkList(byte[] queueBytes) |
protected List<Work> |
RedisWorkQueuing.listWorkSet(byte[] queueBytes) |
Modifier and Type | Method and Description |
---|---|
void |
RedisWorkQueuing.addScheduledWork(String queueId,
Work work)
Persists a work instance and adds it to the scheduled queue.
|
protected byte[] |
RedisWorkQueuing.serializeWork(Work work) |
void |
RedisWorkQueuing.workCompleted(String queueId,
Work work) |
void |
RedisWorkQueuing.workRunning(String queueId,
Work work) |
protected void |
RedisWorkQueuing.workSetCompleted(String queueId,
Work work)
Switches a work to state completed, and saves its new state.
|
protected void |
RedisWorkQueuing.workSetRunning(String queueId,
Work work)
Switches a work to state running.
|
Modifier and Type | Class and Description |
---|---|
class |
UpdateACEStatusWork
Work updating ACE status.
|
Modifier and Type | Class and Description |
---|---|
class |
FulltextExtractorWork
Work task that does fulltext extraction from the blobs of the given document.
|
class |
FulltextUpdaterWork
Work task that inserts the fulltext (extracted manually by the session at save time, or through
FulltextExtractorWork) into the fulltext table.
|
Modifier and Type | Class and Description |
---|---|
class |
DBSFulltextExtractorWork
Work task that does fulltext extraction from the blobs of the given document.
|
Modifier and Type | Method and Description |
---|---|
protected List<Work> |
DBSTransactionState.getFulltextWorks()
Gets the fulltext updates to do.
|
Modifier and Type | Method and Description |
---|---|
protected void |
DBSTransactionState.getFulltextBinariesWorks(List<Work> works,
Set<String> docWithDirtyBinaries) |
protected void |
DBSTransactionState.getFulltextSimpleWorks(List<Work> works,
Set<String> docsWithDirtyStrings) |
protected void |
DBSTransactionState.scheduleWork(List<Work> works) |
Modifier and Type | Method and Description |
---|---|
protected List<Work> |
SessionImpl.getFulltextWorks()
Gets the fulltext updates to do.
|
Modifier and Type | Method and Description |
---|---|
protected void |
SessionImpl.getFulltextBinariesWorks(List<Work> works,
Set<Serializable> dirtyBinaries) |
protected void |
SessionImpl.getFulltextSimpleWorks(List<Work> works,
Set<Serializable> dirtyStrings) |
protected void |
SessionImpl.scheduleWork(List<Work> works) |
Modifier and Type | Class and Description |
---|---|
class |
SQLFulltextExtractorWork
Work task that does fulltext extraction from the blobs of the given document.
|
Modifier and Type | Class and Description |
---|---|
class |
TransiantStorageGCWork |
Modifier and Type | Class and Description |
---|---|
class |
TransientStoreWork
A work allowing to store a result in the
TransientStore . |
Modifier and Type | Class and Description |
---|---|
class |
AbstractWork
A base implementation for a
Work instance, dealing with most of the details around state change. |
class |
SleepWork
Simple work that just sleeps, mostly used for tests.
|
Modifier and Type | Field and Description |
---|---|
Work |
WorkManagerImpl.WorkScheduling.work |
Modifier and Type | Field and Description |
---|---|
protected Map<String,Map<String,Work>> |
MemoryWorkQueuing.allCompleted |
protected Map<String,Map<String,Work>> |
MemoryWorkQueuing.allRunning |
protected List<Work> |
WorkManagerImpl.WorkThreadPoolExecutor.running
List of running Work instances, in order to be able to interrupt them if requested.
|
Modifier and Type | Method and Description |
---|---|
Work |
WorkQueuing.find(String workId,
Work.State state)
Finds a work instance in the scheduled queue or running or completed sets.
|
Work |
WorkManagerImpl.find(String workId,
Work.State state) |
Work |
MemoryWorkQueuing.find(String workId,
Work.State state) |
Work |
WorkManagerImpl.find(Work work,
Work.State state,
boolean useEquals,
int[] pos)
Deprecated.
|
protected Work |
MemoryWorkQueuing.findCompleted(String workId) |
protected Work |
MemoryWorkQueuing.findRunning(String workId) |
protected Work |
MemoryWorkQueuing.findScheduled(String workId) |
static Work |
WorkHolder.getWork(Runnable r) |
Work |
WorkManagerImpl.WorkThreadPoolExecutor.removeScheduled(String workId) |
Work |
WorkQueuing.removeScheduled(String queueId,
String workId)
Finds a scheduled work instance and removes it from the scheduled work.
|
Work |
MemoryWorkQueuing.removeScheduled(String queueId,
String workId) |
Modifier and Type | Method and Description |
---|---|
protected Map<String,Work> |
MemoryWorkQueuing.getCompleted(String queueId) |
protected Map<String,Work> |
MemoryWorkQueuing.getRunning(String queueId) |
protected List<Work> |
MemoryWorkQueuing.listCompleted(String queueId) |
protected List<Work> |
MemoryWorkQueuing.listRunning(String queueId) |
protected List<Work> |
MemoryWorkQueuing.listScheduled(String queueId) |
List<Work> |
WorkQueuing.listWork(String queueId,
Work.State state)
Lists the work instances in a given queue in a defined state.
|
List<Work> |
WorkManagerImpl.listWork(String queueId,
Work.State state) |
List<Work> |
MemoryWorkQueuing.listWork(String queueId,
Work.State state) |
protected Map<String,Work> |
MemoryWorkQueuing.newCompletedMap() |
protected Map<String,Work> |
MemoryWorkQueuing.newRunningMap() |
Modifier and Type | Method and Description |
---|---|
void |
WorkManagerImpl.WorkThreadPoolExecutor.execute(Work work)
Executes the given task sometime in the future.
|
Work |
WorkManagerImpl.find(Work work,
Work.State state,
boolean useEquals,
int[] pos)
Deprecated.
|
void |
WorkManagerImpl.schedule(Work work) |
void |
WorkManagerImpl.schedule(Work work,
boolean afterCommit) |
void |
WorkManagerImpl.schedule(Work work,
WorkManager.Scheduling scheduling) |
void |
WorkManagerImpl.schedule(Work work,
WorkManager.Scheduling scheduling,
boolean afterCommit) |
protected boolean |
WorkManagerImpl.scheduleAfterCommit(Work work,
WorkManager.Scheduling scheduling)
Schedule after commit.
|
protected void |
WorkManagerImpl.WorkThreadPoolExecutor.submit(Work work)
go through the queue instead of using super.execute which may skip the queue and hand off to a thread
directly
|
void |
WorkQueuing.workCompleted(String queueId,
Work work)
Moves a work instance from the running set to the completed set.
|
void |
MemoryWorkQueuing.workCompleted(String queueId,
Work work) |
void |
WorkQueuing.workRunning(String queueId,
Work work)
Moves a work instance from the scheduled queue to the running set.
|
void |
MemoryWorkQueuing.workRunning(String queueId,
Work work) |
Constructor and Description |
---|
WorkHolder(Work work) |
WorkScheduling(Work work,
WorkManager.Scheduling scheduling) |
Modifier and Type | Field and Description |
---|---|
protected static ThreadLocal<Work> |
WorkSchedulePath.enteredLocal |
Modifier and Type | Method and Description |
---|---|
Work |
WorkManager.find(String workId,
Work.State state)
Finds a work instance.
|
Work |
WorkManager.find(Work work,
Work.State state,
boolean useEquals,
int[] pos)
Deprecated.
since 5.8, use
WorkManager.getWorkState(java.lang.String) instead |
Modifier and Type | Method and Description |
---|---|
List<Work> |
WorkManager.listWork(String queueId,
Work.State state)
Lists the work instances in a given queue in a defined state.
|
Modifier and Type | Method and Description |
---|---|
Work |
WorkManager.find(Work work,
Work.State state,
boolean useEquals,
int[] pos)
Deprecated.
since 5.8, use
WorkManager.getWorkState(java.lang.String) instead |
static void |
WorkSchedulePath.handleEnter(Work work) |
protected static String |
WorkSchedulePath.name(Work work) |
static void |
WorkSchedulePath.newInstance(Work work) |
void |
WorkManager.schedule(Work work)
Schedules work for execution at a later time.
|
void |
WorkManager.schedule(Work work,
boolean afterCommit)
Schedules work for execution at a later time, after the current transaction (if any) has committed.
|
void |
WorkManager.schedule(Work work,
WorkManager.Scheduling scheduling)
Schedules work for execution at a later time, with a specific scheduling policy.
|
void |
WorkManager.schedule(Work work,
WorkManager.Scheduling scheduling,
boolean afterCommit)
Schedules work for execution at a later time, with a specific scheduling policy.
|
Constructor and Description |
---|
WorkSchedulePath(WorkSchedulePath parent,
Work work) |
Modifier and Type | Class and Description |
---|---|
class |
CSVImporterWork
Work task to import form a CSV file.
|
Modifier and Type | Class and Description |
---|---|
class |
ImagingRecomputeWork |
Modifier and Type | Class and Description |
---|---|
class |
BlobProviderDocumentsUpdateWork |
Modifier and Type | Class and Description |
---|---|
class |
MediaPublishingUploadWork
Work for asynchronous media upload.
|
Modifier and Type | Class and Description |
---|---|
class |
AclAuditWork |
Modifier and Type | Class and Description |
---|---|
class |
PictureViewsGenerationWork
Work generating the different picture views for a Picture.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractRenditionBuilderWork |
class |
AutomationRenditionBuilder |
Modifier and Type | Method and Description |
---|---|
protected Work |
AutomationLazyRenditionProvider.getRenditionWork(String key,
DocumentModel doc,
RenditionDefinition def) |
protected abstract Work |
AbstractLazyCachableRenditionProvider.getRenditionWork(String key,
DocumentModel doc,
RenditionDefinition def)
|
Modifier and Type | Class and Description |
---|---|
static class |
DocumentRoutingEscalationServiceImpl.EscalationRuleWork |
Modifier and Type | Class and Description |
---|---|
class |
VideoConversionWork
Work running a defined video conversion.
|
Modifier and Type | Class and Description |
---|---|
class |
QuotaMaxSizeSetterWork
Work to set the maxSize on a list of documents
|
class |
QuotaStatsInitialWork
Work doing an initial statistics computation for a defined
QuotaStatsUpdater . |
Modifier and Type | Class and Description |
---|---|
class |
UserProfileImporterWork |
Modifier and Type | Class and Description |
---|---|
class |
ESAuditMigrationWork
Work for the SQL to Elasticsearch audit migration.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractIndexingWorker
Abstract class for sharing code between ElasticSearch related workers
|
class |
BaseIndexingWorker
Abstract class for sharing the worker state
|
class |
BucketIndexingWorker
œ Worker to index a bucket of documents
|
class |
ChildrenIndexingWorker
Worker to index children recursively
|
class |
IndexingWorker
Simple Indexing Worker
|
class |
ScrollingIndexingWorker
Worker to reindex a large amount of document
|
Copyright © 2015 Nuxeo SA. All rights reserved.