unlimited.fc.client.cache

Interface CachedFileIndexInterface

All Known Implementing Classes:

CachedFileIndexInterface.Adapter, CachedFileIndexInterface.NullCachedFileIndex, MappedMemoryTransferCache

public interface CachedFileIndexInterface

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	CachedFileIndexInterface.Adapter
static interface	CachedFileIndexInterface.CacheKeyCredentials
static class	CachedFileIndexInterface.NullCachedFileIndex

Field Summary

Fields

Modifier and Type	Field and Description
static HashFunction	hasher

Method Summary

Modifier and Type	Method and Description
default java.util.Map<LoadableIndexedFile,java.lang.Boolean>	addDirect(java.util.Set<LoadableIndexedFile> files)
java.util.Map<CachedFileToDB,java.lang.Boolean>	addDirectAndMerge(java.util.Set<CachedFileToDB> file)
default void	addFile(FileListDataItem item)
default void	addFile(java.nio.file.Path file)
default void	addFile(java.nio.file.Path file, long timestamp, long size)
void	addFile(java.lang.String indexedString, long timestamp, long size)
default CachedFileToDB	buildCachedFileToDB(java.lang.String path, long timestamp)
default IndexedFile	buildFromDBResult(CachedFileToDB cachedFileInDB)
static long	buildTaskKey(CachedFileIndexInterface.CacheKeyCredentials t)
static long	buildTaskKey(java.lang.String taskID, java.lang.String clientID, java.lang.String siteId, boolean isUpload)
void	clearIndex()
void	deleteIndex()
default <T> java.util.stream.Stream<T>	filteredShouldTransfer(java.util.stream.Stream<T> in, java.util.function.Function<java.util.Set<T>,java.util.Map<T,java.lang.Boolean>> batcher)
java.lang.String	getCacheDirName() Method that returns the name of the cache directory for a single transfer.
java.lang.String	getCacheDirName(java.lang.String direction)
java.nio.file.Path	getClientDirectory()
java.lang.String	getClientID()
default HashCode	getHashCode(java.lang.String path)
IndexedFile	getIndexedFile(FileListDataItem item)
IndexedFile	getIndexedFile(java.nio.file.Path file)
default java.lang.String	getIndexedPath(FileListDataItem f)
default java.lang.String	getIndexedPath(java.nio.file.Path f)
default CachedFileIndexInterface	getLegacyFromThis()
LogUtils	getLogs()
default long	getMD5(FileListDataItem item)
default long	getMD5(java.nio.file.Path path)
default long	getMD5(java.lang.String path)
default java.lang.String	getMD5Str(java.lang.String path)
java.lang.String	getSiteID()
java.lang.String	getTaskID()
default boolean	hasMatch(FileListDataItem fileItem)
default boolean	hasMatch(IndexedFile indexedFile, long currentModified, long currentSize)
default boolean	hasMatch(java.nio.file.Path p)
java.util.Map<FileListDataItem,java.lang.Boolean>	hasMatchBatchFLDI(java.util.Set<FileListDataItem> set)
default java.util.Map<LoadableIndexedFile,java.lang.Boolean>	hasMatchBatchIDX(java.util.Set<LoadableIndexedFile> set)
java.util.Map<java.nio.file.Path,java.lang.Boolean>	hasMatchBatchPath(java.util.Set<java.nio.file.Path> set)
boolean	isIndexed(FileListDataItem item)
boolean	isIndexed(java.nio.file.Path file)
default boolean	isMigrated()
boolean	isUpload()
default CachedFileToDB	mapFLDIToDB(FileListDataItem file)
default CachedFileToDB	mapIDXToDB(LoadableIndexedFile file)
default CachedFileToDB	mapPathToDB(java.nio.file.Path file, long timestamp)
void	preCacheEntries()
void	removeFile(FileListDataItem item)
void	removeFile(java.nio.file.Path file)
default boolean	shouldTransfer(FileListDataItem fileItem)
default boolean	shouldTransfer(java.nio.file.Path p)
default <T> java.util.stream.Stream<<any>>	shouldTransfer(java.util.stream.Stream<T> in, java.util.function.Function<java.util.Set<T>,java.util.Map<T,java.lang.Boolean>> batcher)
default java.util.stream.Stream<<any>>	shouldTransferFLDI(java.util.stream.Stream<FileListDataItem> in)
default <T> boolean	shouldTransferGeneric(T t)
default java.util.stream.Stream<<any>>	shouldTransferPath(java.util.stream.Stream<java.nio.file.Path> in)
int	size()

Field Detail

hasher

static final HashFunction hasher

Method Detail

getHashCode

default HashCode getHashCode(java.lang.String path)

isUpload

boolean isUpload()

getSiteID

java.lang.String getSiteID()

getClientID

java.lang.String getClientID()

getTaskID

java.lang.String getTaskID()

getMD5

default long getMD5(java.lang.String path)

getMD5Str

default java.lang.String getMD5Str(java.lang.String path)

