public class MetricsReplicationSourceSourceImpl extends Object implements MetricsReplicationSourceSource
SOURCE_AGE_OF_LAST_SHIPPED_OP, SOURCE_LOG_EDITS_FILTERED, SOURCE_LOG_READ_IN_BYTES, SOURCE_LOG_READ_IN_EDITS, SOURCE_SHIPPED_BATCHES, SOURCE_SHIPPED_KBS, SOURCE_SHIPPED_OPS, SOURCE_SIZE_OF_LOG_QUEUE
Constructor and Description |
---|
MetricsReplicationSourceSourceImpl(MetricsReplicationSourceImpl rms,
String id) |
Modifier and Type | Method and Description |
---|---|
void |
clear() |
void |
decrSizeOfLogQueue(int size) |
long |
getLastShippedAge() |
void |
incrBatchesShipped(int batches) |
void |
incrLogEditsFiltered(long size) |
void |
incrLogReadInBytes(long size) |
void |
incrLogReadInEdits(long size) |
void |
incrOpsShipped(long ops) |
void |
incrShippedKBs(long size) |
void |
incrSizeOfLogQueue(int size) |
void |
setLastShippedAge(long age) |
void |
setSizeOfLogQueue(int size) |
public MetricsReplicationSourceSourceImpl(MetricsReplicationSourceImpl rms, String id)
public void setLastShippedAge(long age)
setLastShippedAge
in interface MetricsReplicationSourceSource
public void setSizeOfLogQueue(int size)
setSizeOfLogQueue
in interface MetricsReplicationSourceSource
public void incrSizeOfLogQueue(int size)
incrSizeOfLogQueue
in interface MetricsReplicationSourceSource
public void decrSizeOfLogQueue(int size)
decrSizeOfLogQueue
in interface MetricsReplicationSourceSource
public void incrLogReadInEdits(long size)
incrLogReadInEdits
in interface MetricsReplicationSourceSource
public void incrLogEditsFiltered(long size)
incrLogEditsFiltered
in interface MetricsReplicationSourceSource
public void incrBatchesShipped(int batches)
incrBatchesShipped
in interface MetricsReplicationSourceSource
public void incrOpsShipped(long ops)
incrOpsShipped
in interface MetricsReplicationSourceSource
public void incrShippedKBs(long size)
incrShippedKBs
in interface MetricsReplicationSourceSource
public void incrLogReadInBytes(long size)
incrLogReadInBytes
in interface MetricsReplicationSourceSource
public void clear()
clear
in interface MetricsReplicationSourceSource
public long getLastShippedAge()
getLastShippedAge
in interface MetricsReplicationSourceSource