fr.gouv.vitam.storage.offers.tape.cas

Class TapeLibraryContentAddressableStorage

java.lang.Object

fr.gouv.vitam.storage.offers.tape.cas.TapeLibraryContentAddressableStorage

All Implemented Interfaces:

VitamAutoCloseable, ContentAddressableStorage, AutoCloseable

public class TapeLibraryContentAddressableStorage
extends Object
implements ContentAddressableStorage

Constructor Summary

Constructors

Constructor and Description

TapeLibraryContentAddressableStorage(BasicFileStorage basicFileStorage, ObjectReferentialRepository objectReferentialRepository, ArchiveReferentialRepository archiveReferentialRepository, ReadRequestReferentialRepository readRequestReferentialRepository, FileBucketTarCreatorManager fileBucketTarCreatorManager, QueueRepository readWriteQueue, TapeCatalogService tapeCatalogService, String outputTarStorageFolder, ArchiveOutputRetentionPolicy archiveOutputRetentionPolicy)

Method Summary

Modifier and Type	Method and Description
void	close()
void	createContainer(String containerName) Creates a container
String	createReadOrderRequest(String containerName, List<String> objectsIds) Create read order (asynchronous read from tape to local FS) for the given objects representing the data at location containerName/objectId.
void	deleteObject(String containerName, String objectName) Deletes a object representing the data at location containerName/objectName
ContainerInformation	getContainerInformation(String containerName) Get container information like capacity
ObjectContent	getObject(String containerName, String objectName) Retrieves an object representing the data at location containerName/objectName
String	getObjectDigest(String containerName, String objectName, DigestType algo, boolean noCache) compute Object Digest using a defined algorithm
MetadatasObject	getObjectMetadata(String containerName, String objectName, boolean noCache) get metadata of the object
boolean	isExistingContainer(String containerName) Determines if a container exists
boolean	isExistingObject(String containerName, String objectName) Determines if an object exists
VitamPageSet<? extends VitamStorageMetadata>	listContainer(String containerName) List container (create cursor)
VitamPageSet<? extends VitamStorageMetadata>	listContainerNext(String containerName, String nextMarker) List container (next on cursor)
String	putObject(String containerName, String objectName, InputStream stream, DigestType digestType, Long size) Adds an object representing the data at location containerName/objectName
void	removeReadOrderRequest(String readRequestID) Purge all read request id to cleanup local FS

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TapeLibraryContentAddressableStorage

public TapeLibraryContentAddressableStorage(BasicFileStorage basicFileStorage,
                                            ObjectReferentialRepository objectReferentialRepository,
                                            ArchiveReferentialRepository archiveReferentialRepository,
                                            ReadRequestReferentialRepository readRequestReferentialRepository,
                                            FileBucketTarCreatorManager fileBucketTarCreatorManager,
                                            QueueRepository readWriteQueue,
                                            TapeCatalogService tapeCatalogService,
                                            String outputTarStorageFolder,
                                            ArchiveOutputRetentionPolicy archiveOutputRetentionPolicy)

Method Detail

createContainer

public void createContainer(String containerName)

Description copied from interface: ContentAddressableStorage

Creates a container

Specified by:

createContainer in interface ContentAddressableStorage

Parameters:

containerName - name of container to create

isExistingContainer

public boolean isExistingContainer(String containerName)

Description copied from interface: ContentAddressableStorage

Determines if a container exists

Specified by:

isExistingContainer in interface ContentAddressableStorage

Parameters:

containerName - name of container

Returns:

boolean type

putObject

public String putObject(String containerName,
                        String objectName,
                        InputStream stream,
                        DigestType digestType,
                        Long size)
                 throws ContentAddressableStorageException

Description copied from interface: ContentAddressableStorage

Adds an object representing the data at location containerName/objectName

Specified by:

putObject in interface ContentAddressableStorage

Parameters:

containerName - container to place the object.

objectName - fully qualified object name relative to the container.

stream - the data

digestType - parameter to compute an hash.

size - size off the input stream

Throws:

ContentAddressableStorageNotFoundException - Thrown when the container cannot be located.

ContentAddressableStorageException - Thrown when put action failed due some other failure

ContentAddressableStorageAlreadyExistException - Thrown when object creating exists

getObject

public ObjectContent getObject(String containerName,
                               String objectName)
                        throws ContentAddressableStorageNotFoundException,
                               ContentAddressableStorageServerException

Description copied from interface: ContentAddressableStorage

Retrieves an object representing the data at location containerName/objectName

Specified by:

getObject in interface ContentAddressableStorage

