Package org.jumpmind.symmetric.statistic
Class MockStatisticManager
java.lang.Object
org.jumpmind.symmetric.statistic.MockStatisticManager
- All Implemented Interfaces:
IStatisticManager
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
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()
getNodeStatsForPeriod
(Date start, Date end, String nodeId, int periodSizeInMinutes) getRouterStatsByBatch
(Long batchId) 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
void
void
incrementTotalNodesPulledTime
(long count) void
incrementTotalNodesPushedTime
(long count) void
incrementTriggersCreatedCount
(long count) void
incrementTriggersRebuiltCount
(long count) void
incrementTriggersRemovedCount
(long count) void
void
removeRouterStatsByBatch
(Long batchId) void
setDataUnRouted
(String channelId, long count)
-
Constructor Details
-
MockStatisticManager
public MockStatisticManager()
-
-
Method Details
-
getProcessInfos
- Specified by:
getProcessInfos
in interfaceIStatisticManager
-
getProcessInfosThatHaveDoneWork
- Specified by:
getProcessInfosThatHaveDoneWork
in interfaceIStatisticManager
-
removeProcessInfo
-
newProcessInfo
- Specified by:
newProcessInfo
in interfaceIStatisticManager
-
getNodesWithProcessesInError
- Specified by:
getNodesWithProcessesInError
in interfaceIStatisticManager
-
flush
public void flush()- Specified by:
flush
in interfaceIStatisticManager
-
addJobStats
- Specified by:
addJobStats
in interfaceIStatisticManager
-
incrementRestart
public void incrementRestart()- Specified by:
incrementRestart
in interfaceIStatisticManager
-
incrementNodesPulled
public void incrementNodesPulled(long count) - Specified by:
incrementNodesPulled
in interfaceIStatisticManager
-
incrementNodesRegistered
public void incrementNodesRegistered(long count) - Specified by:
incrementNodesRegistered
in interfaceIStatisticManager
-
incrementNodesPushed
public void incrementNodesPushed(long count) - Specified by:
incrementNodesPushed
in interfaceIStatisticManager
-
incrementTotalNodesPulledTime
public void incrementTotalNodesPulledTime(long count) - Specified by:
incrementTotalNodesPulledTime
in interfaceIStatisticManager
-
incrementTotalNodesPushedTime
public void incrementTotalNodesPushedTime(long count) - Specified by:
incrementTotalNodesPushedTime
in interfaceIStatisticManager
-
incrementNodesRejected
public void incrementNodesRejected(long count) - Specified by:
incrementNodesRejected
in interfaceIStatisticManager
-
incrementDataLoadedErrors
- Specified by:
incrementDataLoadedErrors
in interfaceIStatisticManager
-
incrementDataBytesLoaded
- Specified by:
incrementDataBytesLoaded
in interfaceIStatisticManager
-
incrementDataBytesSent
- Specified by:
incrementDataBytesSent
in interfaceIStatisticManager
-
incrementDataEventInserted
- Specified by:
incrementDataEventInserted
in interfaceIStatisticManager
-
incrementDataExtractedErrors
- Specified by:
incrementDataExtractedErrors
in interfaceIStatisticManager
-
incrementDataBytesExtracted
- Specified by:
incrementDataBytesExtracted
in interfaceIStatisticManager
-
setDataUnRouted
- Specified by:
setDataUnRouted
in interfaceIStatisticManager
-
incrementDataRouted
- Specified by:
incrementDataRouted
in interfaceIStatisticManager
-
incrementDataSentErrors
- Specified by:
incrementDataSentErrors
in interfaceIStatisticManager
-
incrementDataExtracted
- Specified by:
incrementDataExtracted
in interfaceIStatisticManager
-
incrementDataLoaded
- Specified by:
incrementDataLoaded
in interfaceIStatisticManager
-
incrementDataSent
- Specified by:
incrementDataSent
in interfaceIStatisticManager
-
getWorkingChannelStats
- Specified by:
getWorkingChannelStats
in interfaceIStatisticManager
-
getWorkingHostStats
- Specified by:
getWorkingHostStats
in interfaceIStatisticManager
-
incrementNodesLoaded
public void incrementNodesLoaded(long count) - Specified by:
incrementNodesLoaded
in interfaceIStatisticManager
-
incrementNodesDisabled
public void incrementNodesDisabled(long count) - Specified by:
incrementNodesDisabled
in interfaceIStatisticManager
-
incrementPurgedBatchIncomingRows
public void incrementPurgedBatchIncomingRows(long count) - Specified by:
incrementPurgedBatchIncomingRows
in interfaceIStatisticManager
-
incrementPurgedBatchOutgoingRows
public void incrementPurgedBatchOutgoingRows(long count) - Specified by:
incrementPurgedBatchOutgoingRows
in interfaceIStatisticManager
-
incrementPurgedDataRows
public void incrementPurgedDataRows(long count) - Specified by:
incrementPurgedDataRows
in interfaceIStatisticManager
-
incrementPurgedDataEventRows
public void incrementPurgedDataEventRows(long count) - Specified by:
incrementPurgedDataEventRows
in interfaceIStatisticManager
-
incrementTriggersRemovedCount
public void incrementTriggersRemovedCount(long count) - Specified by:
incrementTriggersRemovedCount
in interfaceIStatisticManager
-
incrementTriggersRebuiltCount
public void incrementTriggersRebuiltCount(long count) - Specified by:
incrementTriggersRebuiltCount
in interfaceIStatisticManager
-
incrementTriggersCreatedCount
public void incrementTriggersCreatedCount(long count) - Specified by:
incrementTriggersCreatedCount
in interfaceIStatisticManager
-
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 interfaceIStatisticManager
-
getRouterStatsByBatch
- Specified by:
getRouterStatsByBatch
in interfaceIStatisticManager
-
removeRouterStatsByBatch
- Specified by:
removeRouterStatsByBatch
in interfaceIStatisticManager
-
addJobStats
public void addJobStats(String targetNodeId, int targetNodeCount, String jobName, long startTime, long endTime, long processedCount) - Specified by:
addJobStats
in interfaceIStatisticManager
-
getNodeStatsForPeriod
public TreeMap<Date,Map<String, getNodeStatsForPeriodChannelStats>> (Date start, Date end, String nodeId, int periodSizeInMinutes) - Specified by:
getNodeStatsForPeriod
in interfaceIStatisticManager
-
incrementDataLoadedOutgoingErrors
- Specified by:
incrementDataLoadedOutgoingErrors
in interfaceIStatisticManager
-
incrementDataBytesLoadedOutgoing
- Specified by:
incrementDataBytesLoadedOutgoing
in interfaceIStatisticManager
-
incrementDataLoadedOutgoing
- Specified by:
incrementDataLoadedOutgoing
in interfaceIStatisticManager
-
incrementTableRows
- Specified by:
incrementTableRows
in interfaceIStatisticManager
-
incrementPurgedStrandedDataRows
public void incrementPurgedStrandedDataRows(long count) - Specified by:
incrementPurgedStrandedDataRows
in interfaceIStatisticManager
-
incrementPurgedStrandedDataEventRows
public void incrementPurgedStrandedDataEventRows(long count) - Specified by:
incrementPurgedStrandedDataEventRows
in interfaceIStatisticManager
-
incrementPurgedExpiredDataRows
public void incrementPurgedExpiredDataRows(long count) - Specified by:
incrementPurgedExpiredDataRows
in interfaceIStatisticManager
-
getMostRecentActiveTableSynced
- Specified by:
getMostRecentActiveTableSynced
in interfaceIStatisticManager
-
getTotalLoadedRows
- Specified by:
getTotalLoadedRows
in interfaceIStatisticManager
-
addJobStats
public void addJobStats(String jobName, long startTime, long endTime, long processedCount, Exception e) - Specified by:
addJobStats
in interfaceIStatisticManager
-
getWorkingJobStats
- Specified by:
getWorkingJobStats
in interfaceIStatisticManager
-
addJobStats
public void addJobStats(String jobName, long startTime, long endTime, long processedCount, String errorMessage) - Specified by:
addJobStats
in interfaceIStatisticManager
-