Package fr.gouv.vitam.storage.offers.core

Interface DefaultOfferService

All Known Implementing Classes:

DefaultOfferServiceImpl, SanityCheckOfferServiceDecorator

public interface DefaultOfferService

Default offer service interface define offer methods

Field Summary

Fields

Modifier and Type	Field	Description
static java.lang.String	STORAGE_CONF_FILE_NAME

Method Summary

Modifier and Type	Method	Description
StorageBulkPutResult	bulkPutObjects(java.lang.String containerName, java.util.List<java.lang.String> objectIds, MultiplexedStreamReader multiplexedStreamReader, DataCategory type, DigestType digestType)
void	compactOfferLogs()
java.lang.String	createObject(java.lang.String containerName, java.lang.String objectId, java.io.InputStream objectPart, DataCategory type, java.lang.Long size, DigestType digestType)	Create object on container with objectId Receive object part of object.
java.util.Optional<TapeReadRequestReferentialEntity>	createReadOrderRequest(java.lang.String containerName, java.util.List<java.lang.String> objectsIds)	create read order (asynchronous read from tape to local FS) for the given @containerName and objects list.
void	deleteObject(java.lang.String containerName, java.lang.String objectId, DataCategory type)	Deletes a object representing the data at location containerName/objectName
StorageBulkMetadataResult	getBulkMetadata(java.lang.String containerName, java.util.List<java.lang.String> objectIds, java.lang.Boolean noCache)
ContainerInformation	getCapacity(java.lang.String containerName)	Get container capacity
StorageMetadataResult	getMetadata(java.lang.String containerName, java.lang.String objectId, boolean noCache)	Get Metadata
ObjectContent	getObject(java.lang.String containerName, java.lang.String objectId)	Get object on offer as an inputStream
java.lang.String	getObjectDigest(java.lang.String containerName, java.lang.String objectId, DigestType digestAlgorithm)	Get offer storage digest of object
java.util.List<OfferLog>	getOfferLogs(java.lang.String containerName, java.lang.Long offset, int limit, Order order)	Get the offer log of objects created in offer container
java.util.Optional<TapeReadRequestReferentialEntity>	getReadOrderRequest(java.lang.String readRequestID)
boolean	isObjectExist(java.lang.String containerName, java.lang.String objectId)	Check if object exists
void	listObjects(java.lang.String containerName, ObjectListingListener objectListingListener)	List container objects
void	removeReadOrderRequest(java.lang.String readRequestID)

Field Detail

STORAGE_CONF_FILE_NAME

static final java.lang.String STORAGE_CONF_FILE_NAME

See Also:

Constant Field Values

Method Detail

getObjectDigest

java.lang.String getObjectDigest(java.lang.String containerName,
                                 java.lang.String objectId,
                                 DigestType digestAlgorithm)
                          throws ContentAddressableStorageException

Get offer storage digest of object

Parameters:

containerName - the container with the object

objectId - the object name / id

digestAlgorithm - the digest algorithm

Returns:

the offer computed digest

Throws:

ContentAddressableStorageException - thrown on storage error

getObject

ObjectContent getObject(java.lang.String containerName,
                        java.lang.String objectId)
                 throws ContentAddressableStorageNotFoundException,
                        ContentAddressableStorageException

Get object on offer as an inputStream

Parameters:

containerName - the container containing the object

objectId - the object id

Returns:

the object included in a response

Throws:

ContentAddressableStorageNotFoundException - thrown when object does not exists

ContentAddressableStorageException - thrown when a server error occurs

createReadOrderRequest

java.util.Optional<TapeReadRequestReferentialEntity> createReadOrderRequest(java.lang.String containerName,
                                                                            java.util.List<java.lang.String> objectsIds)
                                                                     throws ContentAddressableStorageException

create read order (asynchronous read from tape to local FS) for the given @containerName and objects list. Return read order ID

Parameters:

containerName - the container containing the object

objectsIds - the objects ids

Returns:

readOrder entity

Throws:

ContentAddressableStorageNotFoundException - thrown when object does not exists

ContentAddressableStorageException - thrown when a server error occurs

getReadOrderRequest

java.util.Optional<TapeReadRequestReferentialEntity> getReadOrderRequest(java.lang.String readRequestID)
                                                                  throws ContentAddressableStorageException

