com.continuent.tungsten.replicator.conf
Interface ReplicatorMonitorMBean

All Known Implementing Classes:

ReplicatorMonitor

public interface ReplicatorMonitorMBean

Replicator monitoring interface. This interface contains in memory counters used to show replication performance. They reset whenever the replicator is restarted.

Version:

1.0

Author:

Robert Hodges

Method Summary

void	clearCounters() Clear monitoring counters and timing intervals.
DynamicMBeanHelper	createHelper()
long	getApplied() Returns the number of transactions applied to target.
long	getAppliedLastSeqNo() Returns the last sequence number that was applied.
java.sql.Timestamp	getAppliedLastSourceTStamp() Returns the source timestamp of the last event that was applied.
java.sql.Timestamp	getAppliedLastTargetTStamp() Returns the timestamp when the last event was applied.
double	getAppliedLatency() Returns the latency of the last event processed in seconds, including heartbeat events.
double	getAppliedPerSec() Returns the average events applied per second.
java.util.ArrayList<MonitorThreadInfo>	getCPUTimes() Returns hash map of CPUTimes per thread
boolean	getDetailEnabled() return TRUE IFF detailed statistics are enabled
long	getEvents() Returns the number of events (extracted for extractor, applied for applier).
int	getEventsTotalCacheSize() Returns the events cache total size.
int	getEventsUsedCacheSize() Returns the events cache used size.
long	getExtracted() Returns the total events extracted.
long	getExtractedLastSeqNo() Returns the last sequence number that was extracted.
double	getExtractedPerSec() Returns the average events extracted per second.
long	getLatestEpochNumber()
java.lang.String	getLatestEventId()
double	getMonitoringIntervalSecs() Gets the length of the current monitoring interval in seconds.
long	getReceived() Returns the number of events received and placed in the THL.
long	getReceivedLastSeqNo() Returns the sequence number of the last event received.
java.sql.Timestamp	getReceivedLastSourceTStamp() Returns the source timestamp of the last event that was received.
java.sql.Timestamp	getReceivedLastTargetTStamp() Returns the timestamp when the last event was received.
double	getReceivedLatency() Returns the latency of the last event received in seconds.
double	getReceivedPerSec() Returns the average events received per second.
long	getRows() Returns the number of rows (extracted for extrator, applied for applier).
long	getStartTimeMillis() Returns the monitoring start time in milliseconds.
int	getUsedCacheRatio() Returns used vs.
void	setDetailEnabled(boolean detailEnabled) set value for detail statistics gathering

Method Detail

clearCounters

void clearCounters()

Clear monitoring counters and timing intervals. This ensures that values are current when looking at transaction processing rates.

getDetailEnabled

boolean getDetailEnabled()

return TRUE IFF detailed statistics are enabled

setDetailEnabled

void setDetailEnabled(boolean detailEnabled)

set value for detail statistics gathering

getStartTimeMillis

long getStartTimeMillis()

Returns the monitoring start time in milliseconds.

getMonitoringIntervalSecs

double getMonitoringIntervalSecs()

Gets the length of the current monitoring interval in seconds.

getEvents

long getEvents()

Returns the number of events (extracted for extractor, applied for applier).

getRows

long getRows()

Returns the number of rows (extracted for extrator, applied for applier).

getApplied

long getApplied()

Returns the number of transactions applied to target.

getAppliedLastSeqNo

long getAppliedLastSeqNo()

Returns the last sequence number that was applied.

getAppliedLatency

double getAppliedLatency()

Returns the latency of the last event processed in seconds, including heartbeat events.

getLatestEpochNumber

long getLatestEpochNumber()

Returns:

the latest epoch number, the context of which is determined by whether the replicator's role is master or slave.

getLatestEventId

java.lang.String getLatestEventId()

Returns:

the latest event id, the context of which is determined by whether the replicator's role is master or slave.

getAppliedPerSec

double getAppliedPerSec()

Returns the average events applied per second.

getAppliedLastSourceTStamp

java.sql.Timestamp getAppliedLastSourceTStamp()

Returns the source timestamp of the last event that was applied.

getAppliedLastTargetTStamp

java.sql.Timestamp getAppliedLastTargetTStamp()

Returns the timestamp when the last event was applied.

getExtracted

long getExtracted()

Returns the total events extracted.

getExtractedLastSeqNo

long getExtractedLastSeqNo()

Returns the last sequence number that was extracted.

getExtractedPerSec

double getExtractedPerSec()

Returns the average events extracted per second.

getReceived

long getReceived()

Returns the number of events received and placed in the THL.

getReceivedLastSeqNo

long getReceivedLastSeqNo()

Returns the sequence number of the last event received.

getReceivedLatency

double getReceivedLatency()

Returns the latency of the last event received in seconds.

getReceivedPerSec

double getReceivedPerSec()

Returns the average events received per second.

getReceivedLastTargetTStamp

java.sql.Timestamp getReceivedLastTargetTStamp()

Returns the timestamp when the last event was received.

getReceivedLastSourceTStamp

java.sql.Timestamp getReceivedLastSourceTStamp()

Returns the source timestamp of the last event that was received.

getEventsTotalCacheSize

int getEventsTotalCacheSize()

Returns the events cache total size.

getEventsUsedCacheSize

int getEventsUsedCacheSize()

Returns the events cache used size.

getUsedCacheRatio

int getUsedCacheRatio()

Returns used vs. total cache size ratio

getCPUTimes

java.util.ArrayList<MonitorThreadInfo> getCPUTimes()

Returns hash map of CPUTimes per thread

createHelper

DynamicMBeanHelper createHelper()
                                throws java.lang.Exception

Throws:

java.lang.Exception