fr.gouv.vitam.common.storage.swift

Class Swift

java.lang.Object

fr.gouv.vitam.common.storage.cas.container.api.ContentAddressableStorageAbstract

fr.gouv.vitam.common.storage.swift.Swift

All Implemented Interfaces:

VitamAutoCloseable, ContentAddressableStorage, AutoCloseable

public class Swift
extends ContentAddressableStorageAbstract

Swift abstract implementation Manage with all common swift methods

Field Summary

Fields inherited from class fr.gouv.vitam.common.storage.cas.container.api.ContentAddressableStorageAbstract

LISTING_MAX_RESULTS

Constructor Summary

Constructors

Constructor and Description
Swift(Supplier<org.openstack4j.api.OSClient> osClient, StorageConfiguration configuration) Constructor

Method Summary

Modifier and Type	Method and Description
void	close()
void	createContainer(String containerName) Abstract method to get authenticated openstack client, allow to switch between Keystone V2 and Keystone V3
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 digestType, boolean noCache) compute Object Digest using a defined algorithm
MetadatasObject	getObjectMetadata(String containerName, String objectId, 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 fr.gouv.vitam.common.storage.cas.container.api.ContentAddressableStorageAbstract

cacheExistsContainer, computeObjectDigest, disableContainerCaching, getConfiguration, isExistingContainerInCache

Methods inherited from class java.lang.Object

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

Constructor Detail

Swift

public Swift(Supplier<org.openstack4j.api.OSClient> osClient,
             StorageConfiguration configuration)

Constructor

Parameters:

osClient - the given type of osClient can be OSClientV2, OSClientV3

configuration - StorageConfiguration

Method Detail

createContainer

public void createContainer(String containerName)
                     throws ContentAddressableStorageServerException

Abstract method to get authenticated openstack client, allow to switch between Keystone V2 and Keystone V3

Parameters:

containerName - name of container to create

Throws:

ContentAddressableStorageServerException - Thrown when internal server error happens

isExistingContainer

public boolean isExistingContainer(String containerName)

Description copied from interface: ContentAddressableStorage

Determines if a container exists

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

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

getObjectDigest

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

Description copied from interface: ContentAddressableStorage

compute Object Digest using a defined algorithm

Parameters:

containerName - container where this exists.

objectName - fully qualified name relative to the container.

digestType - 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

getObject

public ObjectContent getObject(String containerName,
                               String objectName)
                        throws ContentAddressableStorageException

Description copied from interface: ContentAddressableStorage

Retrieves an object representing the data at location containerName/objectName

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.

ContentAddressableStorageException - Thrown when get action failed due some other failure

ContentAddressableStorageAlreadyExistException - Thrown when object creating exists

createReadOrderRequest

public String createReadOrderRequest(String containerName,
                                     List<String> objectsIds)

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

Parameters:

containerName - container where this exists.

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

Returns:

read order request id

removeReadOrderRequest

public void removeReadOrderRequest(String readRequestID)

Description copied from interface: ContentAddressableStorage

Purge all read request id to cleanup local FS

Parameters:

readRequestID - the read request ID.

deleteObject

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

Description copied from interface: ContentAddressableStorage

Deletes a object representing the data at location containerName/objectName

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)

Description copied from interface: ContentAddressableStorage

Determines if an object exists

Parameters:

containerName - container where the object resides

objectName - fully qualified name relative to the container.

Returns:

boolean type

getContainerInformation

public ContainerInformation getContainerInformation(String containerName)
                                             throws ContentAddressableStorageNotFoundException

Description copied from interface: ContentAddressableStorage

Get container information like capacity

Parameters:

containerName - the container name

Returns:

container information like usableSpace

Throws:

ContentAddressableStorageNotFoundException - Thrown when the container cannot be located.

getObjectMetadata

public MetadatasObject getObjectMetadata(String containerName,
                                         String objectId,
                                         boolean noCache)

Description copied from interface: ContentAddressableStorage

get metadata of the object

Parameters:

containerName - the container name

objectId - the objectId to check

Returns:

MetadatasObjectResult

listContainer

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

Description copied from interface: ContentAddressableStorage

List container (create cursor)

Parameters:

containerName - the container name

Returns:

container listing

Throws:

ContentAddressableStorageNotFoundException - Thrown when the container cannot be located.

listContainerNext

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

Description copied from interface: ContentAddressableStorage

List container (next on cursor)

Parameters:

containerName - the container name

nextMarker - the last id of the list to get next

Returns:

container listing

Throws:

ContentAddressableStorageNotFoundException - Thrown when the container cannot be located.

close

public void close()