Parameters:

containerName - container where this exists.

objectName - fully qualified name relative to the container.

Returns:

the object you intended to receive

Throws:

ContentAddressableStorageNotFoundException - Thrown when the container cannot be located.

ContentAddressableStorageServerException

createReadOrderRequest

public String createReadOrderRequest(String containerName,
                                     List<String> objectsIds)
                              throws ContentAddressableStorageServerException,
                                     ContentAddressableStorageNotFoundException

Description copied from interface: ContentAddressableStorage

Create read order (asynchronous read from tape to local FS) for the given objects representing the data at location containerName/objectId. Return read order entity

Specified by:

createReadOrderRequest in interface ContentAddressableStorage

Parameters:

containerName - container where this exists.

objectsIds - list of the fully qualified name relative to the container.

Returns:

read order request id

Throws:

ContentAddressableStorageNotFoundException - Thrown when the container cannot be located.

ContentAddressableStorageServerException

removeReadOrderRequest

public void removeReadOrderRequest(String readRequestID)
                            throws ContentAddressableStorageServerException

Description copied from interface: ContentAddressableStorage

Purge all read request id to cleanup local FS

Specified by:

removeReadOrderRequest in interface ContentAddressableStorage

Parameters:

readRequestID - the read request ID.

Throws:

ContentAddressableStorageServerException

deleteObject

public void deleteObject(String containerName,
                         String objectName)
                  throws ContentAddressableStorageServerException,
                         ContentAddressableStorageNotFoundException

Description copied from interface: ContentAddressableStorage

Deletes a object representing the data at location containerName/objectName

Specified by:

deleteObject in interface ContentAddressableStorage

Parameters:

containerName - container where this exists.

objectName - fully qualified name relative to the container.

Throws:

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

ContentAddressableStorageServerException

isExistingObject

public boolean isExistingObject(String containerName,
                                String objectName)
                         throws ContentAddressableStorageServerException

Description copied from interface: ContentAddressableStorage

Determines if an object exists

Specified by:

isExistingObject in interface ContentAddressableStorage

Parameters:

containerName - container where the object resides

objectName - fully qualified name relative to the container.

Returns:

boolean type

Throws:

ContentAddressableStorageServerException - Thrown when internal server error happens

getObjectDigest

public String getObjectDigest(String containerName,
                              String objectName,
                              DigestType algo,
                              boolean noCache)
                       throws ContentAddressableStorageException

Description copied from interface: ContentAddressableStorage

compute Object Digest using a defined algorithm

Specified by:

getObjectDigest in interface ContentAddressableStorage

Parameters:

containerName - container where this exists.

objectName - fully qualified name relative to the container.

algo - Digest algo

noCache - forces full digest computation

Returns:

the digest object as String

Throws:

ContentAddressableStorageNotFoundException - Thrown when the container or the object cannot be located

ContentAddressableStorageServerException - Thrown when internal server error happens

ContentAddressableStorageException - Thrown when put action failed due some other failure

getContainerInformation

public ContainerInformation getContainerInformation(String containerName)

Description copied from interface: ContentAddressableStorage

Get container information like capacity

Specified by:

getContainerInformation in interface ContentAddressableStorage

Parameters:

containerName - the container name

Returns:

container information like usableSpace

getObjectMetadata

public MetadatasObject getObjectMetadata(String containerName,
                                         String objectName,
                                         boolean noCache)
                                  throws ContentAddressableStorageException

Description copied from interface: ContentAddressableStorage

get metadata of the object

Specified by:

getObjectMetadata in interface ContentAddressableStorage

Parameters:

containerName - the container name

objectName - the objectId to check

Returns:

MetadatasObjectResult

Throws:

ContentAddressableStorageException - Thrown when get action failed due some other failure

listContainer

public VitamPageSet<? extends VitamStorageMetadata> listContainer(String containerName)

Description copied from interface: ContentAddressableStorage

List container (create cursor)

Specified by:

listContainer in interface ContentAddressableStorage

Parameters:

containerName - the container name

Returns:

container listing

listContainerNext

public VitamPageSet<? extends VitamStorageMetadata> listContainerNext(String containerName,
                                                                      String nextMarker)

Description copied from interface: ContentAddressableStorage

List container (next on cursor)

Specified by:

listContainerNext in interface ContentAddressableStorage

Parameters:

containerName - the container name

nextMarker - the last id of the list to get next

Returns:

container listing

close

public void close()

Specified by:

close in interface VitamAutoCloseable

Specified by:

close in interface AutoCloseable