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
Work to zip a list of document default blob and store the produced zip into the TransientStore.
|
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 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.
|
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.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 |
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)
Executes the given task sometime in the future.
|
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)
Finds a work instance.
|
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 |
---|---|
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 |
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 |
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 © 2018 Nuxeo. All rights reserved.