Package | Description |
---|---|
fr.gouv.vitam.worker.common |
Provides common classes for the Worker module.
|
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.extractseda | |
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 |
---|---|
HandlerIO |
HandlerIO.addOuputResult(int rank,
Object object,
boolean asyncIO)
Add one output result (no delete)
|
HandlerIO |
HandlerIO.addOuputResult(int rank,
Object object,
boolean deleteLocal,
boolean asyncIO)
Add one output result
|
Modifier and Type | Method and Description |
---|---|
static SedaUtils |
SedaUtilsFactory.create(HandlerIO handlerIO)
Deprecated.
|
SedaUtils |
SedaUtilsFactory.createSedaUtils(HandlerIO handlerIO) |
Constructor and Description |
---|
SedaUtils(HandlerIO handlerIO) |
Modifier and Type | Method and Description |
---|---|
void |
WorkerAction.checkMandatoryIOParameter(HandlerIO handler)
Check mandatory parameter
|
ItemStatus |
WorkerAction.execute(WorkerParameters param,
HandlerIO handler)
Execute an action
|
Constructor and Description |
---|
ArchiveUnitListener(HandlerIO handlerIO,
com.fasterxml.jackson.databind.node.ObjectNode archiveUnitTree,
Map<String,String> unitIdToGuid,
Map<String,String> unitIdToGroupId,
Map<String,List<String>> objectGroupIdToUnitId,
Map<String,String> dataObjectIdToObjectGroupId,
Map<String,GotObj> dataObjectIdWithoutObjectGroupId,
Map<String,LogbookLifeCycleParameters> guidToLifeCycleParameters,
Set<String> existingUnitGuids,
LogbookTypeProcess logbookTypeProcess,
String containerId,
MetaDataClientFactory metaDataClientFactory,
Map<String,String> objectGroupIdToGuid,
Map<String,String> dataObjectIdToGuid,
Map<String,Set<String>> unitIdToSetOfRuleId,
UnitType workflowUnitType,
List<String> originatingAgencies,
Map<String,com.fasterxml.jackson.databind.JsonNode> existingGOTs) |
Modifier and Type | Method and Description |
---|---|
HandlerIO |
ExtractSedaActionHandler.getHandlerIO() |
Modifier and Type | Method and Description |
---|---|
void |
RollBackActionHandler.checkMandatoryIOParameter(HandlerIO handler) |
void |
FinalizeLifecycleTraceabilityActionHandler.checkMandatoryIOParameter(HandlerIO handler) |
void |
CommitLifeCycleActionHandler.checkMandatoryIOParameter(HandlerIO handler) |
void |
GenerateAuditReportActionHandler.checkMandatoryIOParameter(HandlerIO handler) |
void |
ExtractSedaActionHandler.checkMandatoryIOParameter(HandlerIO handler) |
void |
ListLifecycleTraceabilityActionHandler.checkMandatoryIOParameter(HandlerIO handler) |
void |
CheckStorageAvailabilityActionHandler.checkMandatoryIOParameter(HandlerIO handler) |
void |
AccessionRegisterActionHandler.checkMandatoryIOParameter(HandlerIO handler) |
void |
VerifyTimeStampActionHandler.checkMandatoryIOParameter(HandlerIO handler) |
void |
CheckIngestContractActionHandler.checkMandatoryIOParameter(HandlerIO handler) |
void |
CheckSedaActionHandler.checkMandatoryIOParameter(HandlerIO handler) |
void |
ListArchiveUnitsActionHandler.checkMandatoryIOParameter(HandlerIO handler) |
void |
CheckHeaderActionHandler.checkMandatoryIOParameter(HandlerIO handler) |
void |
CheckNoObjectsActionHandler.checkMandatoryIOParameter(HandlerIO handler) |
void |
CheckVersionActionHandler.checkMandatoryIOParameter(HandlerIO handler) |
void |
ListRunningIngestsActionHandler.checkMandatoryIOParameter(HandlerIO handler) |
void |
DummyHandler.checkMandatoryIOParameter(HandlerIO handler) |
void |
TransferNotificationActionHandler.checkMandatoryIOParameter(HandlerIO handler) |
void |
CheckArchiveProfileRelationActionHandler.checkMandatoryIOParameter(HandlerIO handler) |
void |
VerifyMerkleTreeActionHandler.checkMandatoryIOParameter(HandlerIO handler) |
void |
CheckArchiveProfileActionHandler.checkMandatoryIOParameter(HandlerIO handler) |
void |
CheckOriginatingAgencyHandler.checkMandatoryIOParameter(HandlerIO handler) |
void |
PrepareAuditActionHandler.checkMandatoryIOParameter(HandlerIO handler) |
void |
PrepareStorageInfoActionHandler.checkMandatoryIOParameter(HandlerIO handler) |
void |
CheckObjectsNumberActionHandler.checkMandatoryIOParameter(HandlerIO handler) |
void |
CheckObjectUnitConsistencyActionHandler.checkMandatoryIOParameter(HandlerIO handler) |
void |
CheckDataObjectPackageActionHandler.checkMandatoryIOParameter(HandlerIO handler) |
void |
PrepareTraceabilityCheckProcessActionHandler.checkMandatoryIOParameter(HandlerIO handler) |
abstract void |
CommitLifeCycleActionHandler.commitLifeCycle(HandlerIO handlerIO,
String objectID,
String operationId)
Runs a commit process for the given object (Unit or ObjectGroup) and a given operation
|
void |
CommitLifeCycleUnitActionHandler.commitLifeCycle(HandlerIO handlerIO,
String objectID,
String operationId) |
void |
CommitLifeCycleObjectGroupActionHandler.commitLifeCycle(HandlerIO handlerIO,
String objectID,
String operationId) |
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) |
static void |
HandlerUtils.saveMap(HandlerIO handlerIO,
Map<String,?> map,
int rank,
boolean removeTmpFile,
boolean asyncIO)
Save the given map as specified by the rank output argument
|
Modifier and Type | Class and Description |
---|---|
class |
HandlerIOImpl
Handler input and output parameter
|
Modifier and Type | Method and Description |
---|---|
HandlerIO |
HandlerIOImpl.addOuputResult(int rank,
Object object,
boolean asyncIO) |
HandlerIO |
HandlerIOImpl.addOuputResult(int rank,
Object object,
boolean deleteLocal,
boolean asyncIO) |
Constructor and Description |
---|
AsyncWorkspaceTransfer(HandlerIO handlerAsyncIO) |
WorkspaceBatchRunner(HandlerIO handlerAsyncIO,
Executor executor,
int queueSize) |
WorkspaceTransferTask(HandlerIO handlerAsyncIO,
WorkspaceQueue task) |
Modifier and Type | Method and Description |
---|---|
void |
UpdateObjectGroupPlugin.checkMandatoryIOParameter(HandlerIO handler) |
void |
StoreMetaDataObjectGroupActionPlugin.checkMandatoryIOParameter(HandlerIO handlerIO) |
void |
CheckClassificationLevelActionPlugin.checkMandatoryIOParameter(HandlerIO handler) |
void |
RunningIngestsUpdateActionPlugin.checkMandatoryIOParameter(HandlerIO handler) |
void |
CheckIntegrityObjectPlugin.checkMandatoryIOParameter(HandlerIO handler) |
void |
CreateObjectSecureFileActionPlugin.checkMandatoryIOParameter(HandlerIO handler) |
void |
CreateUnitSecureFileActionPlugin.checkMandatoryIOParameter(HandlerIO handler) |
void |
StoreMetaDataUnitActionPlugin.checkMandatoryIOParameter(HandlerIO handler) |
void |
StoreObjectGroupActionPlugin.checkMandatoryIOParameter(HandlerIO handler) |
void |
UnitsRulesComputePlugin.checkMandatoryIOParameter(HandlerIO handler) |
void |
CheckConformityActionPlugin.checkMandatoryIOParameter(HandlerIO handler) |
void |
AuditCheckObjectPlugin.checkMandatoryIOParameter(HandlerIO handler) |
void |
CheckExistenceObjectPlugin.checkMandatoryIOParameter(HandlerIO handler) |
void |
IndexUnitActionPlugin.checkMandatoryIOParameter(HandlerIO handler) |
void |
IndexObjectGroupActionPlugin.checkMandatoryIOParameter(HandlerIO handler) |
void |
CheckArchiveUnitSchemaActionPlugin.checkMandatoryIOParameter(HandlerIO handler) |
void |
FormatIdentificationActionPlugin.checkMandatoryIOParameter(HandlerIO handler) |
void |
ArchiveUnitRulesUpdateActionPlugin.checkMandatoryIOParameter(HandlerIO handler) |
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) |
protected void |
CreateSecureFileActionPlugin.storeLifecycle(com.fasterxml.jackson.databind.JsonNode lifecycle,
String lfGuid,
HandlerIO handlerIO,
String lifecycleType) |
Modifier and Type | Method and Description |
---|---|
void |
CreateManifest.checkMandatoryIOParameter(HandlerIO handler) |
void |
PutBinaryOnWorkspace.checkMandatoryIOParameter(HandlerIO handler) |
void |
StoreDIP.checkMandatoryIOParameter(HandlerIO handler) |
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.