Modifier and Type | Method and Description |
---|---|
javax.ws.rs.core.Response |
BatchReportResource.exportDistinctObjectGroup(String processId,
ReportExportRequest reportExportRequest) |
javax.ws.rs.core.Response |
BatchReportResource.exportPreservation(String processId,
com.fasterxml.jackson.databind.JsonNode body) |
javax.ws.rs.core.Response |
BatchReportResource.exportPurgeAccessionRegister(String processId,
ReportExportRequest reportExportRequest) |
javax.ws.rs.core.Response |
BatchReportResource.exportUnitsToInvalidate(String processId,
ReportExportRequest reportExportRequest) |
Modifier and Type | Method and Description |
---|---|
void |
BatchReportServiceImpl.exportPreservationReport(String processId,
String fileName,
int tenantId) |
void |
BatchReportServiceImpl.exportPurgeAccessionRegister(String processId,
String filename,
int tenantId) |
void |
BatchReportServiceImpl.exportPurgeDistinctObjectGroupOfDeletedUnits(String processId,
String filename,
int tenantId) |
void |
BatchReportServiceImpl.exportUnitsToInvalidate(String processId,
int tenantId,
ReportExportRequest reportExportRequest) |
Modifier and Type | Method and Description |
---|---|
void |
OpenstackSwift.removeReadOrderRequest(String readRequestID) |
Modifier and Type | Method and Description |
---|---|
void |
ContentAddressableStorage.createContainer(String containerName)
Creates a container
|
ContainerInformation |
ContentAddressableStorage.getContainerInformation(String containerName)
Get container information like capacity
|
String |
ContentAddressableStorage.getObjectDigest(String containerName,
String objectName,
DigestType algo,
boolean noCache)
compute Object Digest using a defined algorithm
|
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)
|
void |
ContentAddressableStorage.removeReadOrderRequest(String readRequestID)
Purge all read request id to cleanup local FS
|
Modifier and Type | Method and Description |
---|---|
void |
HashFileSystemHelper.checkContainerPathTraversal(String containerName) |
void |
HashFileSystemHelper.createContainer(String container)
Create a directory recursively in the sub tree
|
void |
HashFileSystem.createContainer(String containerName) |
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.isExistingObject(String containerName,
String objectName) |
VitamPageSet<? extends VitamStorageMetadata> |
HashFileSystem.listContainer(String containerName) |
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 |
AmazonS3V1.createContainer(String containerName) |
ContainerInformation |
AmazonS3V1.getContainerInformation(String containerName) |
String |
AmazonS3V1.getObjectDigest(String containerName,
String objectName,
DigestType digestType,
boolean noCache) |
boolean |
AmazonS3V1.isExistingContainer(String containerName) |
boolean |
AmazonS3V1.isExistingObject(String containerName,
String objectName) |
VitamPageSet<? extends VitamStorageMetadata> |
AmazonS3V1.listContainer(String containerName) |
VitamPageSet<? extends VitamStorageMetadata> |
AmazonS3V1.listContainerNext(String containerName,
String nextMarker) |
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 |
---|---|
void |
ExportsPurgeService.purgeExpiredFiles(String container) |
Modifier and Type | Method and Description |
---|---|
String |
DefaultOfferServiceImpl.createCursor(String containerName) |
String |
DefaultOfferService.createCursor(String containerName)
Create a new cursor for listing container operation
|
ContainerInformation |
DefaultOfferServiceImpl.getCapacity(String containerName) |
ContainerInformation |
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
|
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.bulkSave(String containerName,
List<String> fileNames,
OfferLogAction action)
Save on offerLog.
|
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 |
---|---|
String |
TapeLibraryContentAddressableStorage.createReadOrderRequest(String containerName,
List<String> objectsIds) |
void |
TapeLibraryContentAddressableStorage.deleteObject(String containerName,
String objectName) |
ObjectContent |
TapeLibraryContentAddressableStorage.getObject(String containerName,
String objectName) |
boolean |
TapeLibraryContentAddressableStorage.isExistingObject(String containerName,
String objectName) |
void |
TapeLibraryContentAddressableStorage.removeReadOrderRequest(String readRequestID) |
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 |
---|---|
default 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 |
CheckConcurrentWorkflowLockHandler.execute(WorkerParameters param,
HandlerIO handler) |
ItemStatus |
CheckNoObjectsActionHandler.execute(WorkerParameters params,
HandlerIO handlerIO) |
ItemStatus |
CheckObjectsNumberActionHandler.execute(WorkerParameters params,
HandlerIO handlerIO) |
ItemStatus |
CheckDataObjectPackageActionHandler.execute(WorkerParameters params,
HandlerIO handlerIO) |
ItemStatus |
VerifyTimeStampActionHandler.execute(WorkerParameters param,
HandlerIO handler) |
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 |
AuditPreparePlugin.execute(WorkerParameters param,
HandlerIO handler) |
ItemStatus |
AuditFinalizePlugin.execute(WorkerParameters param,
HandlerIO handler) |
ItemStatus |
AuditCheckObjectPlugin.execute(WorkerParameters param,
HandlerIO handler) |
Modifier and Type | Method and Description |
---|---|
ItemStatus |
ComputeInheritedRulesPreparationPlugin.execute(WorkerParameters param,
HandlerIO handler) |
ItemStatus |
ComputeInheritedRulesFinalizationPlugin.execute(WorkerParameters param,
HandlerIO handler) |
Modifier and Type | Method and Description |
---|---|
ItemStatus |
StoreExports.execute(WorkerParameters params,
HandlerIO handler) |
ItemStatus |
PutBinaryOnWorkspace.execute(WorkerParameters param,
HandlerIO handler) |
Modifier and Type | Method and Description |
---|---|
ItemStatus |
EliminationActionCheckDistributionThresholdHandler.execute(WorkerParameters param,
HandlerIO handler) |
ItemStatus |
EliminationAnalysisPreparationHandler.execute(WorkerParameters param,
HandlerIO handler) |
ItemStatus |
EliminationActionReportGenerationHandler.execute(WorkerParameters param,
HandlerIO handler) |
ItemStatus |
EliminationActionFinalizationHandler.execute(WorkerParameters param,
HandlerIO handler) |
ItemStatus |
EliminationAnalysisFinalizationHandler.execute(WorkerParameters param,
HandlerIO handler) |
ItemStatus |
EliminationActionUnitPreparationHandler.execute(WorkerParameters param,
HandlerIO handler) |
ItemStatus |
EliminationAnalysisCheckDistributionThresholdHandler.execute(WorkerParameters param,
HandlerIO handler) |
ItemStatus |
EliminationAnalysisUnitIndexationPlugin.execute(WorkerParameters param,
HandlerIO handler) |
Modifier and Type | Method and Description |
---|---|
ItemStatus |
EvidenceAuditGenerateReports.execute(WorkerParameters param,
HandlerIO handlerIO) |
ItemStatus |
EvidenceAuditFinalize.execute(WorkerParameters param,
HandlerIO handlerIO) |
ItemStatus |
DataCorrectionFinalize.execute(WorkerParameters param,
HandlerIO handlerIO) |
ItemStatus |
DataRectificationStep.execute(WorkerParameters param,
HandlerIO handler) |
Modifier and Type | Method and Description |
---|---|
ItemStatus |
BuildObjectGroupTraceabilityActionPlugin.execute(WorkerParameters params,
HandlerIO handler) |
ItemStatus |
PrepareObjectGroupLfcTraceabilityActionPlugin.execute(WorkerParameters params,
HandlerIO handler) |
ItemStatus |
PrepareUnitLfcTraceabilityActionPlugin.execute(WorkerParameters params,
HandlerIO handler) |
ItemStatus |
BuildUnitTraceabilityActionPlugin.execute(WorkerParameters params,
HandlerIO handler) |
Modifier and Type | Method and Description |
---|---|
ItemStatus |
PrepareUpdateUnits.execute(WorkerParameters param,
HandlerIO handler)
Execute an action
|
ItemStatus |
MassUpdateFinalize.execute(WorkerParameters param,
HandlerIO handler) |
ItemStatus |
CheckDistributionThreshold.execute(WorkerParameters param,
HandlerIO handler) |
Modifier and Type | Method and Description |
---|---|
ItemStatus |
MassUpdateUnitsProcess.execute(WorkerParameters param,
HandlerIO handler)
Execute an action
|
Modifier and Type | Method and Description |
---|---|
ItemStatus |
MassUpdateUnitsRulesProcess.execute(WorkerParameters param,
HandlerIO handler)
Execute an action
|
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 |
PreservationFinalizationPlugin.execute(WorkerParameters param,
HandlerIO handler) |
ItemStatus |
PreservationPreparationPlugin.execute(WorkerParameters param,
HandlerIO handler) |
List<ItemStatus> |
PreservationStorageMetadataAndLfc.executeList(WorkerParameters param,
HandlerIO handler) |
Modifier and Type | Method and Description |
---|---|
ItemStatus |
ProbativeCreateDistributionFile.execute(WorkerParameters param,
HandlerIO handler) |
ItemStatus |
ProbativeCreateReportEntry.execute(WorkerParameters param,
HandlerIO handler) |
ItemStatus |
ProbativeCreateReport.execute(WorkerParameters param,
HandlerIO handler) |
Modifier and Type | Method and Description |
---|---|
ItemStatus |
PurgeAccessionRegisterUpdatePlugin.execute(WorkerParameters param,
HandlerIO handler) |
ItemStatus |
PurgeAccessionRegisterPreparationHandler.execute(WorkerParameters param,
HandlerIO handler) |
ItemStatus |
PurgeObjectGroupPreparationHandler.execute(WorkerParameters param,
HandlerIO handler) |
Modifier and Type | Method and Description |
---|---|
ItemStatus |
ReclassificationPreparationLoadRequestHandler.execute(WorkerParameters param,
HandlerIO handler) |
ItemStatus |
ReclassificationPreparationCheckGraphHandler.execute(WorkerParameters param,
HandlerIO handler) |
ItemStatus |
ReclassificationFinalizationHandler.execute(WorkerParameters param,
HandlerIO handler) |
ItemStatus |
UnitAttachmentPlugin.execute(WorkerParameters param,
HandlerIO handler) |
ItemStatus |
ReclassificationPreparationUpdateDistributionHandler.execute(WorkerParameters param,
HandlerIO handler) |
ItemStatus |
UnitDetachmentPlugin.execute(WorkerParameters param,
HandlerIO handler) |
Modifier and Type | Method and Description |
---|---|
ItemStatus |
VerifyAtrPlugin.execute(WorkerParameters param,
HandlerIO handler) |
ItemStatus |
TransferReplyFinalizationPlugin.execute(WorkerParameters param,
HandlerIO handler) |
ItemStatus |
TransferReplyUnitPreparationHandler.execute(WorkerParameters param,
HandlerIO handler) |
ItemStatus |
SaveAtrPlugin.execute(WorkerParameters param,
HandlerIO handler) |
ItemStatus |
TransferReplyReportGenerationHandler.execute(WorkerParameters param,
HandlerIO handler) |
ItemStatus |
CheckAtrAndAddItToWorkspacePlugin.execute(WorkerParameters param,
HandlerIO handler) |
Modifier and Type | Method and Description |
---|---|
javax.ws.rs.core.Response |
WorkspaceClient.bulkGetObjects(String containerName,
List<String> objectURIs) |
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
|
javax.ws.rs.core.Response |
WorkspaceClient.getObject(String containerName,
String objectName,
long offset,
Long maxChunkSize)
Get Object at a specific offset and max specific size
|
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.purgeOldFilesInContainer(String containerName,
TimeToLive timeToLive) |
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 © 2019 Vitam. All rights reserved.