Throws:

ContentAddressableStorageException

removeReadOrderRequest

void removeReadOrderRequest(java.lang.String readRequestID)
                     throws ContentAddressableStorageException

Throws:

ContentAddressableStorageException

createObject

java.lang.String createObject(java.lang.String containerName,
                              java.lang.String objectId,
                              java.io.InputStream objectPart,
                              DataCategory type,
                              java.lang.Long size,
                              DigestType digestType)
                       throws ContentAddressableStorageException

Create object on container with objectId Receive object part of object. Actually these parts HAVE TO be send in the great order.

Parameters:

containerName - the container name

objectId - the offer objectId to create

objectPart - the part of the object to create (chunk style)

type - the object type to create

size - inputstream size

digestType - digest of object

Returns:

the digest of the complete file or the digest of the chunk

Throws:

ContentAddressableStorageException - if the container does not exist

bulkPutObjects

StorageBulkPutResult bulkPutObjects(java.lang.String containerName,
                                    java.util.List<java.lang.String> objectIds,
                                    MultiplexedStreamReader multiplexedStreamReader,
                                    DataCategory type,
                                    DigestType digestType)
                             throws ContentAddressableStorageException,
                                    java.io.IOException

Throws:

ContentAddressableStorageException

java.io.IOException

isObjectExist

boolean isObjectExist(java.lang.String containerName,
                      java.lang.String objectId)
               throws ContentAddressableStorageException

Check if object exists

Parameters:

containerName - the container suppose to contain the object

objectId - the objectId to check

Returns:

true if object exists, false otherwise

Throws:

ContentAddressableStorageServerException

ContentAddressableStorageException

getCapacity

ContainerInformation getCapacity(java.lang.String containerName)
                          throws ContentAddressableStorageException

Get container capacity

Parameters:

containerName - the container name

Returns:

Json with usableSpace information

Throws:

ContentAddressableStorageNotFoundException - thrown if the container does not exist

ContentAddressableStorageServerException

ContentAddressableStorageException

deleteObject

void deleteObject(java.lang.String containerName,
                  java.lang.String objectId,
                  DataCategory type)
           throws ContentAddressableStorageNotFoundException,
                  ContentAddressableStorageException

Deletes a object representing the data at location containerName/objectName

Parameters:

containerName - container where this exists.

objectId - the objectId to delete

type - the object type to delete

Throws:

ContentAddressableStorageNotFoundException - Thrown when the container cannot be located or the blob cannot be located in the container.

ContentAddressableStorageException - Thrown when delete action failed due some other failure

getMetadata

StorageMetadataResult getMetadata(java.lang.String containerName,
                                  java.lang.String objectId,
                                  boolean noCache)
                           throws ContentAddressableStorageException

Get Metadata

Parameters:

containerName -

objectId -

noCache -

Returns:

StorageMetadataResult

Throws:

ContentAddressableStorageException

java.io.IOException

getOfferLogs

java.util.List<OfferLog> getOfferLogs(java.lang.String containerName,
                                      java.lang.Long offset,
                                      int limit,
                                      Order order)
                               throws ContentAddressableStorageException

Get the offer log of objects created in offer container

Parameters:

containerName - container the container name

offset - the offset of the object before the wanted list

limit - number of objects wanted

order - order of search

Returns:

list of object informations

Throws:

ContentAddressableStorageDatabaseException - Database error

ContentAddressableStorageServerException - Parsing error

ContentAddressableStorageException

listObjects

void listObjects(java.lang.String containerName,
                 ObjectListingListener objectListingListener)
          throws java.io.IOException,
                 ContentAddressableStorageException

List container objects

Parameters:

containerName - the container name

objectListingListener - a listener to which are reported found object entries

Throws:

java.io.IOException

ContentAddressableStorageException

compactOfferLogs

void compactOfferLogs()
               throws java.lang.Exception

Throws:

java.lang.Exception

getBulkMetadata

StorageBulkMetadataResult getBulkMetadata(java.lang.String containerName,
                                          java.util.List<java.lang.String> objectIds,
                                          java.lang.Boolean noCache)
                                   throws ContentAddressableStorageException

Throws:

ContentAddressableStorageException