Package io.clonecloudstore.accessor.server.simple.application

Class AccessorObjectService

java.lang.Object

io.clonecloudstore.accessor.server.simple.application.AccessorObjectService

All Implemented Interfaces:

AccessorObjectServiceInterface

@ApplicationScoped
public class AccessorObjectService
extends Object
implements AccessorObjectServiceInterface

Accessor Bucket Service

Field Summary

Fields

Modifier and Type	Field	Description
protected FilesystemHandler	filesystemHandler

Constructor Summary

Constructors

Constructor	Description
AccessorObjectService()

Method Summary

Modifier and Type	Method	Description
AccessorObject	createObject(AccessorObject accessorObject, String hash, long len, String clientId)	Before really creating Object, creates it in DB if possible
AccessorObject	createObjectFinalize(AccessorObject accessorObject, String hash, long len, String clientId, boolean external)	Once Object really created in Driver Storage, finalize the Object in DB and Replicator if needed
void	deleteObject(String bucketName, String objectName, String clientId, boolean external)	Delete object in DB and through Replicator if needed
InputStream	filterObjects(String bucketName, AccessorFilter filter, DriverApi driver)
InputStream	filterObjects(String bucketName, AccessorFilter filter, String clientId, boolean external)
AccessorObject	getObjectInfo(String bucketName, String objectName, String clientId)	Get DB Object DTO
StorageType	objectOrDirectoryExists(String bucketName, String objectOrDirectoryName, boolean fullCheck, String clientId)	Check if object or directory exists
StorageType	objectOrDirectoryExists(String bucketName, String objectOrDirectoryName, boolean fullCheck, String clientId, String opId, boolean external)	Check if object or directory exists

Methods inherited from class java.lang.Object

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

Field Details

filesystemHandler

protected FilesystemHandler filesystemHandler

Constructor Details

AccessorObjectService

public AccessorObjectService()

Method Details

objectOrDirectoryExists

public StorageType objectOrDirectoryExists(String bucketName,
 String objectOrDirectoryName,
 boolean fullCheck,
 String clientId)
                                    throws CcsOperationException

Check if object or directory exists

Specified by:

objectOrDirectoryExists in interface AccessorObjectServiceInterface

Parameters:

bucketName - bucket name

objectOrDirectoryName - prefix or full name

fullCheck - if True, and if Object, will check on Driver Storage

Returns:

the associated StorageType

Throws:

CcsOperationException

objectOrDirectoryExists

public StorageType objectOrDirectoryExists(String bucketName,
 String objectOrDirectoryName,
 boolean fullCheck,
 String clientId,
 String opId,
 boolean external)
                                    throws CcsOperationException

Description copied from interface: AccessorObjectServiceInterface

Check if object or directory exists

Specified by:

objectOrDirectoryExists in interface AccessorObjectServiceInterface

Throws:

CcsOperationException

getObjectInfo

public AccessorObject getObjectInfo(String bucketName,
 String objectName,
 String clientId)
                             throws CcsNotExistException,
CcsOperationException

Get DB Object DTO

Specified by:

getObjectInfo in interface AccessorObjectServiceInterface

Throws:

CcsNotExistException

CcsOperationException

createObject

public AccessorObject createObject(AccessorObject accessorObject,
 String hash,
 long len,
 String clientId)
                            throws CcsOperationException,
CcsAlreadyExistException,
CcsNotExistException,
CcsNotAcceptableException

Before really creating Object, creates it in DB if possible

Specified by:

createObject in interface AccessorObjectServiceInterface

Throws:

CcsNotAcceptableException - if already in creation step

CcsOperationException

CcsAlreadyExistException

CcsNotExistException

createObjectFinalize

public AccessorObject createObjectFinalize(AccessorObject accessorObject,
 String hash,
 long len,
 String clientId,
 boolean external)
                                    throws CcsOperationException

Once Object really created in Driver Storage, finalize the Object in DB and Replicator if needed

Specified by:

createObjectFinalize in interface AccessorObjectServiceInterface

Throws:

CcsOperationException

deleteObject

public void deleteObject(String bucketName,
 String objectName,
 String clientId,
 boolean external)
                  throws CcsDeletedException,
CcsNotExistException,
CcsOperationException

Delete object in DB and through Replicator if needed

Specified by:

deleteObject in interface AccessorObjectServiceInterface

Throws:

CcsDeletedException

CcsNotExistException

CcsOperationException

filterObjects

public InputStream filterObjects(String bucketName,
 AccessorFilter filter,
 DriverApi driver)

Parameters:

bucketName - bucket name

filter - the filter to apply on Objects

Returns:

a stream (InputStream) of AccessorObject line by line (newline separated)

filterObjects

public InputStream filterObjects(String bucketName,
 AccessorFilter filter,
 String clientId,
 boolean external)
                          throws CcsOperationException

Specified by:

filterObjects in interface AccessorObjectServiceInterface

Parameters:

bucketName - bucket name

filter - the filter to apply on Objects

external - True if bucket will be for external usage

Returns:

a stream (InputStream) of AccessorObject line by line (newline separated)

Throws:

CcsOperationException