org.jumpmind.symmetric.statistic

Interface IStatisticManager

All Known Implementing Classes:

StatisticManager

public interface IStatisticManager

This manager provides an API record statistics

Method Summary

Modifier and Type	Method and Description
void	addJobStats(java.lang.String targetNodeId, int targetNodeCount, java.lang.String jobName, long startTime, long endTime, long processedCount)
void	addJobStats(java.lang.String jobName, long startTime, long endTime, long processedCount)
void	addRouterStats(long startDataId, long endDataId, long dataReadCount, long peekAheadFillCount, java.util.List<DataGap> dataGaps, java.util.Set<java.lang.String> transactions, java.util.Collection<OutgoingBatch> batches)
void	flush()
java.util.TreeMap<java.util.Date,java.util.Map<java.lang.String,ChannelStats>>	getNodeStatsForPeriod(java.util.Date start, java.util.Date end, java.lang.String nodeId, int periodSizeInMinutes)
java.util.Set<java.lang.String>	getNodesWithProcessesInError()
java.util.List<ProcessInfo>	getProcessInfos()
java.util.List<ProcessInfo>	getProcessInfosThatHaveDoneWork()
RouterStats	getRouterStatsByBatch(java.lang.Long batchId)
java.util.Map<java.lang.String,ChannelStats>	getWorkingChannelStats()
HostStats	getWorkingHostStats()
void	incrementDataBytesExtracted(java.lang.String channelId, long count)
void	incrementDataBytesLoaded(java.lang.String channelId, long count)
void	incrementDataBytesLoadedOutgoing(java.lang.String channelId, long count)
void	incrementDataBytesSent(java.lang.String channelId, long count)
void	incrementDataEventInserted(java.lang.String channelId, long count)
void	incrementDataExtracted(java.lang.String channelId, long count)
void	incrementDataExtractedErrors(java.lang.String channelId, long count)
void	incrementDataLoaded(java.lang.String channelId, long count)
void	incrementDataLoadedErrors(java.lang.String channelId, long count)
void	incrementDataLoadedOutgoing(java.lang.String channelId, long count)
void	incrementDataLoadedOutgoingErrors(java.lang.String channelId, long count)
void	incrementDataRouted(java.lang.String channelId, long count)
void	incrementDataSent(java.lang.String channelId, long count)
void	incrementDataSentErrors(java.lang.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	incrementRestart()
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	removeRouterStatsByBatch(java.lang.Long batchId)
void	setDataUnRouted(java.lang.String channelId, long count)

Method Detail

newProcessInfo

ProcessInfo newProcessInfo(ProcessInfoKey key)

getProcessInfos

java.util.List<ProcessInfo> getProcessInfos()

getProcessInfosThatHaveDoneWork

java.util.List<ProcessInfo> getProcessInfosThatHaveDoneWork()

getNodesWithProcessesInError

java.util.Set<java.lang.String> getNodesWithProcessesInError()

flush

void flush()

addJobStats

void addJobStats(java.lang.String jobName,
                 long startTime,
                 long endTime,
                 long processedCount)

addJobStats

void addJobStats(java.lang.String targetNodeId,
                 int targetNodeCount,
                 java.lang.String jobName,
                 long startTime,
                 long endTime,
                 long processedCount)

addRouterStats

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

getRouterStatsByBatch

RouterStats getRouterStatsByBatch(java.lang.Long batchId)

removeRouterStatsByBatch

void removeRouterStatsByBatch(java.lang.Long batchId)

incrementDataLoadedErrors

void incrementDataLoadedErrors(java.lang.String channelId,
                               long count)

incrementDataBytesLoaded

void incrementDataBytesLoaded(java.lang.String channelId,
                              long count)

incrementDataLoaded

void incrementDataLoaded(java.lang.String channelId,
                         long count)

incrementDataLoadedOutgoingErrors

void incrementDataLoadedOutgoingErrors(java.lang.String channelId,
                                       long count)

incrementDataBytesLoadedOutgoing

void incrementDataBytesLoadedOutgoing(java.lang.String channelId,
                                      long count)

incrementDataLoadedOutgoing

void incrementDataLoadedOutgoing(java.lang.String channelId,
                                 long count)

incrementDataBytesSent

void incrementDataBytesSent(java.lang.String channelId,
                            long count)

incrementDataSent

void incrementDataSent(java.lang.String channelId,
                       long count)

incrementDataEventInserted

void incrementDataEventInserted(java.lang.String channelId,
                                long count)

incrementDataExtractedErrors

void incrementDataExtractedErrors(java.lang.String channelId,
                                  long count)

incrementDataBytesExtracted

void incrementDataBytesExtracted(java.lang.String channelId,
                                 long count)

incrementDataExtracted

void incrementDataExtracted(java.lang.String channelId,
                            long count)

setDataUnRouted

void setDataUnRouted(java.lang.String channelId,
                     long count)

incrementDataRouted

void incrementDataRouted(java.lang.String channelId,
                         long count)

incrementDataSentErrors

void incrementDataSentErrors(java.lang.String channelId,
                             long count)

incrementRestart

void incrementRestart()

incrementNodesPulled

void incrementNodesPulled(long count)

incrementNodesPushed

void incrementNodesPushed(long count)

incrementTotalNodesPulledTime

void incrementTotalNodesPulledTime(long count)

incrementTotalNodesPushedTime

void incrementTotalNodesPushedTime(long count)

incrementNodesRejected

void incrementNodesRejected(long count)

incrementNodesLoaded

void incrementNodesLoaded(long count)

incrementNodesRegistered

void incrementNodesRegistered(long count)

incrementNodesDisabled

void incrementNodesDisabled(long count)

incrementPurgedBatchIncomingRows

void incrementPurgedBatchIncomingRows(long count)

incrementPurgedBatchOutgoingRows

void incrementPurgedBatchOutgoingRows(long count)

incrementPurgedDataRows

void incrementPurgedDataRows(long count)

incrementPurgedDataEventRows

void incrementPurgedDataEventRows(long count)

incrementTriggersRemovedCount

void incrementTriggersRemovedCount(long count)

incrementTriggersRebuiltCount

void incrementTriggersRebuiltCount(long count)

incrementTriggersCreatedCount

void incrementTriggersCreatedCount(long count)

getWorkingChannelStats

java.util.Map<java.lang.String,ChannelStats> getWorkingChannelStats()

getWorkingHostStats

HostStats getWorkingHostStats()

getNodeStatsForPeriod

java.util.TreeMap<java.util.Date,java.util.Map<java.lang.String,ChannelStats>> getNodeStatsForPeriod(java.util.Date start,
                                                                                                     java.util.Date end,
                                                                                                     java.lang.String nodeId,
                                                                                                     int periodSizeInMinutes)