Package org.jumpmind.symmetric.statistic

Interface IStatisticManager

All Known Implementing Classes:
MockStatisticManager, StatisticManager
public interface IStatisticManager
This manager provides an API record statistics

  • Method Details

    • newProcessInfo

      ProcessInfo newProcessInfo(ProcessInfoKey key)

    • getProcessInfos

      List<ProcessInfo> getProcessInfos()

    • getProcessInfosThatHaveDoneWork

      List<ProcessInfo> getProcessInfosThatHaveDoneWork()

    • getNodesWithProcessesInError

      Set<String> getNodesWithProcessesInError()

    • flush

      void flush()

    • addJobStats

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

    • addJobStats

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

    • addJobStats

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

    • addJobStats

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

    • addRouterStats

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

    • getRouterStatsByBatch

      RouterStats getRouterStatsByBatch(Long batchId)

    • removeRouterStatsByBatch

      void removeRouterStatsByBatch(Long batchId)

    • incrementDataLoadedErrors

      void incrementDataLoadedErrors(String channelId, long count)

    • incrementDataBytesLoaded

      void incrementDataBytesLoaded(String channelId, long count)

    • incrementDataLoaded

      void incrementDataLoaded(String channelId, long count)

    • incrementDataLoadedOutgoingErrors

      void incrementDataLoadedOutgoingErrors(String channelId, long count)

    • incrementDataBytesLoadedOutgoing

      void incrementDataBytesLoadedOutgoing(String channelId, long count)

    • incrementDataLoadedOutgoing

      void incrementDataLoadedOutgoing(String channelId, long count)

    • incrementDataBytesSent

      void incrementDataBytesSent(String channelId, long count)

    • incrementDataSent

      void incrementDataSent(String channelId, long count)

    • incrementDataEventInserted

      void incrementDataEventInserted(String channelId, long count)

    • incrementDataExtractedErrors

      void incrementDataExtractedErrors(String channelId, long count)

    • incrementDataBytesExtracted

      void incrementDataBytesExtracted(String channelId, long count)

    • incrementDataExtracted

      void incrementDataExtracted(String channelId, long count)

    • setDataUnRouted

      void setDataUnRouted(String channelId, long count)

    • incrementDataRouted

      void incrementDataRouted(String channelId, long count)

    • incrementDataSentErrors

      void incrementDataSentErrors(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)

    • incrementPurgedStrandedDataRows

      void incrementPurgedStrandedDataRows(long count)

    • incrementPurgedStrandedDataEventRows

      void incrementPurgedStrandedDataEventRows(long count)

    • incrementPurgedExpiredDataRows

      void incrementPurgedExpiredDataRows(long count)

    • incrementTriggersRemovedCount

      void incrementTriggersRemovedCount(long count)

    • incrementTriggersRebuiltCount

      void incrementTriggersRebuiltCount(long count)

    • incrementTriggersCreatedCount

      void incrementTriggersCreatedCount(long count)

    • incrementTableRows

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

    • getWorkingChannelStats

      Map<String,ChannelStats> getWorkingChannelStats()

    • getWorkingJobStats

      List<JobStats> getWorkingJobStats()

    • getWorkingHostStats

      HostStats getWorkingHostStats()

    • getNodeStatsForPeriod

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

    • getMostRecentActiveTableSynced

      String getMostRecentActiveTableSynced()

    • getTotalLoadedRows

      Map<Integer,Date> getTotalLoadedRows()