Package org.jumpmind.symmetric.statistic

Class MockStatisticManager

java.lang.Object

org.jumpmind.symmetric.statistic.MockStatisticManager

All Implemented Interfaces:

IStatisticManager

public class MockStatisticManager
extends Object
implements IStatisticManager

Constructor Summary

Constructors

Constructor	Description
MockStatisticManager()

Method Summary

Modifier and Type	Method	Description
void	addJobStats(String targetNodeId, int targetNodeCount, String jobName, long startTime, long endTime, long processedCount)
void	addJobStats(String jobName, long startTime, long endTime, long processedCount)
void	addJobStats(String jobName, long startTime, long endTime, long processedCount, Exception e)
void	addJobStats(String jobName, long startTime, long endTime, long processedCount, String errorMessage)
void	addRouterStats(long startDataId, long endDataId, long dataReadCount, long peekAheadFillCount, List<DataGap> dataGaps, Set<String> transactions, Collection<OutgoingBatch> batches)
void	flush()
String	getMostRecentActiveTableSynced()
TreeMap<Date,Map<String,ChannelStats>>	getNodeStatsForPeriod(Date start, Date end, String nodeId, int periodSizeInMinutes)
Set<String>	getNodesWithProcessesInError()
List<ProcessInfo>	getProcessInfos()
List<ProcessInfo>	getProcessInfosThatHaveDoneWork()
RouterStats	getRouterStatsByBatch(Long batchId)
Map<Integer,Date>	getTotalLoadedRows()
Map<String,ChannelStats>	getWorkingChannelStats()
HostStats	getWorkingHostStats()
List<JobStats>	getWorkingJobStats()
void	incrementDataBytesExtracted(String channelId, long count)
void	incrementDataBytesLoaded(String channelId, long count)
void	incrementDataBytesLoadedOutgoing(String channelId, long count)
void	incrementDataBytesSent(String channelId, long count)
void	incrementDataEventInserted(String channelId, long count)
void	incrementDataExtracted(String channelId, long count)
void	incrementDataExtractedErrors(String channelId, long count)
void	incrementDataLoaded(String channelId, long count)
void	incrementDataLoadedErrors(String channelId, long count)
void	incrementDataLoadedOutgoing(String channelId, long count)
void	incrementDataLoadedOutgoingErrors(String channelId, long count)
void	incrementDataRouted(String channelId, long count)
void	incrementDataSent(String channelId, long count)
void	incrementDataSentErrors(String channelId, long count)
void	incrementNodesDisabled(long count)
void	incrementNodesLoaded(long count)
void	incrementNodesPulled(long count)
void	incrementNodesPushed(long count)
void	incrementNodesRegistered(long count)
void	incrementNodesRejected(long count)
void	incrementPurgedBatchIncomingRows(long count)
void	incrementPurgedBatchOutgoingRows(long count)
void	incrementPurgedDataEventRows(long count)
void	incrementPurgedDataRows(long count)
void	incrementPurgedExpiredDataRows(long count)
void	incrementPurgedStrandedDataEventRows(long count)
void	incrementPurgedStrandedDataRows(long count)
void	incrementRestart()
void	incrementTableRows(Map<String,Map<String,Long>> tableCounts, boolean loaded)
void	incrementTotalNodesPulledTime(long count)
void	incrementTotalNodesPushedTime(long count)
void	incrementTriggersCreatedCount(long count)
void	incrementTriggersRebuiltCount(long count)
void	incrementTriggersRemovedCount(long count)
ProcessInfo	newProcessInfo(ProcessInfoKey key)
void	removeProcessInfo(ProcessInfoKey key)
void	removeRouterStatsByBatch(Long batchId)
void	setDataUnRouted(String channelId, long count)

Methods inherited from class java.lang.Object

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

Constructor Details

MockStatisticManager

public MockStatisticManager()

Method Details

getProcessInfos

public List<ProcessInfo> getProcessInfos()

Specified by:

getProcessInfos in interface IStatisticManager

getProcessInfosThatHaveDoneWork

public List<ProcessInfo> getProcessInfosThatHaveDoneWork()

Specified by:

getProcessInfosThatHaveDoneWork in interface IStatisticManager

removeProcessInfo

