Merge pull request shyiko#176 from adsr/upstream

Add TotalBytesReceived metric

Author: shyiko

src/main/java/com/github/shyiko/mysql/binlog/jmx/BinaryLogClientStatistics.java

@@ -31,6 +31,7 @@ public class BinaryLogClientStatistics implements BinaryLogClientStatisticsMXBea
     private AtomicReference<EventHeader> lastEventHeader = new AtomicReference<EventHeader>();
     private AtomicLong timestampOfLastEvent = new AtomicLong();
     private AtomicLong totalNumberOfEventsSeen = new AtomicLong();
+    private AtomicLong totalBytesReceived = new AtomicLong();
     private AtomicLong numberOfSkippedEvents = new AtomicLong();
     private AtomicLong numberOfDisconnects = new AtomicLong();
 
@@ -72,6 +73,11 @@ public long getTotalNumberOfEventsSeen() {
         return totalNumberOfEventsSeen.get();
     }
 
+    @Override
+    public long getTotalBytesReceived() {
+        return totalBytesReceived.get();
+    }
+
     @Override
     public long getNumberOfSkippedEvents() {
         return numberOfSkippedEvents.get();
@@ -87,15 +93,18 @@ public void reset() {
         lastEventHeader.set(null);
         timestampOfLastEvent.set(0);
         totalNumberOfEventsSeen.set(0);
+        totalBytesReceived.set(0);
         numberOfSkippedEvents.set(0);
         numberOfDisconnects.set(0);
     }
 
     @Override
     public void onEvent(Event event) {
-        lastEventHeader.set(event.getHeader());
+        EventHeader header = event.getHeader();
+        lastEventHeader.set(header);
         timestampOfLastEvent.set(getCurrentTimeMillis());
         totalNumberOfEventsSeen.getAndIncrement();
+        totalBytesReceived.getAndAdd(header.getHeaderLength() + header.getDataLength());
     }
 
     @Override

src/main/java/com/github/shyiko/mysql/binlog/jmx/BinaryLogClientStatisticsMXBean.java

@@ -24,6 +24,7 @@ public interface BinaryLogClientStatisticsMXBean {
     long getSecondsSinceLastEvent();
     long getSecondsBehindMaster();
     long getTotalNumberOfEventsSeen();
+    long getTotalBytesReceived();
     long getNumberOfSkippedEvents();
     long getNumberOfDisconnects();
     void reset();