fr.gouv.vitam.storage.engine.server.distribution

Interface StorageDistribution

All Superinterfaces:

AutoCloseable, VitamAutoCloseable

All Known Implementing Classes:

StorageDistributionImpl

public interface StorageDistribution
extends VitamAutoCloseable

Interface Storage Distribution for Storage Operations

Method Summary

Modifier and Type	Method and Description
boolean	checkObjectExisting(String strategyId, String objectId, DataCategory category, List<String> offerIds) Verify if object exists
StoredInfoResult	copyObjectFromOfferToOffer(DataContext context, String sourceOffer, String destinationOffer) copy object from on offer to an another
com.fasterxml.jackson.databind.JsonNode	createContainer(String strategyId) Create a container Architects are aware of this.
void	deleteObjectInAllOffers(String strategyId, DataContext context) Delete an object
void	deleteObjectInOffers(String strategyId, DataContext context, List<String> offers) Delete an object in offers
javax.ws.rs.core.Response	getContainerByCategory(String strategyId, String objectId, DataCategory category, AccessLogInfoModel logInformation) Get a specific Object binary data as an input stream
javax.ws.rs.core.Response	getContainerByCategory(String strategyId, String objectId, DataCategory category, String offerId) Get a specific Object binary data as an input stream
com.fasterxml.jackson.databind.JsonNode	getContainerInformation(String strategyId) Get Storage Information (availability and capacity) for the requested tenant + strategy
com.fasterxml.jackson.databind.JsonNode	getContainerInformation(String strategyId, DataCategory type, String objectId, List<String> offerIds) Get a specific Object information
List<String>	getOfferIds(String strategyId) get offer ids list
RequestResponse<OfferLog>	getOfferLogs(String strategyId, DataCategory category, Long offset, int limit, Order order) Get offer log from referent
RequestResponse<OfferLog>	getOfferLogsByOfferId(String strategyId, String offerId, DataCategory category, Long offset, int limit, Order order) Get offer log from the given offer
RequestResponse<com.fasterxml.jackson.databind.JsonNode>	listContainerObjects(String strategyId, DataCategory category, String cursorId) List container objects
com.fasterxml.jackson.databind.JsonNode	status() Get the status from the service
StoredInfoResult	storeDataInAllOffers(String strategyId, String objectId, ObjectDescription createObjectDescription, DataCategory category, String requester) Store data of any type for given tenant on storage offers associated to given strategy
StoredInfoResult	storeDataInOffers(String strategyId, StreamAndInfo streamAndInfo, String objectId, DataCategory category, String requester, List<String> offerIds)
StoredInfoResult	storeDataInOffers(String strategyId, String objectId, DataCategory category, String requester, List<String> offerIds, javax.ws.rs.core.Response response) Store data of any type for given tenant on the given storage offer.

Methods inherited from interface fr.gouv.vitam.common.model.VitamAutoCloseable

close

Method Detail

copyObjectFromOfferToOffer

StoredInfoResult copyObjectFromOfferToOffer(DataContext context,
                                            String sourceOffer,
                                            String destinationOffer)
                                     throws StorageException

copy object from on offer to an another

Parameters:

context - the context

destinationOffer - destination Offer

sourceOffer - source offer

Returns:

StoredInfoResult Object

Throws:

StorageException - StorageException

storeDataInAllOffers

StoredInfoResult storeDataInAllOffers(String strategyId,
                                      String objectId,
                                      ObjectDescription createObjectDescription,
                                      DataCategory category,
                                      String requester)
                               throws StorageException

Store data of any type for given tenant on storage offers associated to given strategy

Parameters:

strategyId - id of the strategy

objectId - the workspace URI of the data to be retrieve (and stored in offer)

createObjectDescription - object additional informations

category - the category of the data to store (unit, object...)

requester - the requester information

Returns:

a StoredInfoResult containing informations about the created Data

Throws:

StorageException - StorageException

storeDataInOffers

StoredInfoResult storeDataInOffers(String strategyId,
                                   String objectId,
                                   DataCategory category,
                                   String requester,
                                   List<String> offerIds,
                                   javax.ws.rs.core.Response response)
                            throws StorageException

Store data of any type for given tenant on the given storage offer.

Parameters:

strategyId - id of the strategy

