Package com.j_spaces.core.cache

Class InitialLoadInfo

java.lang.Object

com.j_spaces.core.cache.InitialLoadInfo

public class InitialLoadInfo
extends Object

cache-manager information about initial load performed

Since:

10.0

Author:

yechiel

Constructor Summary

Constructors

Constructor	Description
InitialLoadInfo(org.slf4j.Logger logger, boolean logRecoveryProcess, long recoveryLogInterval)

Method Summary

Modifier and Type	Method	Description
void	completeInitCounting()
BlobStoreFifoInitialLoader	getBlobStoreFifoInitialLoader()
IServerTypeDesc	getCurDesc()
TypeData	getCurTypeData()
int	getFoundInDatabase()
Map<String,Integer>	getFoundInDatabasePerType()
LinkedList<String>	getInitialLoadErrors()
int	getInsertedToCache()
Map<String,Integer>	getInsertedToCachePerType()
int	getInsertedToHotTier()
long	getLastLoggedTime()
org.slf4j.Logger	getLogger()
long	getRecoveryLogInterval()
long	getRecoveryStartTime()
void	incrementFoundInDatabase()
void	incrementFoundInDatabasePerType(String typeName)
void	incrementInsertedToCache()
void	incrementInsertedToCachePerType(String typeName)
void	incrementInsertedToHotTier()
boolean	isLogRecoveryProcess()
void	onInitCountingComplete(Runnable callback)
void	setBlobStoreFifoInitialLoader(BlobStoreFifoInitialLoader il)
void	setCurDesc(IServerTypeDesc _curDesc)
void	setCurTypeData(TypeData _curTypeData)
void	setFoundInDatabase(int foundInDatabase)
void	setFoundInDatabasePerType(Map<String,Integer> foundInDatabasePerType)
void	setInsertedToCache(int insertedToCache)
void	setInsertedToCachePerType(Map<String,Integer> insertedToCachePerType)
void	setLastLoggedTime(long _lastLoggedTime)
void	setRecoveryStartTime(long _recoveryStartTime)
void	startInitCounting()

Methods inherited from class java.lang.Object

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

Constructor Details

InitialLoadInfo

public InitialLoadInfo(org.slf4j.Logger logger,
 boolean logRecoveryProcess,
 long recoveryLogInterval)

Method Details

getFoundInDatabase

public int getFoundInDatabase()

setFoundInDatabase

public void setFoundInDatabase(int foundInDatabase)

incrementFoundInDatabase

public void incrementFoundInDatabase()

startInitCounting

public void startInitCounting()

completeInitCounting

public void completeInitCounting()

onInitCountingComplete

public void onInitCountingComplete(Runnable callback)

getInsertedToCache

public int getInsertedToCache()

setInsertedToCache

public void setInsertedToCache(int insertedToCache)

incrementInsertedToCache

public void incrementInsertedToCache()

incrementInsertedToHotTier

public void incrementInsertedToHotTier()

getInsertedToHotTier

public int getInsertedToHotTier()

getRecoveryStartTime

public long getRecoveryStartTime()

setRecoveryStartTime

public void setRecoveryStartTime(long _recoveryStartTime)

getLastLoggedTime

public long getLastLoggedTime()

setLastLoggedTime

public void setLastLoggedTime(long _lastLoggedTime)

getBlobStoreFifoInitialLoader

public BlobStoreFifoInitialLoader getBlobStoreFifoInitialLoader()

setBlobStoreFifoInitialLoader

public void setBlobStoreFifoInitialLoader(BlobStoreFifoInitialLoader il)

getCurDesc

public IServerTypeDesc getCurDesc()

setCurDesc

public void setCurDesc(IServerTypeDesc _curDesc)

getCurTypeData

public TypeData getCurTypeData()

setCurTypeData

public void setCurTypeData(TypeData _curTypeData)

getInitialLoadErrors

public LinkedList<String> getInitialLoadErrors()

getLogger

public org.slf4j.Logger getLogger()

isLogRecoveryProcess

public boolean isLogRecoveryProcess()

getRecoveryLogInterval

public long getRecoveryLogInterval()

getFoundInDatabasePerType

public Map<String,Integer> getFoundInDatabasePerType()

setFoundInDatabasePerType

public void setFoundInDatabasePerType(Map<String,Integer> foundInDatabasePerType)

incrementFoundInDatabasePerType

public void incrementFoundInDatabasePerType(String typeName)

getInsertedToCachePerType

public Map<String,Integer> getInsertedToCachePerType()

setInsertedToCachePerType

public void setInsertedToCachePerType(Map<String,Integer> insertedToCachePerType)

incrementInsertedToCachePerType

public void incrementInsertedToCachePerType(String typeName)