Package | Description |
---|---|
fr.gouv.vitam.common.storage.cas.container.api |
Provides API classes for the Workspace module
|
fr.gouv.vitam.common.storage.filesystem.v2 |
Provides a FileSystem implementation for storage modules have to manage up to 500 millions of files
|
fr.gouv.vitam.common.storage.swift |
Provides a Swift implementation for the storage modules.
|
fr.gouv.vitam.functionaltest.cucumber.step | |
fr.gouv.vitam.storage.offers.common.core |
Provides core implementation (Workspace based) for the Storage Offer Default
module
|
fr.gouv.vitam.storage.offers.common.database |
Provides core implementation for default offer mongo acces.
|
fr.gouv.vitam.worker.common |
Provides common 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.workspace.client |
Provides Workspace client factory and implementations.
|
fr.gouv.vitam.workspace.common |
Provides common classes for the Workspace module.
|
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 |
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.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 |
DefaultOfferService.countObjects(String containerName)
Count the number of objects in a container defined by the tenant and the type
|
com.fasterxml.jackson.databind.JsonNode |
DefaultOfferServiceImpl.countObjects(String containerName) |
String |
DefaultOfferService.createCursor(String containerName)
Create a new cursor for listing container operation
|
String |
DefaultOfferServiceImpl.createCursor(String containerName) |
com.fasterxml.jackson.databind.JsonNode |
DefaultOfferService.getCapacity(String containerName)
Get container capacity
|
com.fasterxml.jackson.databind.JsonNode |
DefaultOfferServiceImpl.getCapacity(String containerName) |
List<OfferLog> |
DefaultOfferService.getOfferLogs(String containerName,
Long offset,
int limit,
Order order)
Get the offer log of objects created in offer container
|
List<OfferLog> |
DefaultOfferServiceImpl.getOfferLogs(String containerName,
Long offset,
int limit,
Order order) |
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
|
ObjectInit |
DefaultOfferServiceImpl.initCreateObject(String containerName,
ObjectInit objectInit,
String objectGUID) |
boolean |
DefaultOfferService.isObjectExist(String containerName,
String objectId)
Check if object exists
|
boolean |
DefaultOfferServiceImpl.isObjectExist(String containerName,
String objectId) |
List<com.fasterxml.jackson.databind.JsonNode> |
DefaultOfferService.next(String containerName,
String cursorId)
Get next values
|
List<com.fasterxml.jackson.databind.JsonNode> |
DefaultOfferServiceImpl.next(String containerName,
String cursorId) |
Modifier and Type | Method and Description |
---|---|
void |
OfferLogDatabaseService.save(String containerName,
String fileName,
String 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
|
ItemStatus |
Worker.run(WorkerParameters workParams,
Step step)
Worker execute the step's actions
|
Modifier and Type | Method and Description |
---|---|
ItemStatus |
GenerateAuditReportActionHandler.execute(WorkerParameters param,
HandlerIO handler) |
ItemStatus |
VerifyTimeStampActionHandler.execute(WorkerParameters param,
HandlerIO handler) |
ItemStatus |
CheckNoObjectsActionHandler.execute(WorkerParameters params,
HandlerIO handlerIO) |
ItemStatus |
PrepareAuditActionHandler.execute(WorkerParameters param,
HandlerIO handler) |
ItemStatus |
CheckObjectsNumberActionHandler.execute(WorkerParameters params,
HandlerIO handlerIO) |
ItemStatus |
CheckDataObjectPackageActionHandler.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 |
---|---|
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.