public void removeProcessInfo(ProcessInfoKey key)

newProcessInfo

public ProcessInfo newProcessInfo(ProcessInfoKey key)

Specified by:

newProcessInfo in interface IStatisticManager

getNodesWithProcessesInError

public Set<String> getNodesWithProcessesInError()

Specified by:

getNodesWithProcessesInError in interface IStatisticManager

flush

public void flush()

Specified by:

flush in interface IStatisticManager

addJobStats

public void addJobStats(String jobName,
 long startTime,
 long endTime,
 long processedCount)

Specified by:

addJobStats in interface IStatisticManager

incrementRestart

public void incrementRestart()

Specified by:

incrementRestart in interface IStatisticManager

incrementNodesPulled

public void incrementNodesPulled(long count)

Specified by:

incrementNodesPulled in interface IStatisticManager

incrementNodesRegistered

public void incrementNodesRegistered(long count)

Specified by:

incrementNodesRegistered in interface IStatisticManager

incrementNodesPushed

public void incrementNodesPushed(long count)

Specified by:

incrementNodesPushed in interface IStatisticManager

incrementTotalNodesPulledTime

public void incrementTotalNodesPulledTime(long count)

Specified by:

incrementTotalNodesPulledTime in interface IStatisticManager

incrementTotalNodesPushedTime

public void incrementTotalNodesPushedTime(long count)

Specified by:

incrementTotalNodesPushedTime in interface IStatisticManager

incrementNodesRejected

public void incrementNodesRejected(long count)

Specified by:

incrementNodesRejected in interface IStatisticManager

incrementDataLoadedErrors

public void incrementDataLoadedErrors(String channelId,
 long count)

Specified by:

incrementDataLoadedErrors in interface IStatisticManager

incrementDataBytesLoaded

public void incrementDataBytesLoaded(String channelId,
 long count)

Specified by:

incrementDataBytesLoaded in interface IStatisticManager

incrementDataBytesSent

public void incrementDataBytesSent(String channelId,
 long count)

Specified by:

incrementDataBytesSent in interface IStatisticManager

incrementDataEventInserted

public void incrementDataEventInserted(String channelId,
 long count)

Specified by:

incrementDataEventInserted in interface IStatisticManager

incrementDataExtractedErrors

public void incrementDataExtractedErrors(String channelId,
 long count)

Specified by:

incrementDataExtractedErrors in interface IStatisticManager

incrementDataBytesExtracted

public void incrementDataBytesExtracted(String channelId,
 long count)

Specified by:

incrementDataBytesExtracted in interface IStatisticManager

setDataUnRouted

public void setDataUnRouted(String channelId,
 long count)

Specified by:

setDataUnRouted in interface IStatisticManager

incrementDataRouted

public void incrementDataRouted(String channelId,
 long count)

Specified by:

incrementDataRouted in interface IStatisticManager

incrementDataSentErrors

public void incrementDataSentErrors(String channelId,
 long count)

Specified by:

incrementDataSentErrors in interface IStatisticManager

incrementDataExtracted

public void incrementDataExtracted(String channelId,
 long count)

Specified by:

incrementDataExtracted in interface IStatisticManager

incrementDataLoaded

public void incrementDataLoaded(String channelId,
 long count)

Specified by:

incrementDataLoaded in interface IStatisticManager

incrementDataSent

public void incrementDataSent(String channelId,
 long count)

Specified by:

incrementDataSent in interface IStatisticManager

getWorkingChannelStats

public Map<String,ChannelStats> getWorkingChannelStats()

Specified by:

getWorkingChannelStats in interface IStatisticManager

getWorkingHostStats

public HostStats getWorkingHostStats()

Specified by:

getWorkingHostStats in interface IStatisticManager

incrementNodesLoaded

public void incrementNodesLoaded(long count)

Specified by:

incrementNodesLoaded in interface IStatisticManager

incrementNodesDisabled

public void incrementNodesDisabled(long count)

Specified by:

incrementNodesDisabled in interface IStatisticManager

incrementPurgedBatchIncomingRows

public void incrementPurgedBatchIncomingRows(long count)

Specified by:

incrementPurgedBatchIncomingRows in interface IStatisticManager

incrementPurgedBatchOutgoingRows

