Package io.clonecloudstore.accessor.server.commons.buffer

Class FilesystemHandler

java.lang.Object

io.clonecloudstore.accessor.server.commons.buffer.FilesystemHandler

@ApplicationScoped
public class FilesystemHandler
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final String	X_EXPIRES
static final String	X_HASH

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	FilesystemHandler()

Method Summary

Modifier and Type	Method	Description
boolean	check(String bucket, String object)
void	checkFreeSpaceGb(long size)
long	count()
protected boolean	delete(String bucket, String object)
long	deleteOlderThan(Instant limitDate)
List<BufferedItem>	getCurrentRegisteredTasks()
InputStream	readContent(String bucket, String object)
protected Map<String,String>	readMetadata(String bucket, String object)
StorageObject	readStorageObject(String bucket, String object)
void	registerItem(String bucket, String object)
void	removedValidatedTasks(List<BufferedItem> validated)
long	save(String bucket, String object, InputStream inputStream, Map<String,String> metadata, Instant expires)
long	size()
boolean	unregisterItem(String bucket, String object)
void	update(String bucket, String object, Map<String,String> metadata, String hash)

Methods inherited from class java.lang.Object

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

Field Details

X_HASH

public static final String X_HASH

See Also:

• Constant Field Values

X_EXPIRES

public static final String X_EXPIRES

See Also:

• Constant Field Values

Constructor Details

FilesystemHandler

protected FilesystemHandler()

Method Details

save

public long save(String bucket,
 String object,
 InputStream inputStream,
 Map<String,String> metadata,
 Instant expires)
          throws IOException

Throws:

IOException

update

public void update(String bucket,
 String object,
 Map<String,String> metadata,
 String hash)
            throws IOException

Throws:

IOException

readContent

public InputStream readContent(String bucket,
 String object)
                        throws FileNotFoundException

Throws:

FileNotFoundException

readMetadata

protected Map<String,String> readMetadata(String bucket,
 String object)
                                   throws IOException

Throws:

IOException

readStorageObject

public StorageObject readStorageObject(String bucket,
 String object)
                                throws IOException

Throws:

IOException

delete

protected boolean delete(String bucket,
 String object)

check

public boolean check(String bucket,
 String object)

registerItem

public void registerItem(String bucket,
 String object)

unregisterItem

public boolean unregisterItem(String bucket,
 String object)

getCurrentRegisteredTasks

public List<BufferedItem> getCurrentRegisteredTasks()

removedValidatedTasks

public void removedValidatedTasks(List<BufferedItem> validated)

checkFreeSpaceGb

public void checkFreeSpaceGb(long size)
                      throws IOException

Throws:

IOException

deleteOlderThan

public long deleteOlderThan(Instant limitDate)
                     throws IOException

Throws:

IOException

count

public long count()
           throws IOException

Throws:

IOException

size

public long size()
          throws IOException

Throws:

IOException