|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object me.prettyprint.cassandra.service.CassandraClientMonitor
public class CassandraClientMonitor
Nested Class Summary | |
---|---|
static class |
CassandraClientMonitor.Counter
List of available JMX counts |
Constructor Summary | |
---|---|
CassandraClientMonitor(HConnectionManager connectionManager)
|
Method Summary | |
---|---|
boolean |
addCassandraHost(String hostStr)
Add a host in the format of "[hostname]:[port]" |
Set<String> |
getExhaustedPoolNames()
List of exhausted pools. |
List<String> |
getKnownHosts()
|
int |
getNumActive()
Total number of active clients in all client pools |
int |
getNumBlockedThreads()
Number of threads that are currently blocked, waiting for a free connection. |
long |
getNumConnectionErrors()
How many times did initial connection failed. |
int |
getNumExhaustedPools()
Number of exhausted connection pools |
int |
getNumIdleConnections()
Total number of idle clients in all client pools |
long |
getNumPoolExhaustedEventCount()
|
int |
getNumPools()
Number of existing connection pools. |
long |
getReadFail()
|
long |
getReadSuccess()
|
long |
getRecoverableErrorCount()
Returns the total number of recoverable errors which is the sum of getRecoverableTimedOutCount, getRecoverableTimedOutCount and getRecoverableTransportExceptionCount |
long |
getRecoverableLoadBalancedConnectErrors()
|
long |
getRecoverableTimedOutCount()
|
long |
getRecoverableTransportExceptionCount()
|
long |
getRecoverableUnavailableCount()
|
long |
getSkipHostSuccess()
|
List<String> |
getStatisticsPerPool()
Retrieves stats per pool. |
Set<String> |
getSuspendedCassandraHosts()
|
long |
getWriteFail()
|
long |
getWriteSuccess()
|
void |
incCounter(CassandraClientMonitor.Counter counterType)
|
boolean |
removeCassandraHost(String hostStr)
Remove a host in the format of "[hostname]:[port]" |
boolean |
suspendCassandraHost(String hostStr)
|
boolean |
unsuspendCassandraHost(String hostStr)
|
void |
updateKnownHosts()
Tells all pulls to update their list of known hosts. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public CassandraClientMonitor(HConnectionManager connectionManager)
Method Detail |
---|
public void incCounter(CassandraClientMonitor.Counter counterType)
public long getWriteSuccess()
public long getReadFail()
getReadFail
in interface CassandraClientMonitorMBean
public long getReadSuccess()
public long getSkipHostSuccess()
getSkipHostSuccess
in interface CassandraClientMonitorMBean
public long getRecoverableTimedOutCount()
getRecoverableTimedOutCount
in interface CassandraClientMonitorMBean
TimedOutException
that the client has been able to recover from by
failing over to a different host in the ring.public long getRecoverableUnavailableCount()
getRecoverableUnavailableCount
in interface CassandraClientMonitorMBean
UnavailableException
that the client has been able to recover from by
failing over to a different host in the ring.public long getWriteFail()
getWriteFail
in interface CassandraClientMonitorMBean
public void updateKnownHosts() throws HectorTransportException
CassandraClientMonitorMBean
updateKnownHosts
in interface CassandraClientMonitorMBean
HectorTransportException
public long getNumPoolExhaustedEventCount()
getNumPoolExhaustedEventCount
in interface CassandraClientMonitorMBean
public Set<String> getExhaustedPoolNames()
CassandraClientMonitorMBean
getExhaustedPoolNames
in interface CassandraClientMonitorMBean
public int getNumActive()
CassandraClientMonitorMBean
getNumActive
in interface CassandraClientMonitorMBean
public int getNumBlockedThreads()
CassandraClientMonitorMBean
ExhaustedPolicy
is
ExhaustedPolicy.WHEN_EXHAUSTED_BLOCK
getNumBlockedThreads
in interface CassandraClientMonitorMBean
public int getNumExhaustedPools()
CassandraClientMonitorMBean
getNumExhaustedPools
in interface CassandraClientMonitorMBean
public int getNumIdleConnections()
CassandraClientMonitorMBean
getNumIdleConnections
in interface CassandraClientMonitorMBean
public int getNumPools()
CassandraClientMonitorMBean
getNumPools
in interface CassandraClientMonitorMBean
public List<String> getKnownHosts()
getKnownHosts
in interface CassandraClientMonitorMBean
public List<String> getStatisticsPerPool()
CassandraClientMonitorMBean
getStatisticsPerPool
in interface CassandraClientMonitorMBean
public long getRecoverableTransportExceptionCount()
getRecoverableTransportExceptionCount
in interface CassandraClientMonitorMBean
TTransportException
that the client has been able to recover from by
failing over to a different host in the ring.public long getRecoverableErrorCount()
CassandraClientMonitorMBean
getRecoverableErrorCount
in interface CassandraClientMonitorMBean
public long getRecoverableLoadBalancedConnectErrors()
getRecoverableLoadBalancedConnectErrors
in interface CassandraClientMonitorMBean
public long getNumConnectionErrors()
CassandraClientMonitorMBean
getNumConnectionErrors
in interface CassandraClientMonitorMBean
public boolean addCassandraHost(String hostStr)
CassandraClientMonitorMBean
addCassandraHost
in interface CassandraClientMonitorMBean
public boolean removeCassandraHost(String hostStr)
CassandraClientMonitorMBean
removeCassandraHost
in interface CassandraClientMonitorMBean
CassandraHost#equals(Object)} for how hosts are compared
public Set<String> getSuspendedCassandraHosts()
getSuspendedCassandraHosts
in interface CassandraClientMonitorMBean
public boolean suspendCassandraHost(String hostStr)
suspendCassandraHost
in interface CassandraClientMonitorMBean
#removeCassandraHost(String)} above for semantics of the host string.
,
HConnectionManager#removeCassandraHost(CassandraHost)} for details of this operation.
public boolean unsuspendCassandraHost(String hostStr)
unsuspendCassandraHost
in interface CassandraClientMonitorMBean
#suspendCassandraHost(String)} above. This is the opposite.
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |