fr.gouv.vitam.storage.engine.client

Interface StorageClient

All Superinterfaces:

AutoCloseable, BasicClient, MockOrRestClient, VitamAutoCloseable

All Known Implementing Classes:

StorageClientMock

public interface StorageClient
extends BasicClient

Storage Client interface

Field Summary

Fields inherited from interface fr.gouv.vitam.common.client.BasicClient

STATUS_URL

Method Summary

Modifier and Type	Method and Description
BulkObjectStoreResponse	bulkStoreFilesFromWorkspace(String strategyId, BulkObjectStoreRequest bulkObjectStoreRequest) Store objects available in workspace into offers
RequestResponseOK	copyObjectToOneOfferAnother(String objectId, DataCategory category, String source, String destination, String strategyId)
RequestResponseOK	create(String strategyId, String objectId, DataCategory category, InputStream inputStream, Long inputStreamSize, List<String> offerIds)
boolean	delete(String strategyId, DataCategory type, String guid) Delete an object of given type in the storage offer strategy
boolean	delete(String strategyId, DataCategory type, String guid, List<String> offerIds) Delete an object of given type in the storage offer strategy
Map<String,Boolean>	exists(String strategyId, DataCategory type, String guid, List<String> offerIds) Check the existence of an object in storage by its id and type DataCategory.
boolean	existsContainer(String strategyId) Check the existance of a tenant container in storage by its id
RequestResponse<BatchObjectInformationResponse>	getBatchObjectInformation(String strategyId, DataCategory type, Collection<String> offerIds, Collection<String> objectIds) Get object information from objects in storage
javax.ws.rs.core.Response	getContainerAsync(String strategyId, String guid, DataCategory type, AccessLogInfoModel logInfo) Retrieves a binary object knowing its guid as an inputStream for a specific tenant/strategy
com.fasterxml.jackson.databind.JsonNode	getInformation(String strategyId, DataCategory type, String guid, List<String> offerIds, boolean noCache) Get object information from objects in storage
RequestResponse<OfferLog>	getOfferLogs(String strategyId, DataCategory type, Long offset, int limit, Order order) Get offer log .
List<String>	getOffers(String strategyId) get List of offers for a strategy
com.fasterxml.jackson.databind.JsonNode	getStorageInformation(String strategyId) Check if the storage of objects could be done, knowing a required size
RequestResponse<StorageStrategy>	getStorageStrategies() Get strategies.
VitamRequestIterator<com.fasterxml.jackson.databind.JsonNode>	listContainer(String strategyId, DataCategory type) List object type in container
RequestResponseOK	storageAccessLogBackup() Call storage accesslog backup operation.
RequestResponseOK	storageLogBackup() Call storage log backup operation.
RequestResponseOK	storageLogTraceability() Call storage log traceability operation.
StoredInfoResult	storeFileFromWorkspace(String strategyId, DataCategory type, String guid, ObjectDescription description) Store an object available in workspace by its vitam guid

Methods inherited from interface fr.gouv.vitam.common.client.MockOrRestClient

checkStatus, checkStatus, close, consumeAnyEntityAndClose, getResourcePath, getServiceUrl

Method Detail

getStorageInformation

com.fasterxml.jackson.databind.JsonNode getStorageInformation(String strategyId)
                                                       throws StorageNotFoundClientException,
                                                              StorageServerClientException

Check if the storage of objects could be done, knowing a required size

Parameters:

strategyId - the storage strategy id

Returns:

the capacity of the storage

Throws:

StorageNotFoundClientException - if the Server got a NotFound result

StorageServerClientException - if the Server got an internal error

getOffers

List<String> getOffers(String strategyId)
                throws StorageNotFoundClientException,
                       StorageServerClientException

get List of offers for a strategy

Parameters:

strategyId - strategyId

Returns:

list id of offers

Throws:

StorageNotFoundClientException

StorageServerClientException

storeFileFromWorkspace

StoredInfoResult storeFileFromWorkspace(String strategyId,
                                        DataCategory type,
                                        String guid,
                                        ObjectDescription description)
                                 throws StorageAlreadyExistsClientException,
                                        StorageNotFoundClientException,
                                        StorageServerClientException

Store an object available in workspace by its vitam guid

Parameters:

strategyId - the storage strategy id

type - the type of object collection

guid - vitam guid

description - object description

Returns:

the result status of object creation

Throws:

StorageAlreadyExistsClientException - if the Server got a CONFLICT status result

StorageNotFoundClientException - if the Server got a NotFound result

StorageServerClientException - if the Server got an internal error

bulkStoreFilesFromWorkspace

BulkObjectStoreResponse bulkStoreFilesFromWorkspace(String strategyId,
                                                    BulkObjectStoreRequest bulkObjectStoreRequest)
                                             throws StorageAlreadyExistsClientException,
                                                    StorageNotFoundClientException,
                                                    StorageServerClientException

Store objects available in workspace into offers

Parameters:

strategyId - the storage strategy id

bulkObjectStoreRequest - request

Returns:

the result status of object creation

Throws:

StorageAlreadyExistsClientException - if the Server got a CONFLICT status result

StorageNotFoundClientException - if the Server got a NotFound result

StorageServerClientException - if the Server got an internal error

existsContainer

boolean existsContainer(String strategyId)
                 throws StorageServerClientException

Check the existance of a tenant container in storage by its id

Parameters:

strategyId - the storage strategy id

Returns:

true if exist

Throws:

StorageServerClientException - if the Server got an internal error

exists

Map<String,Boolean> exists(String strategyId,
                           DataCategory type,
                           String guid,
                           List<String> offerIds)
                    throws StorageServerClientException

Check the existence of an object in storage by its id and type DataCategory.