public void incrementPurgedBatchOutgoingRows(long count)

Specified by:

incrementPurgedBatchOutgoingRows in interface IStatisticManager

incrementPurgedDataRows

public void incrementPurgedDataRows(long count)

Specified by:

incrementPurgedDataRows in interface IStatisticManager

incrementPurgedDataEventRows

public void incrementPurgedDataEventRows(long count)

Specified by:

incrementPurgedDataEventRows in interface IStatisticManager

incrementTriggersRemovedCount

public void incrementTriggersRemovedCount(long count)

Specified by:

incrementTriggersRemovedCount in interface IStatisticManager

incrementTriggersRebuiltCount

public void incrementTriggersRebuiltCount(long count)

Specified by:

incrementTriggersRebuiltCount in interface IStatisticManager

incrementTriggersCreatedCount

public void incrementTriggersCreatedCount(long count)

Specified by:

incrementTriggersCreatedCount in interface IStatisticManager

addRouterStats

public void addRouterStats(long startDataId,
 long endDataId,
 long dataReadCount,
 long peekAheadFillCount,
 List<DataGap> dataGaps,
 Set<String> transactions,
 Collection<OutgoingBatch> batches)

Specified by:

addRouterStats in interface IStatisticManager

getRouterStatsByBatch

public RouterStats getRouterStatsByBatch(Long batchId)

Specified by:

getRouterStatsByBatch in interface IStatisticManager

removeRouterStatsByBatch

public void removeRouterStatsByBatch(Long batchId)

Specified by:

removeRouterStatsByBatch in interface IStatisticManager

addJobStats

public void addJobStats(String targetNodeId,
 int targetNodeCount,
 String jobName,
 long startTime,
 long endTime,
 long processedCount)

Specified by:

addJobStats in interface IStatisticManager

getNodeStatsForPeriod

public TreeMap<Date,Map<String,ChannelStats>> getNodeStatsForPeriod(Date start,
 Date end,
 String nodeId,
 int periodSizeInMinutes)

Specified by:

getNodeStatsForPeriod in interface IStatisticManager

incrementDataLoadedOutgoingErrors

public void incrementDataLoadedOutgoingErrors(String channelId,
 long count)

Specified by:

incrementDataLoadedOutgoingErrors in interface IStatisticManager

incrementDataBytesLoadedOutgoing

public void incrementDataBytesLoadedOutgoing(String channelId,
 long count)

Specified by:

incrementDataBytesLoadedOutgoing in interface IStatisticManager

incrementDataLoadedOutgoing

public void incrementDataLoadedOutgoing(String channelId,
 long count)

Specified by:

incrementDataLoadedOutgoing in interface IStatisticManager

incrementTableRows

public void incrementTableRows(Map<String,Map<String,Long>> tableCounts,
 boolean loaded)

Specified by:

incrementTableRows in interface IStatisticManager

incrementPurgedStrandedDataRows

public void incrementPurgedStrandedDataRows(long count)

Specified by:

incrementPurgedStrandedDataRows in interface IStatisticManager

incrementPurgedStrandedDataEventRows

public void incrementPurgedStrandedDataEventRows(long count)

Specified by:

incrementPurgedStrandedDataEventRows in interface IStatisticManager

incrementPurgedExpiredDataRows

public void incrementPurgedExpiredDataRows(long count)

Specified by:

incrementPurgedExpiredDataRows in interface IStatisticManager

getMostRecentActiveTableSynced

public String getMostRecentActiveTableSynced()

Specified by:

getMostRecentActiveTableSynced in interface IStatisticManager

getTotalLoadedRows

public Map<Integer,Date> getTotalLoadedRows()

Specified by:

getTotalLoadedRows in interface IStatisticManager

addJobStats

public void addJobStats(String jobName,
 long startTime,
 long endTime,
 long processedCount,
 Exception e)

Specified by:

addJobStats in interface IStatisticManager

getWorkingJobStats

public List<JobStats> getWorkingJobStats()

Specified by:

getWorkingJobStats in interface IStatisticManager

addJobStats

public void addJobStats(String jobName,
 long startTime,
 long endTime,
 long processedCount,
 String errorMessage)

Specified by:

addJobStats in interface IStatisticManager