objectId - the workspace URI of the data to be retrieve (and stored in

category - the category of the data to store (unit, object...)

requester - the requester information

offerIds - offer identfier

response - the response

Returns:

a StoredInfoResult containing informations about the created Data

Throws:

StorageException - StorageException

storeDataInOffers

StoredInfoResult storeDataInOffers(String strategyId,
                                   StreamAndInfo streamAndInfo,
                                   String objectId,
                                   DataCategory category,
                                   String requester,
                                   List<String> offerIds)
                            throws StorageException

Parameters:

strategyId - id of the strategy

streamAndInfo - streamAndInfo

objectId - id of the object

category - the object type to list

requester - the requester information

offerIds - offer identfiers

Returns:

StoredInfoResult

Throws:

StorageException - StorageException

getOfferIds

List<String> getOfferIds(String strategyId)
                  throws StorageException

get offer ids list

Parameters:

strategyId - strategy id

Returns:

offers ids list

Throws:

StorageException

getContainerInformation

com.fasterxml.jackson.databind.JsonNode getContainerInformation(String strategyId)
                                                         throws StorageException

Get Storage Information (availability and capacity) for the requested tenant + strategy

Parameters:

strategyId - id of the strategy

Returns:

a JsonNode containing informations about the storage

Throws:

StorageNotFoundException - Thrown if the Container does not exist

StorageTechnicalException - Thrown in case of any technical problem

StorageException

createContainer

com.fasterxml.jackson.databind.JsonNode createContainer(String strategyId)
                                                 throws StorageException

Create a container Architects are aware of this.

Parameters:

strategyId - id of the strategy

Returns:

a JsonNode containing informations about the created Container

Throws:

StorageException - Thrown in case the Container already exists

listContainerObjects

RequestResponse<com.fasterxml.jackson.databind.JsonNode> listContainerObjects(String strategyId,
                                                                              DataCategory category,
                                                                              String cursorId)
                                                                       throws StorageException

List container objects

Parameters:

strategyId - the strategy id to get offers

category - the object type to list

cursorId - the cursorId if exists

Returns:

a response with object listing

Throws:

StorageException - thrown in case of any technical problem

getOfferLogs

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

Get offer log from referent

Parameters:

strategyId - the strategy id to get offers

category - the object type to list

offset - offset of the excluded object

limit - the number of result wanted

order - order

Returns:

list of offer log

Throws:

StorageException - thrown in case of any technical problem

getOfferLogsByOfferId

RequestResponse<OfferLog> getOfferLogsByOfferId(String strategyId,
                                                String offerId,
                                                DataCategory category,
                                                Long offset,
                                                int limit,
                                                Order order)
                                         throws StorageException

Get offer log from the given offer

Parameters:

strategyId - the strategy id to get offers

offerId -

category - the object type to list

offset - offset of the excluded object

limit - the number of result wanted

order - order

Returns:

list of offer log

Throws:

StorageException - thrown in case of any technical problem

getContainerByCategory

javax.ws.rs.core.Response getContainerByCategory(String strategyId,
                                                 String objectId,
                                                 DataCategory category,
                                                 AccessLogInfoModel logInformation)
                                          throws StorageException

Get a specific Object binary data as an input stream

Parameters:

strategyId - id of the strategy

objectId - id of the object

category - category of the object

logInformation - information for accessLog

Returns:

an object as a Response with an InputStream

Throws:

StorageNotFoundException - Thrown if the Container or the object does not exist

StorageTechnicalException - thrown if a technical error happened

StorageException

getContainerByCategory

javax.ws.rs.core.Response getContainerByCategory(String strategyId,
                                                 String objectId,
                                                 DataCategory category,
                                                 String offerId)
                                          throws StorageException

Get a specific Object binary data as an input stream

Parameters:

strategyId - id of the strategy

objectId - id of the object

category - category

offerId - offer identfier

Returns:

an object as a Response with an InputStream

Throws:

StorageNotFoundException - Thrown if the Container or the object does not exist

StorageTechnicalException - thrown if a technical error happened

StorageException

getContainerInformation

com.fasterxml.jackson.databind.JsonNode getContainerInformation(String strategyId,
                                                                DataCategory type,
                                                                String objectId,
                                                                List<String> offerIds)
                                                         throws StorageException

Get a specific Object information

Parameters:

strategyId - id of the strategy

type - data category

objectId - id of the object

offerIds - list id of offers

Returns:

JsonNode containing informations about the requested object

Throws:

StorageException

checkObjectExisting

boolean checkObjectExisting(String strategyId,
                            String objectId,
                            DataCategory category,
                            List<String> offerIds)
                     throws StorageException

Verify if object exists

Parameters:

strategyId - id of the strategy

objectId - id of the object

offerIds - list id of offers

Returns:

boolean

Throws:

StorageException - StorageException

deleteObjectInAllOffers

void deleteObjectInAllOffers(String strategyId,
                             DataContext context)
                      throws StorageException

Delete an object

Parameters:

strategyId - id of the strategy

Throws:

StorageNotFoundException - Thrown if the Container or the object does not exist

StorageTechnicalException - thrown if a technical error happened

StorageException

deleteObjectInOffers

void deleteObjectInOffers(String strategyId,
                          DataContext context,
                          List<String> offers)
                   throws StorageException

Delete an object in offers

Parameters:

strategyId - id of the strategy

context - context

offers - offers

Throws:

StorageNotFoundException - Thrown if the Container or the object does not exist

StorageTechnicalException - thrown if a technical error happened

StorageException

status

com.fasterxml.jackson.databind.JsonNode status()
                                        throws UnsupportedOperationException

Get the status from the service

Returns:

the status as a JsonNode

Throws:

UnsupportedOperationException - method not implemented yet