getMD5

default long getMD5(java.nio.file.Path path)

getMD5

default long getMD5(FileListDataItem item)

addDirect

default java.util.Map<LoadableIndexedFile,java.lang.Boolean> addDirect(java.util.Set<LoadableIndexedFile> files)

mapIDXToDB

default CachedFileToDB mapIDXToDB(LoadableIndexedFile file)

addDirectAndMerge

java.util.Map<CachedFileToDB,java.lang.Boolean> addDirectAndMerge(java.util.Set<CachedFileToDB> file)

getIndexedPath

default java.lang.String getIndexedPath(java.nio.file.Path f)

getClientDirectory

java.nio.file.Path getClientDirectory()

getIndexedPath

default java.lang.String getIndexedPath(FileListDataItem f)

isIndexed

boolean isIndexed(java.nio.file.Path file)

getIndexedFile

IndexedFile getIndexedFile(java.nio.file.Path file)

getIndexedFile

IndexedFile getIndexedFile(FileListDataItem item)

addFile

void addFile(java.lang.String indexedString,
             long timestamp,
             long size)

addFile

default void addFile(java.nio.file.Path file)

addFile

default void addFile(java.nio.file.Path file,
                     long timestamp,
                     long size)

addFile

default void addFile(FileListDataItem item)

buildFromDBResult

default IndexedFile buildFromDBResult(CachedFileToDB cachedFileInDB)

mapPathToDB

default CachedFileToDB mapPathToDB(java.nio.file.Path file,
                                   long timestamp)

mapFLDIToDB

default CachedFileToDB mapFLDIToDB(FileListDataItem file)

removeFile

void removeFile(java.nio.file.Path file)

removeFile

void removeFile(FileListDataItem item)

clearIndex

void clearIndex()

deleteIndex

void deleteIndex()

isIndexed

boolean isIndexed(FileListDataItem item)

preCacheEntries

void preCacheEntries()

shouldTransfer

default boolean shouldTransfer(java.nio.file.Path p)

hasMatchBatchPath

java.util.Map<java.nio.file.Path,java.lang.Boolean> hasMatchBatchPath(java.util.Set<java.nio.file.Path> set)

hasMatchBatchFLDI

java.util.Map<FileListDataItem,java.lang.Boolean> hasMatchBatchFLDI(java.util.Set<FileListDataItem> set)

hasMatchBatchIDX

default java.util.Map<LoadableIndexedFile,java.lang.Boolean> hasMatchBatchIDX(java.util.Set<LoadableIndexedFile> set)

filteredShouldTransfer

default <T> java.util.stream.Stream<T> filteredShouldTransfer(java.util.stream.Stream<T> in,
                                                              java.util.function.Function<java.util.Set<T>,java.util.Map<T,java.lang.Boolean>> batcher)

Parameters:

in -

batcher - - This should either be hasMatchBatchPath, or hasMatchBatchFLDI

Returns:

a stream of pairs where the second value of the pair will be if the item should transfer

shouldTransfer

default <T> java.util.stream.Stream<<any>> shouldTransfer(java.util.stream.Stream<T> in,
                                                          java.util.function.Function<java.util.Set<T>,java.util.Map<T,java.lang.Boolean>> batcher)

Parameters:

in - a stream of items that need to be checked against the transfer cache.

batcher - - This should either be hasMatchBatchPath, or hasMatchBatchFLDI

Returns:

a stream of items that should be transferred

getLegacyFromThis

default CachedFileIndexInterface getLegacyFromThis()

shouldTransferFLDI

default java.util.stream.Stream<<any>> shouldTransferFLDI(java.util.stream.Stream<FileListDataItem> in)

shouldTransferPath

default java.util.stream.Stream<<any>> shouldTransferPath(java.util.stream.Stream<java.nio.file.Path> in)

shouldTransfer

default boolean shouldTransfer(FileListDataItem fileItem)

shouldTransferGeneric

default <T> boolean shouldTransferGeneric(T t)

hasMatch

default boolean hasMatch(IndexedFile indexedFile,
                         long currentModified,
                         long currentSize)

hasMatch

default boolean hasMatch(java.nio.file.Path p)

hasMatch

default boolean hasMatch(FileListDataItem fileItem)

buildCachedFileToDB

default CachedFileToDB buildCachedFileToDB(java.lang.String path,
                                           long timestamp)

getLogs

LogUtils getLogs()

buildTaskKey

static long buildTaskKey(CachedFileIndexInterface.CacheKeyCredentials t)

buildTaskKey

static long buildTaskKey(java.lang.String taskID,
                         java.lang.String clientID,
                         java.lang.String siteId,
                         boolean isUpload)

getCacheDirName

java.lang.String getCacheDirName()

Method that returns the name of the cache directory for a single transfer.

Returns:

String

getCacheDirName

java.lang.String getCacheDirName(java.lang.String direction)

size

int size()

isMigrated

default boolean isMigrated()