org.apache.jackrabbit.oak.plugins.blob

Class UploadStagingCache

java.lang.Object

org.apache.jackrabbit.oak.plugins.blob.UploadStagingCache

All Implemented Interfaces:

Closeable, AutoCloseable

public class UploadStagingCache
extends Object
implements Closeable

Cache for staging async uploads. This serves as a temporary cache for serving local requests till the time the upload has not been synced with the backend.

The appropriate backend for this cache are wrapped in StagingUploader implementations.

Method Summary

Modifier and Type	Method and Description
static UploadStagingCache	build(File dir, File home, int uploadThreads, long size, org.apache.jackrabbit.oak.plugins.blob.StagingUploader uploader, FileCache cache, StatisticsProvider statisticsProvider, ListeningExecutorService executor, ScheduledExecutorService scheduledExecutor, int purgeInterval, int retryInterval)
void	close()
File	getIfPresent(String key) Returns the File if present or null otherwise.
DataStoreCacheStatsMBean	getStats() Cache related stats
<any>	put(String id, File input) Puts the file into the staging cache if possible.

Methods inherited from class java.lang.Object

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

Method Detail

build

public static UploadStagingCache build(File dir,
                                       File home,
                                       int uploadThreads,
                                       long size,
                                       org.apache.jackrabbit.oak.plugins.blob.StagingUploader uploader,
                                       FileCache cache,
                                       StatisticsProvider statisticsProvider,
                                       ListeningExecutorService executor,
                                       ScheduledExecutorService scheduledExecutor,
                                       int purgeInterval,
                                       int retryInterval)

put

public <any> put(String id,
                 File input)

Puts the file into the staging cache if possible. Returns an optional SettableFuture if staged for upload otherwise empty.

Parameters:

id - the id of the file to be staged

input - the file to be staged

Returns:

An Optional SettableFuture.

getIfPresent

public File getIfPresent(String key)

Returns the File if present or null otherwise. Any usage of the returned file should assert for its existence as the file could be purged from the file system once uploaded using the internal scheduled remove mechanism.

Parameters:

key - of the file to check

Returns:

a File object if found

getStats

public DataStoreCacheStatsMBean getStats()

Cache related stats

Returns:

an instance of the DataStoreCacheStatsMBean.

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable