Modifier and Type | Method and Description |
---|---|
javax.ws.rs.core.Response |
BatchReportResource.exportDistinctObjectGroup(String processId,
com.fasterxml.jackson.databind.JsonNode body) |
javax.ws.rs.core.Response |
BatchReportResource.exportEliminationActionAccessionRegister(String processId,
com.fasterxml.jackson.databind.JsonNode body) |
javax.ws.rs.core.Response |
BatchReportResource.exportObjectGroup(String processId,
com.fasterxml.jackson.databind.JsonNode body) |
javax.ws.rs.core.Response |
BatchReportResource.exportUnitReport(String processId,
com.fasterxml.jackson.databind.JsonNode body) |
Modifier and Type | Method and Description |
---|---|
void |
BatchReportServiceImpl.exportEliminationActionAccessionRegister(String processId,
String filename,
int tenantId) |
void |
BatchReportServiceImpl.exportEliminationActionDistinctObjectGroupOfDeletedUnits(String processId,
String filename,
int tenantId) |
void |
BatchReportServiceImpl.exportEliminationActionObjectGroupReport(String processId,
String fileName,
int tenantId) |
void |
BatchReportServiceImpl.exportEliminationActionUnitReport(String processId,
String fileName,
int tenantId) |
Modifier and Type | Method and Description |
---|---|
String |
ContentAddressableStorage.computeObjectDigest(String containerName,
String objectName,
DigestType algo)
compute Object Digest using a defined algorithm
|
long |
ContentAddressableStorage.countObjects(String containerName)
Determines if a container exists
|
void |
ContentAddressableStorage.createContainer(String containerName)
Creates a container
|
ContainerInformation |
ContentAddressableStorage.getContainerInformation(String containerName)
Get container information like capacity
|
boolean |
ContentAddressableStorage.isExistingContainer(String containerName)
Determines if a container exists
|
boolean |
ContentAddressableStorage.isExistingObject(String containerName,
String objectName)
Determines if an object exists
|
VitamPageSet<? extends VitamStorageMetadata> |
ContentAddressableStorage.listContainer(String containerName)
List container (create cursor)
|
VitamPageSet<? extends VitamStorageMetadata> |
ContentAddressableStorage.listContainerNext(String containerName,
String nextMarker)
List container (next on cursor)
|
Modifier and Type | Method and Description |
---|---|
long |
HashFileSystem.countObjects(String containerName) |
void |
HashFileSystem.createContainer(String containerName) |
void |
HashFileSystemHelper.createContainer(String container)
Create a directory recursively in the sub tree
|
void |
HashFileSystemHelper.createDirectories(Path path)
Create recursively the directories
|
ContainerInformation |
HashFileSystem.getContainerInformation(String containerName) |
Path |
HashFileSystemHelper.getPathObject(String container,
String objectId)
Get the path of an object based on its container and the objectId
|
boolean |
HashFileSystem.isExistingContainer(String containerName) |
boolean |
HashFileSystem.isExistingObject(String containerName,
String objectName) |
VitamPageSet<? extends VitamStorageMetadata> |
HashFileSystem.listContainerNext(String containerName,
String nextMarker) |
List<String> |
HashFileSystemHelper.splitObjectId(String objectId)
Split objectId without extension
|
Modifier and Type | Method and Description |
---|---|
void |
Swift.createContainer(String containerName)
Abstract method to get authenticated openstack client, allow to switch between Keystone V2 and Keystone V3
|
void |
Swift.deleteObject(String containerName,
String objectName) |
Modifier and Type | Method and Description |
---|---|
boolean |
StorageStep.store(Path sip,
String uri,
String strategy,
String guid)
Store a file
|
Modifier and Type | Method and Description |
---|---|
com.fasterxml.jackson.databind.JsonNode |
DefaultOfferServiceImpl.countObjects(String containerName) |
com.fasterxml.jackson.databind.JsonNode |
DefaultOfferService.countObjects(String containerName)
Count the number of objects in a container defined by the tenant and the type
|
String |
DefaultOfferServiceImpl.createCursor(String containerName) |
String |
DefaultOfferService.createCursor(String containerName)
Create a new cursor for listing container operation
|
com.fasterxml.jackson.databind.JsonNode |
DefaultOfferServiceImpl.getCapacity(String containerName) |
com.fasterxml.jackson.databind.JsonNode |
DefaultOfferService.getCapacity(String containerName)
Get container capacity
|
List<OfferLog> |
DefaultOfferServiceImpl.getOfferLogs(String containerName,
Long offset,
int limit,
Order order) |
List<OfferLog> |
DefaultOfferService.getOfferLogs(String containerName,
Long offset,
int limit,
Order order)
Get the offer log of objects created in offer container
|
ObjectInit |
DefaultOfferServiceImpl.initCreateObject(String containerName,
ObjectInit objectInit,
String objectGUID) |
ObjectInit |
DefaultOfferService.initCreateObject(String containerName,
ObjectInit objectInit,
String objectGUID)
Initialize object creation
Create container on offer if does not exist for one object Also update digest type and object GUID
|
boolean |
DefaultOfferServiceImpl.isObjectExist(String containerName,
String objectId) |
boolean |
DefaultOfferService.isObjectExist(String containerName,
String objectId)
Check if object exists
|
List<com.fasterxml.jackson.databind.JsonNode> |
DefaultOfferServiceImpl.next(String containerName,
String cursorId) |
List<com.fasterxml.jackson.databind.JsonNode> |
DefaultOfferService.next(String containerName,
String cursorId)
Get next values
|
Modifier and Type | Method and Description |
---|---|
void |
OfferLogDatabaseService.save(String containerName,
String fileName,
OfferLogAction action)
Save on offerLog.
|
List<OfferLog> |
OfferLogDatabaseService.searchOfferLog(String containerName,
Long offset,
int limit,
Order order)
Search in offer log
|
Modifier and Type | Method and Description |
---|---|
File |
HandlerIO.getFileFromWorkspace(String objectName)
Helper to load a file from Workspace (or local cache) and save it into local cache.
To be used when not specified within the Input parameters |
InputStream |
HandlerIO.getInputStreamFromWorkspace(String objectName)
Helper to get an InputStream (using local cache if possible) from Workspace
To be used when not specified within the Input parameters |
javax.ws.rs.core.Response |
HandlerIO.getInputStreamNoCachedFromWorkspace(String objectName)
Helper to get an InputStream (without cache) from Workspace
To be used when not specified within the Input parameters |
Modifier and Type | Method and Description |
---|---|
ItemStatus |
WorkerAction.execute(WorkerParameters param,
HandlerIO handler)
Execute an action
|
default List<ItemStatus> |
WorkerAction.executeList(WorkerParameters workerParameters,
HandlerIO handler) |
ItemStatus |
Worker.run(WorkerParameters workParams,
Step step)
Worker execute the step's actions
|
Modifier and Type | Method and Description |
---|---|
ItemStatus |
CheckNoObjectsActionHandler.execute(WorkerParameters params,
HandlerIO handlerIO) |
ItemStatus |
GenerateAuditReportActionHandler.execute(WorkerParameters param,
HandlerIO handler) |
ItemStatus |
CheckDataObjectPackageActionHandler.execute(WorkerParameters params,
HandlerIO handlerIO) |
ItemStatus |
PrepareAuditActionHandler.execute(WorkerParameters param,
HandlerIO handler) |
ItemStatus |
CheckConcurrentWorkflowLockHandler.execute(WorkerParameters param,
HandlerIO handler) |
ItemStatus |
VerifyTimeStampActionHandler.execute(WorkerParameters param,
HandlerIO handler) |
ItemStatus |
CheckObjectsNumberActionHandler.execute(WorkerParameters params,
HandlerIO handlerIO) |
void |
GenerateAuditReportActionHandler.storeAuditReport(String guid,
InputStream report) |
Modifier and Type | Method and Description |
---|---|
File |
HandlerIOImpl.getFileFromWorkspace(String objectName) |
InputStream |
HandlerIOImpl.getInputStreamFromWorkspace(String objectName) |
javax.ws.rs.core.Response |
HandlerIOImpl.getInputStreamNoCachedFromWorkspace(String objectName) |
Modifier and Type | Method and Description |
---|---|
ItemStatus |
CheckIntegrityObjectPlugin.execute(WorkerParameters params,
HandlerIO handler) |
ItemStatus |
AuditCheckObjectPlugin.execute(WorkerParameters param,
HandlerIO handler) |
Modifier and Type | Method and Description |
---|---|
ItemStatus |
PutBinaryOnWorkspace.execute(WorkerParameters param,
HandlerIO handler) |
ItemStatus |
StoreDIP.execute(WorkerParameters params,
HandlerIO handler) |
Modifier and Type | Method and Description |
---|---|
ItemStatus |
EliminationAnalysisUnitIndexationPlugin.execute(WorkerParameters param,
HandlerIO handler) |
ItemStatus |
EliminationActionCheckDistributionThresholdHandler.execute(WorkerParameters param,
HandlerIO handler) |
ItemStatus |
EliminationAnalysisCheckDistributionThresholdHandler.execute(WorkerParameters param,
HandlerIO handler) |
ItemStatus |
EliminationActionAccessionRegisterUpdatePlugin.execute(WorkerParameters param,
HandlerIO handler) |
ItemStatus |
EliminationActionReportGenerationHandler.execute(WorkerParameters param,
HandlerIO handler) |
ItemStatus |
EliminationAnalysisPreparationHandler.execute(WorkerParameters param,
HandlerIO handler) |
ItemStatus |
EliminationActionFinalizationHandler.execute(WorkerParameters param,
HandlerIO handler) |
ItemStatus |
EliminationActionObjectGroupPreparationHandler.execute(WorkerParameters param,
HandlerIO handler) |
ItemStatus |
EliminationActionUnitPreparationHandler.execute(WorkerParameters param,
HandlerIO handler) |
ItemStatus |
EliminationAnalysisFinalizationHandler.execute(WorkerParameters param,
HandlerIO handler) |
ItemStatus |
EliminationActionAccessionRegisterPreparationHandler.execute(WorkerParameters param,
HandlerIO handler) |
Modifier and Type | Method and Description |
---|---|
ItemStatus |
DataRectificationStep.execute(WorkerParameters param,
HandlerIO handler) |
ItemStatus |
EvidenceAuditGenerateReports.execute(WorkerParameters param,
HandlerIO handlerIO) |
ItemStatus |
DataCorrectionFinalize.execute(WorkerParameters param,
HandlerIO handlerIO) |
ItemStatus |
EvidenceAuditFinalize.execute(WorkerParameters param,
HandlerIO handlerIO) |
Modifier and Type | Method and Description |
---|---|
ItemStatus |
CheckDistributionThreshold.execute(WorkerParameters param,
HandlerIO handler)
Execute an action
|
ItemStatus |
MassUpdateFinalize.execute(WorkerParameters param,
HandlerIO handler)
Execute an action
|
ItemStatus |
PrepareUpdateUnits.execute(WorkerParameters param,
HandlerIO handler)
Execute an action
|
ItemStatus |
MassUpdateUnitsRulesProcess.execute(WorkerParameters param,
HandlerIO handler)
Execute an action
|
ItemStatus |
MassUpdateUnitsProcess.execute(WorkerParameters param,
HandlerIO handler)
Execute an action
|
List<ItemStatus> |
MassUpdateUnitsRulesProcess.executeList(WorkerParameters workerParameters,
HandlerIO handler)
executeList for bulk update units.
|
List<ItemStatus> |
MassUpdateUnitsProcess.executeList(WorkerParameters workerParameters,
HandlerIO handler)
executeList for bulk update units.
|
Modifier and Type | Method and Description |
---|---|
ItemStatus |
MigrationFinalize.execute(WorkerParameters param,
HandlerIO handlerIO) |
ItemStatus |
MigrationUnits.execute(WorkerParameters param,
HandlerIO handler) |
ItemStatus |
MigrationObjectGroups.execute(WorkerParameters param,
HandlerIO handler) |
Modifier and Type | Method and Description |
---|---|
ItemStatus |
ProbativeValueGenerateReports.execute(WorkerParameters param,
HandlerIO handlerIO) |
com.fasterxml.jackson.databind.node.ObjectNode |
ProbativeValueReport.gatherOperationInfo(HandlerIO handler,
WorkerParameters param,
String endDate) |
Modifier and Type | Method and Description |
---|---|
ItemStatus |
ReclassificationPreparationCheckGraphHandler.execute(WorkerParameters param,
HandlerIO handler) |
ItemStatus |
ReclassificationPreparationLoadRequestHandler.execute(WorkerParameters param,
HandlerIO handler) |
ItemStatus |
ReclassificationPreparationUpdateDistributionHandler.execute(WorkerParameters param,
HandlerIO handler) |
ItemStatus |
UnitDetachmentPlugin.execute(WorkerParameters param,
HandlerIO handler) |
ItemStatus |
UnitAttachmentPlugin.execute(WorkerParameters param,
HandlerIO handler) |
ItemStatus |
ReclassificationFinalizationHandler.execute(WorkerParameters param,
HandlerIO handler) |
Modifier and Type | Method and Description |
---|---|
void |
WorkspaceClient.compress(String containerName,
CompressInformation compressInformation)
Compress
|
long |
WorkspaceClient.countObjects(String containerName)
Count the number of object in a container
|
void |
WorkspaceClient.createContainer(String containerName)
Create container
|
void |
WorkspaceClient.createFolder(String containerName,
String folderName)
Create a folder
|
void |
WorkspaceClient.deleteContainer(String containerName,
boolean recursive)
Delete container
|
void |
WorkspaceClient.deleteFolder(String containerName,
String folderName)
Delete folder
|
void |
WorkspaceClient.deleteObject(String containerName,
String objectName)
Delete object
|
RequestResponse<ContainerInformation> |
WorkspaceClient.getContainerInformation(String containerName) |
RequestResponse<List<URI>> |
WorkspaceClient.getListUriDigitalObjectFromFolder(String containerName,
String folderName)
Get List of digital object
|
javax.ws.rs.core.Response |
WorkspaceClient.getObject(String containerName,
String objectName)
Get Object
|
RequestResponse<com.fasterxml.jackson.databind.JsonNode> |
WorkspaceClient.getObjectInformation(String containerName,
String objectName)
Get Object Information
|
boolean |
WorkspaceClient.isExistingContainer(String containerName)
Check if container exists
|
boolean |
WorkspaceClient.isExistingFolder(String containerName,
String folderName)
Check if folder exists
|
boolean |
WorkspaceClient.isExistingObject(String containerName,
String objectName)
Check if obejct is existing
|
void |
WorkspaceClient.putObject(String containerName,
String objectName,
InputStream stream)
Put object
|
Modifier and Type | Method and Description |
---|---|
void |
WorkspaceFileSystem.createContainer(String containerName) |
void |
WorkspaceContentAddressableStorage.createContainer(String containerName)
Creates a container
|
void |
WorkspaceFileSystem.createFolder(String containerName,
String folderName) |
void |
WorkspaceContentAddressableStorage.createFolder(String containerName,
String folderName)
Creates a folder (or a directory) marker depending on the service
|
void |
WorkspaceFileSystem.deleteContainer(String containerName,
boolean recursive) |
void |
WorkspaceContentAddressableStorage.deleteContainer(String containerName,
boolean recursive)
Deletes everything inside a container recursively.
|
void |
WorkspaceFileSystem.deleteFolder(String containerName,
String folderName) |
void |
WorkspaceContentAddressableStorage.deleteFolder(String containerName,
String folderName)
Deletes a folder (or a directory) marker depending on the service
|
ContainerInformation |
WorkspaceFileSystem.getContainerInformation(String containerName) |
ContainerInformation |
WorkspaceContentAddressableStorage.getContainerInformation(String containerName)
Get container information like capacity
|
void |
WorkspaceFileSystem.purgeContainer(String containerName) |
void |
WorkspaceContentAddressableStorage.purgeContainer(String containerName)
Deletes the contents of a container at its root path without deleting the container
|
Copyright © 2018 Vitam. All rights reserved.