public interface IStatisticManager
| 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) |
ProcessInfo newProcessInfo(ProcessInfoKey key)
java.util.List<ProcessInfo> getProcessInfos()
java.util.List<ProcessInfo> getProcessInfosThatHaveDoneWork()
java.util.Set<java.lang.String> getNodesWithProcessesInError()
void flush()
void addJobStats(java.lang.String jobName,
long startTime,
long endTime,
long processedCount)
void addJobStats(java.lang.String targetNodeId,
int targetNodeCount,
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)
RouterStats getRouterStatsByBatch(java.lang.Long batchId)
void removeRouterStatsByBatch(java.lang.Long batchId)
void incrementDataLoadedErrors(java.lang.String channelId,
long count)
void incrementDataBytesLoaded(java.lang.String channelId,
long count)
void incrementDataLoaded(java.lang.String channelId,
long count)
void incrementDataLoadedOutgoingErrors(java.lang.String channelId,
long count)
void incrementDataBytesLoadedOutgoing(java.lang.String channelId,
long count)
void incrementDataLoadedOutgoing(java.lang.String channelId,
long count)
void incrementDataBytesSent(java.lang.String channelId,
long count)
void incrementDataSent(java.lang.String channelId,
long count)
void incrementDataEventInserted(java.lang.String channelId,
long count)
void incrementDataExtractedErrors(java.lang.String channelId,
long count)
void incrementDataBytesExtracted(java.lang.String channelId,
long count)
void incrementDataExtracted(java.lang.String channelId,
long count)
void setDataUnRouted(java.lang.String channelId,
long count)
void incrementDataRouted(java.lang.String channelId,
long count)
void incrementDataSentErrors(java.lang.String channelId,
long count)
void incrementRestart()
void incrementNodesPulled(long count)
void incrementNodesPushed(long count)
void incrementTotalNodesPulledTime(long count)
void incrementTotalNodesPushedTime(long count)
void incrementNodesRejected(long count)
void incrementNodesLoaded(long count)
void incrementNodesRegistered(long count)
void incrementNodesDisabled(long count)
void incrementPurgedBatchIncomingRows(long count)
void incrementPurgedBatchOutgoingRows(long count)
void incrementPurgedDataRows(long count)
void incrementPurgedDataEventRows(long count)
void incrementTriggersRemovedCount(long count)
void incrementTriggersRebuiltCount(long count)
void incrementTriggersCreatedCount(long count)
java.util.Map<java.lang.String,ChannelStats> getWorkingChannelStats()
HostStats getWorkingHostStats()
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)