Package | Description |
---|---|
fr.gouv.vitam.access.external.client |
Provides
|
fr.gouv.vitam.common.client |
Contains generic VitamClient and associated basic implementation used as base for every specific client module.
|
fr.gouv.vitam.common.external.client |
Contains generic VitamClient and associated basic implementation used as base for every specific client module.
|
fr.gouv.vitam.common.model |
This package contains simple POJOs and DTOs that may be shared commonly by all vitam internal components
|
fr.gouv.vitam.common.model.processing |
Provides common public Model classes for the Processing module.
|
fr.gouv.vitam.ingest.internal.client |
Provides Ingest Internal Client interface, configuration, factory and implementations.
|
fr.gouv.vitam.processing.common.automation | |
fr.gouv.vitam.processing.common.model |
Provides common Model classes for the Processing module.
|
fr.gouv.vitam.processing.distributor.api |
Provides API classes for the Processing Distributor module
|
fr.gouv.vitam.processing.distributor.v2 | |
fr.gouv.vitam.processing.management.api |
Provides API classes for the Processing Management module
|
fr.gouv.vitam.processing.management.client |
Provides Processing Management client interface, factory and implementations.
|
fr.gouv.vitam.processing.management.core |
Provides core implementation for the Processing Management module.
|
fr.gouv.vitam.processing.model |
Specific model class for the distributor
|
fr.gouv.vitam.worker.client |
Provides Worker client interface, configuration, factory and implementations.
|
fr.gouv.vitam.worker.common.utils |
Provides common utility classes for the Worker module.
|
fr.gouv.vitam.worker.core.api |
Provides API definition for the Worker Core module.
|
fr.gouv.vitam.worker.core.handler |
Provides Handler classes for the Worker Core module
|
fr.gouv.vitam.worker.core.impl |
Provides
|
fr.gouv.vitam.worker.core.plugin |
Plugin package in worker module
|
fr.gouv.vitam.worker.core.plugin.dip | |
fr.gouv.vitam.worker.model |
Provides POJO used for XML serialization within the Worker Core module
|
Modifier and Type | Method and Description |
---|---|
ItemStatus |
OperationManagementClient.cancelOperationProcessExecution(String id)
cancelOperationProcessExecution : cancel processing operation
|
static ItemStatus |
ClientMockResultHelper.getItemStatus(String id) |
ItemStatus |
OperationManagementClient.getOperationProcessExecutionDetails(String id)
getOperationProcessExecutionDetails : get operation processing execution details
|
ItemStatus |
OperationManagementClient.getOperationProcessStatus(String id)
getOperationProcessStatus:
get operation process status**
|
Modifier and Type | Method and Description |
---|---|
RequestResponse<ItemStatus> |
OperationManagementClient.updateOperationActionProcess(String actionId,
String operationId)
updateOperationActionProcess : update operation processing status
|
Modifier and Type | Method and Description |
---|---|
static ItemStatus |
ClientMockResultHelper.getItemStatus(String id) |
Modifier and Type | Method and Description |
---|---|
protected ItemStatus |
ItemStatus.increment(ItemStatus itemStatus1,
ItemStatus itemStatus2) |
ItemStatus |
ItemStatus.increment(StatusCode statusCode) |
ItemStatus |
ItemStatus.increment(StatusCode statusCode,
int increment) |
ItemStatus |
ItemStatus.setData(String key,
Object value) |
ItemStatus |
ItemStatus.setEvDetailData(String evDetailData)
set EvDetailData
|
ItemStatus |
ItemStatus.setGlobalState(ProcessState globalState) |
ItemStatus |
ItemStatus.setItemId(String itemId) |
ItemStatus |
ItemStatus.setItemsStatus(ItemStatus compositeItemStatus) |
ItemStatus |
ItemStatus.setItemsStatus(String itemId,
ItemStatus statusDetails) |
ItemStatus |
ItemStatus.setLogbookTypeProcess(String logbookTypeProcess) |
ItemStatus |
ItemStatus.setMasterData(String key,
Object value) |
ItemStatus |
ItemStatus.setMessage(String message) |
ItemStatus |
ItemStatus.setSubTaskStatus(String taskId,
ItemStatus taskStatus) |
Modifier and Type | Method and Description |
---|---|
Map<String,ItemStatus> |
ItemStatus.getItemsStatus() |
LinkedHashMap<String,ItemStatus> |
ItemStatus.getSubTaskStatus() |
Modifier and Type | Method and Description |
---|---|
protected ItemStatus |
ItemStatus.increment(ItemStatus itemStatus1,
ItemStatus itemStatus2) |
ItemStatus |
ItemStatus.setItemsStatus(ItemStatus compositeItemStatus) |
ItemStatus |
ItemStatus.setItemsStatus(String itemId,
ItemStatus statusDetails) |
ItemStatus |
ItemStatus.setSubTaskStatus(String taskId,
ItemStatus taskStatus) |
Constructor and Description |
---|
ItemStatus(String itemId,
String message,
StatusCode globalStatus,
List<Integer> statusMeter,
Map<String,Object> data,
LinkedHashMap<String,ItemStatus> itemsStatus,
String evDetailData,
ProcessState globalState) |
Modifier and Type | Method and Description |
---|---|
ItemStatus |
Step.getStepResponses() |
Modifier and Type | Method and Description |
---|---|
Step |
Step.setStepResponses(ItemStatus stepResponses) |
Modifier and Type | Method and Description |
---|---|
ItemStatus |
IngestInternalClientMock.cancelOperationProcessExecution(String id) |
ItemStatus |
IngestInternalClientMock.getOperationProcessExecutionDetails(String id) |
ItemStatus |
IngestInternalClientMock.getOperationProcessStatus(String id) |
Modifier and Type | Method and Description |
---|---|
RequestResponse<ItemStatus> |
IngestInternalClientMock.updateOperationActionProcess(String actionId,
String operationId) |
Modifier and Type | Method and Description |
---|---|
void |
IEventsProcessEngine.onComplete(ItemStatus itemStatus,
WorkerParameters workerParameters)
The ProcessEngine callback on complete step (for any status code)
|
Modifier and Type | Method and Description |
---|---|
ItemStatus |
DistributorIndex.getItemStatus() |
Modifier and Type | Method and Description |
---|---|
void |
DistributorIndex.setItemStatus(ItemStatus itemStatus) |
Constructor and Description |
---|
DistributorIndex(String level,
int offset,
ItemStatus itemStatus,
String requestId,
String stepId,
List<String> remainingElements) |
Modifier and Type | Method and Description |
---|---|
ItemStatus |
ProcessDistributor.distribute(WorkerParameters workParams,
Step step,
String operationId,
PauseRecover pauseRecover)
Distribute different steps (execute a workflow actions step by step)
|
Modifier and Type | Method and Description |
---|---|
ItemStatus |
ProcessDistributorImpl.distribute(WorkerParameters workParams,
Step step,
String operationId,
PauseRecover pauseRecover)
Temporary method for distribution supporting multi-list
|
ItemStatus |
WorkerTask.get() |
Modifier and Type | Method and Description |
---|---|
ItemStatus |
ProcessManagement.cancel(String operationId,
Integer tenantId)
Handle a cancel action for the corresponding process workflow
|
ItemStatus |
ProcessManagement.next(WorkerParameters workerParameters,
Integer tenantId)
Handle a next action for the corresponding process workflow
|
ItemStatus |
ProcessManagement.pause(String operationId,
Integer tenantId)
Handle a pause action for the corresponding process workflow
|
ItemStatus |
ProcessManagement.replay(WorkerParameters workerParameters,
Integer tenantId)
Handle a replay action for the corresponding process workflow
|
ItemStatus |
ProcessManagement.resume(WorkerParameters workerParameters,
Integer tenantId)
Handle a resume action for the corresponding process workflow
|
Modifier and Type | Method and Description |
---|---|
ItemStatus |
ProcessingManagementClientMock.cancelOperationProcessExecution(String id) |
ItemStatus |
ProcessingManagementClientMock.getOperationProcessExecutionDetails(String id) |
ItemStatus |
ProcessingManagementClientMock.getOperationProcessStatus(String id) |
Modifier and Type | Method and Description |
---|---|
RequestResponse<ItemStatus> |
ProcessingManagementClientMock.updateOperationActionProcess(String actionId,
String operationId) |
Modifier and Type | Method and Description |
---|---|
ItemStatus |
ProcessManagementImpl.cancel(String operationId,
Integer tenantId) |
ItemStatus |
ProcessManagementImpl.next(WorkerParameters workerParameters,
Integer tenantId) |
ItemStatus |
ProcessManagementImpl.pause(String operationId,
Integer tenantId) |
ItemStatus |
ProcessManagementImpl.replay(WorkerParameters workerParameters,
Integer tenantId) |
ItemStatus |
ProcessManagementImpl.resume(WorkerParameters workerParameters,
Integer tenantId) |
Modifier and Type | Method and Description |
---|---|
void |
StateMachine.onComplete(ItemStatus itemStatus,
WorkerParameters workerParameters) |
Modifier and Type | Method and Description |
---|---|
ItemStatus |
WorkerAsyncResponse.getCompositeItemStatus() |
Modifier and Type | Method and Description |
---|---|
WorkerAsyncResponse |
WorkerAsyncResponse.setItemStatus(ItemStatus ItemStatus) |
Constructor and Description |
---|
WorkerAsyncResponse(WorkerAsyncRequest workerAsyncRequest,
ItemStatus itemStatus) |
Modifier and Type | Method and Description |
---|---|
ItemStatus |
WorkerClient.submitStep(DescriptionStep step)
add a step to the worker
|
Modifier and Type | Method and Description |
---|---|
SedaUtils.CheckSedaValidationStatus |
SedaUtils.checkSedaValidation(WorkerParameters params,
ItemStatus itemStatus)
The method is used to validate SEDA by XSD
|
static void |
LogbookLifecycleWorkerHelper.setLifeCycleFinalEventStatusByStep(LogbookLifeCyclesClientHelper helper,
LogbookLifeCycleParameters logbookLifecycleParameters,
ItemStatus itemStatus) |
Modifier and Type | Method and Description |
---|---|
ItemStatus |
WorkerAction.execute(WorkerParameters param,
HandlerIO handler)
Execute an action
|
ItemStatus |
Worker.run(WorkerParameters workParams,
Step step)
Worker execute the step's actions
|
Modifier and Type | Method and Description |
---|---|
abstract ItemStatus |
CommitLifeCycleActionHandler.buildFinalItemStatus(ItemStatus itemStatus)
Returns the final ItemStatus related to the current actionHandler execution based on a given one
|
ItemStatus |
CommitLifeCycleUnitActionHandler.buildFinalItemStatus(ItemStatus itemStatus) |
ItemStatus |
CommitLifeCycleObjectGroupActionHandler.buildFinalItemStatus(ItemStatus itemStatus) |
ItemStatus |
RollBackActionHandler.execute(WorkerParameters params,
HandlerIO param) |
ItemStatus |
FinalizeLifecycleTraceabilityActionHandler.execute(WorkerParameters params,
HandlerIO handler) |
ItemStatus |
CommitLifeCycleActionHandler.execute(WorkerParameters params,
HandlerIO param) |
ItemStatus |
GenerateAuditReportActionHandler.execute(WorkerParameters param,
HandlerIO handler) |
ItemStatus |
ExtractSedaActionHandler.execute(WorkerParameters params,
HandlerIO ioParam) |
ItemStatus |
ListLifecycleTraceabilityActionHandler.execute(WorkerParameters params,
HandlerIO handler) |
ItemStatus |
CheckStorageAvailabilityActionHandler.execute(WorkerParameters params,
HandlerIO handlerIO) |
ItemStatus |
AccessionRegisterActionHandler.execute(WorkerParameters params,
HandlerIO handler) |
ItemStatus |
VerifyTimeStampActionHandler.execute(WorkerParameters param,
HandlerIO handler) |
ItemStatus |
CheckIngestContractActionHandler.execute(WorkerParameters params,
HandlerIO ioParam) |
ItemStatus |
CheckSedaActionHandler.execute(WorkerParameters params,
HandlerIO handlerIO) |
ItemStatus |
ListArchiveUnitsActionHandler.execute(WorkerParameters params,
HandlerIO handler) |
ItemStatus |
CheckHeaderActionHandler.execute(WorkerParameters params,
HandlerIO handlerIO) |
ItemStatus |
CheckNoObjectsActionHandler.execute(WorkerParameters params,
HandlerIO handlerIO) |
ItemStatus |
CheckVersionActionHandler.execute(WorkerParameters params,
HandlerIO handlerIO) |
ItemStatus |
ListRunningIngestsActionHandler.execute(WorkerParameters params,
HandlerIO handler) |
ItemStatus |
DummyHandler.execute(WorkerParameters param,
HandlerIO handler) |
ItemStatus |
TransferNotificationActionHandler.execute(WorkerParameters params,
HandlerIO handler) |
ItemStatus |
CheckArchiveProfileRelationActionHandler.execute(WorkerParameters params,
HandlerIO handlerIO) |
ItemStatus |
VerifyMerkleTreeActionHandler.execute(WorkerParameters params,
HandlerIO handler) |
ItemStatus |
CheckArchiveProfileActionHandler.execute(WorkerParameters params,
HandlerIO handlerIO) |
ItemStatus |
CheckOriginatingAgencyHandler.execute(WorkerParameters param,
HandlerIO handler) |
ItemStatus |
PrepareAuditActionHandler.execute(WorkerParameters param,
HandlerIO handler) |
ItemStatus |
PrepareStorageInfoActionHandler.execute(WorkerParameters params,
HandlerIO handlerIO) |
ItemStatus |
CheckObjectsNumberActionHandler.execute(WorkerParameters params,
HandlerIO handlerIO) |
ItemStatus |
CheckObjectUnitConsistencyActionHandler.execute(WorkerParameters params,
HandlerIO handler) |
ItemStatus |
CheckDataObjectPackageActionHandler.execute(WorkerParameters params,
HandlerIO handlerIO) |
ItemStatus |
PrepareTraceabilityCheckProcessActionHandler.execute(WorkerParameters param,
HandlerIO handler) |
abstract ItemStatus |
CommitLifeCycleActionHandler.getItemStatus()
Returns an ItemStatus
|
ItemStatus |
CommitLifeCycleUnitActionHandler.getItemStatus() |
ItemStatus |
CommitLifeCycleObjectGroupActionHandler.getItemStatus() |
Modifier and Type | Method and Description |
---|---|
abstract ItemStatus |
CommitLifeCycleActionHandler.buildFinalItemStatus(ItemStatus itemStatus)
Returns the final ItemStatus related to the current actionHandler execution based on a given one
|
ItemStatus |
CommitLifeCycleUnitActionHandler.buildFinalItemStatus(ItemStatus itemStatus) |
ItemStatus |
CommitLifeCycleObjectGroupActionHandler.buildFinalItemStatus(ItemStatus itemStatus) |
com.fasterxml.jackson.databind.node.ObjectNode |
ExtractSedaActionHandler.extractSEDA(LogbookLifeCyclesClient logbookLifeCycleClient,
WorkerParameters params,
ItemStatus globalCompositeItemStatus,
UnitType workflowUnitType)
Split Element from InputStream and write it to workspace
|
void |
ActionHandler.updateDetailItemStatus(ItemStatus globalCompositeItemStatus,
String value,
String globalOutcomeDetailSubcode)
Update a detail item status
|
Modifier and Type | Method and Description |
---|---|
ItemStatus |
WorkerImpl.run(WorkerParameters workParams,
Step step) |
Modifier and Type | Method and Description |
---|---|
ItemStatus |
UpdateObjectGroupPlugin.execute(WorkerParameters params,
HandlerIO handlerIO) |
ItemStatus |
StoreMetaDataObjectGroupActionPlugin.execute(WorkerParameters params,
HandlerIO actionDefinition) |
ItemStatus |
CheckClassificationLevelActionPlugin.execute(WorkerParameters param,
HandlerIO handler) |
ItemStatus |
RunningIngestsUpdateActionPlugin.execute(WorkerParameters params,
HandlerIO handler) |
ItemStatus |
CheckIntegrityObjectPlugin.execute(WorkerParameters params,
HandlerIO handler) |
ItemStatus |
CreateObjectSecureFileActionPlugin.execute(WorkerParameters params,
HandlerIO handler) |
ItemStatus |
CreateUnitSecureFileActionPlugin.execute(WorkerParameters params,
HandlerIO handler) |
ItemStatus |
StoreMetaDataUnitActionPlugin.execute(WorkerParameters params,
HandlerIO actionDefinition) |
ItemStatus |
StoreObjectGroupActionPlugin.execute(WorkerParameters params,
HandlerIO actionDefinition) |
ItemStatus |
UnitsRulesComputePlugin.execute(WorkerParameters params,
HandlerIO handler) |
ItemStatus |
CheckConformityActionPlugin.execute(WorkerParameters params,
HandlerIO handler) |
ItemStatus |
AuditCheckObjectPlugin.execute(WorkerParameters param,
HandlerIO handler) |
ItemStatus |
CheckExistenceObjectPlugin.execute(WorkerParameters params,
HandlerIO handler) |
ItemStatus |
IndexUnitActionPlugin.execute(WorkerParameters params,
HandlerIO param) |
ItemStatus |
IndexObjectGroupActionPlugin.execute(WorkerParameters params,
HandlerIO actionDefinition) |
ItemStatus |
CheckArchiveUnitSchemaActionPlugin.execute(WorkerParameters params,
HandlerIO handler) |
ItemStatus |
FormatIdentificationActionPlugin.execute(WorkerParameters params,
HandlerIO handler) |
ItemStatus |
ArchiveUnitRulesUpdateActionPlugin.execute(WorkerParameters params,
HandlerIO handler) |
Modifier and Type | Method and Description |
---|---|
protected StoredInfoResult |
StoreObjectActionHandler.storeObject(ObjectDescription description,
ItemStatus itemStatus)
The function is used for retrieving ObjectGroup in workspace and storing metaData in storage offer
|
Modifier and Type | Method and Description |
---|---|
ItemStatus |
CreateManifest.execute(WorkerParameters param,
HandlerIO handlerIO) |
ItemStatus |
PutBinaryOnWorkspace.execute(WorkerParameters param,
HandlerIO handler) |
ItemStatus |
StoreDIP.execute(WorkerParameters params,
HandlerIO handler) |
Constructor and Description |
---|
LogbookLifeCycleTraceabilityHelper(HandlerIO handlerIO,
LogbookOperationsClient logbookOperationsClient,
ItemStatus itemStatus,
String operationID) |
Copyright © 2018 Vitam. All rights reserved.