Parameters:

strategyId - the storage strategy id

type - the type of object collection

guid - vitam guid

Returns:

true/false for each offer

Throws:

StorageServerClientException - if the Server got an internal error

delete

boolean delete(String strategyId,
               DataCategory type,
               String guid)
        throws StorageServerClientException

Delete an object of given type in the storage offer strategy

Parameters:

strategyId - the storage strategy id

type - the type of object collection

guid - vitam guid

Returns:

true if deleted

Throws:

StorageServerClientException - if the Server got an internal error

delete

boolean delete(String strategyId,
               DataCategory type,
               String guid,
               List<String> offerIds)
        throws StorageServerClientException

Delete an object of given type in the storage offer strategy

Parameters:

strategyId - the storage strategy id

type - the type of object collection

guid - vitam guid

offerIds - offers ids to delete

Returns:

true if deleted

Throws:

StorageServerClientException

getContainerAsync

javax.ws.rs.core.Response getContainerAsync(String strategyId,
                                            String guid,
                                            DataCategory type,
                                            AccessLogInfoModel logInfo)
                                     throws StorageServerClientException,
                                            StorageNotFoundException

Retrieves a binary object knowing its guid as an inputStream for a specific tenant/strategy

Parameters:

strategyId - the storage strategy id

guid - vitam guid of the object to be returned

type - the object type to list

logInfo - additional information for accessLog

Returns:

the object requested

Throws:

StorageServerClientException - if the Server got an internal error

StorageNotFoundException - if the Server got a NotFound result, if the container or the object does not exist

listContainer

VitamRequestIterator<com.fasterxml.jackson.databind.JsonNode> listContainer(String strategyId,
                                                                            DataCategory type)
                                                                     throws StorageServerClientException

List object type in container

Parameters:

strategyId - the strategy ID

type - the object type to list

Returns:

an iterator with object list

Throws:

StorageServerClientException - thrown if the server got an internal error

storageAccessLogBackup

RequestResponseOK storageAccessLogBackup()
                                  throws StorageServerClientException,
                                         InvalidParseOperationException

Call storage accesslog backup operation.

Returns:

Storage logbook backup response

Throws:

StorageServerClientException

InvalidParseOperationException

storageLogBackup

RequestResponseOK storageLogBackup()
                            throws StorageServerClientException,
                                   InvalidParseOperationException

Call storage log backup operation.

Returns:

Storage logbook backup response

Throws:

StorageServerClientException - StorageServerClientException

InvalidParseOperationException - InvalidParseOperationException

storageLogTraceability

RequestResponseOK storageLogTraceability()
                                  throws StorageServerClientException,
                                         InvalidParseOperationException

Call storage log traceability operation.

Returns:

storage log traceability response

Throws:

StorageServerClientException - StorageServerClientException

InvalidParseOperationException - InvalidParseOperationException

getInformation

com.fasterxml.jackson.databind.JsonNode getInformation(String strategyId,
                                                       DataCategory type,
                                                       String guid,
                                                       List<String> offerIds,
                                                       boolean noCache)
                                                throws StorageServerClientException,
                                                       StorageNotFoundClientException

Get object information from objects in storage

Parameters:

strategyId - the storage strategy id

type - the object type to list

guid - vitam guid

offerIds - offers ids to delete

noCache - noCache forces digest computation.

Returns:

informations

Throws:

StorageServerClientException - StorageServerClientException

StorageNotFoundClientException - StorageNotFoundClientException

getBatchObjectInformation

RequestResponse<BatchObjectInformationResponse> getBatchObjectInformation(String strategyId,
                                                                          DataCategory type,
                                                                          Collection<String> offerIds,
                                                                          Collection<String> objectIds)
                                                                   throws StorageServerClientException

Get object information from objects in storage

Parameters:

strategyId - the storage strategy id

type - the object type to list

offerIds - offers ids

objectIds - list of object ids

Returns:

informations

Throws:

StorageServerClientException - StorageServerClientException

copyObjectToOneOfferAnother

RequestResponseOK copyObjectToOneOfferAnother(String objectId,
                                              DataCategory category,
                                              String source,
                                              String destination,
                                              String strategyId)
                                       throws StorageServerClientException,
                                              InvalidParseOperationException

Parameters:

objectId - objectId

category - category

source - source

destination - destination

strategyId - strategyId

Returns:

RequestResponseOK

Throws:

StorageServerClientException - StorageServerClientException

InvalidParseOperationException - StorageServerClientException

create

RequestResponseOK create(String strategyId,
                         String objectId,
                         DataCategory category,
                         InputStream inputStream,
                         Long inputStreamSize,
                         List<String> offerIds)
                  throws StorageServerClientException,
                         InvalidParseOperationException

Parameters:

strategyId - strategyId

objectId - objectId

category - category

inputStream - inputStream

inputStreamSize - inputStreamSize

offerIds - offers ids

Returns:

RequestResponseOK

Throws:

StorageServerClientException - StorageServerClientException

InvalidParseOperationException - InvalidParseOperationException

getOfferLogs

RequestResponse<OfferLog> getOfferLogs(String strategyId,
                                       DataCategory type,
                                       Long offset,
                                       int limit,
                                       Order order)
                                throws StorageServerClientException

Get offer log .

Parameters:

strategyId - the strategy to get offers

type - the object type to list

offset - offset of the last object before

limit - the number of result wanted

order - the order order

Returns:

list of offer log

Throws:

StorageServerClientException

getStorageStrategies

RequestResponse<StorageStrategy> getStorageStrategies()
                                               throws StorageServerClientException

Get strategies.

Returns:

strategies available for storage

Throws:

StorageServerClientException