Modifier and Type | Class and Description |
---|---|
class |
ExtractXmlAttributesWorker |
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 |
BlobListZipWork
Deprecated.
since 10.3, not used anymore since bulk download operation is synchronous.
|
Modifier and Type | Class and Description |
---|---|
class |
DuplicateCollectionMemberWork |
class |
RemovedAbstractWork |
class |
RemovedCollectionMemberWork |
class |
RemovedCollectionWork |
class |
RemoveFromCollectionWork |
Modifier and Type | Class and Description |
---|---|
class |
BatchFinderWork
Abstract Work to find the ids of documents for which some process must be executed in batch, based on a NXQL query.
|
class |
BatchProcessorWork
Abstract Work to process a list of documents.
|
Modifier and Type | Method and Description |
---|---|
abstract Work |
BatchFinderWork.getBatchProcessorWork(List<String> docIds) |
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) |
protected Work |
RedisWorkQueuing.getWorkFromQueue(String queueId)
Removes first work from work queue.
|
Modifier and Type | Method and Description |
---|---|
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 |
---|---|
protected List<byte[]> |
RedisWorkQueuing.args(Work work,
boolean serialize) |
protected byte[] |
RedisWorkQueuing.serializeWork(Work work) |
void |
RedisWorkQueuing.workCanceled(String queueId,
Work work) |
void |
RedisWorkQueuing.workCompleted(String queueId,
Work work) |
protected byte[] |
RedisWorkQueuing.workId(Work work) |
void |
RedisWorkQueuing.workReschedule(String queueId,
Work work) |
void |
RedisWorkQueuing.workRunning(String queueId,
Work work) |
void |
RedisWorkQueuing.workSchedule(String queueId,
Work work) |
protected void |
RedisWorkQueuing.workSetCancelledScheduled(String queueId,
Work work)
Switches a work to state completed, and saves its new state.
|
protected void |
RedisWorkQueuing.workSetCompleted(String queueId,
Work work)
Switches a work to state completed, and saves its new state.
|
protected void |
RedisWorkQueuing.workSetReschedule(String queueId,
Work work)
Switches a work to state canceled, and saves its new state.
|
protected void |
RedisWorkQueuing.workSetRunning(String queueId,
Work work)
Switches a work to state running.
|
void |
RedisWorkQueuing.workSetScheduled(String queueId,
Work work)
Persists a work instance and adds it to the scheduled queue.
|
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 string properties and the blobs of the given document, saving them
into the fulltext table.
|
Modifier and Type | Class and Description |
---|---|
static class |
DBSTransactionState.FindReadAclsWork
Work to find the ids of documents for which Read ACLs must be recomputed, and launch the needed update works.
|
static class |
DBSTransactionState.UpdateReadAclsWork
Work to update the Read ACLs on a list of documents, without recursion.
|
Modifier and Type | Method and Description |
---|---|
Work |
DBSTransactionState.FindReadAclsWork.getBatchProcessorWork(List<String> docIds) |
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.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.scheduleWork(List<Work> works) |
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 |
protected Work |
WorkComputation.work |
Work |
StreamWorkManager.WorkScheduling.work |
Modifier and Type | Field and Description |
---|---|
protected ConcurrentLinkedQueue<Work> |
WorkManagerImpl.WorkThreadPoolExecutor.running
List of running Work instances, in order to be able to interrupt them if requested.
|
protected Map<String,Work> |
MemoryBlockingQueue.works |
Modifier and Type | Method and Description |
---|---|
static Work |
WorkComputation.deserialize(byte[] data) |
Work |
WorkQueuing.find(String workId,
Work.State state)
Finds a work instance in the scheduled or running or completed sets.
|
Work |
WorkManagerImpl.find(String workId,
Work.State state) |
Work |
StreamWorkManager.find(String s,
Work.State state) |
Work |
MemoryWorkQueuing.find(String workId,
Work.State state) |
static Work |
WorkHolder.getWork(Runnable r) |
Modifier and Type | Method and Description |
---|---|
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> |
StreamWorkManager.listWork(String s,
Work.State state) |
List<Work> |
MemoryWorkQueuing.listWork(String queueId,
Work.State state) |
Modifier and Type | Method and Description |
---|---|
void |
WorkManagerImpl.WorkThreadPoolExecutor.execute(Work work)
Deprecated.
since 10.2 because unused
|
void |
WorkQueuing.Listener.queueChanged(Work work,
WorkQueueMetrics metric) |
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) |
void |
StreamWorkManager.schedule(Work work,
WorkManager.Scheduling scheduling,
boolean afterCommit) |
protected boolean |
WorkManagerImpl.scheduleAfterCommit(Work work,
WorkManager.Scheduling scheduling)
Schedule after commit.
|
protected boolean |
StreamWorkManager.scheduleAfterCommit(Work work,
WorkManager.Scheduling scheduling) |
static byte[] |
WorkComputation.serialize(Work work) |
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.workCanceled(String queueId,
Work work)
Removes a work instance from scheduled set.
|
void |
MemoryWorkQueuing.workCanceled(String queueId,
Work work) |
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) |
protected static boolean |
MemoryWorkQueuing.workHasState(Work work,
Work.State state)
Returns
true if the given state is not null and matches the state of the given work or if the
state is null and the work's state is either Work.State.SCHEDULED or Work.State.RUNNING ,
false otherwise. |
void |
WorkQueuing.workReschedule(String queueId,
Work work)
Moves back a work instance from running set to the scheduled set.
|
void |
MemoryWorkQueuing.workReschedule(String queueId,
Work work) |
void |
WorkQueuing.workRunning(String queueId,
Work work)
Put the work instance into the running set.
|
void |
MemoryWorkQueuing.workRunning(String queueId,
Work work) |
void |
WorkQueuing.workSchedule(String queueId,
Work work)
Submit a work to the
ThreadPoolExecutor and put it in the scheduled set. |
void |
MemoryWorkQueuing.workSchedule(String queueId,
Work work) |
Constructor and Description |
---|
WorkHolder(Work work) |
WorkScheduling(Work work,
WorkManager.Scheduling scheduling) |
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)
Deprecated.
since 10.2 not scalable
|
Modifier and Type | Method and Description |
---|---|
List<Work> |
WorkManager.listWork(String queueId,
Work.State state)
Deprecated.
since 10.2 not scalable
|
Modifier and Type | Method and Description |
---|---|
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 |
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 |
ImagingRecomputeWork |
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 |
ThreeDBatchUpdateWork
Work running batch conversions to update 3D document type preview assets
|
Modifier and Type | Class and Description |
---|---|
class |
ThumbnailRecomputeWork
Work to recompute the thumbnail of the documents resulting from the provided NXQL query.
|
Modifier and Type | Class and Description |
---|---|
class |
VideoConversionWork
Work running a defined video conversion.
|
class |
VideoInfoWork
Work to process the video info of a Video document and schedule two works to process the storyboard and conversions,
see
VideoStoryboardWork and VideoConversionWork . |
class |
VideoStoryboardWork
Work to process the storyboard of a Video document.
|
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 © 2019 Nuxeo. All rights reserved.