public class NodeStats extends Object implements Iterable<NodeStats>
/stats
operation.
By implementing the Iterable interface it contains N sets
of data where N is the number of connections the current client holds.
Worth noting is that integer values are returned as BigInteger objects.
This is done to match the unconstrained size provided by Riak.
For example, using the HTTPClusterClient you can retrieve stats from all of your nodes:
HTTPClusterConfig c = new HTTPClusterConfig(10);
HTTPClientConfig cc HTTPClientConfig.defaults();
c.addHosts(cc,"192.168.1.5:8098","192.168.1.6:8098","192.168.1.7:8098");
IRiakClient riakClient = RiakFactory.newClient(c);
for (NodeStats ns : riakClient.stats())
{
System.out.println(ns.nodename());
Syste.out.println(ns.vnodeGets());
}
| Modifier and Type | Class and Description |
|---|---|
static class |
NodeStats.UndefinedStatDeserializer |
| Constructor and Description |
|---|
NodeStats() |
| Modifier and Type | Method and Description |
|---|---|
void |
add(NodeStats anotherStats)
Adds a set of stats to the end of the collection.
|
String |
bashoMetricsVersion()
Returns the
basho_lager_version value from the Riak stats reply |
String |
bashoStatsVersion()
Returns the
basho_stats_version value from the Riak stats reply |
String |
bitcaskVersion()
Returns the
bitcask_version value from the Riak stats reply |
String |
clusterInfoVersion()
Returns the
cluster_info_version value from the Riak stats reply |
String[] |
connectedNodes()
Returns the
connected_nodes value from the Riak Stats reply |
BigInteger |
convergeDelayLast() |
BigInteger |
convergeDelayMax() |
BigInteger |
convergeDelayMean() |
BigInteger |
convergeDelayMin() |
BigInteger |
coordRedirsTotal()
Returns the
coord_redirs_total value from the Riak Stats reply |
BigInteger |
cpuAvg1()
Returns the
cpu_avg1 value from the Riak Stats reply |
BigInteger |
cpuAvg15()
Returns the
cpu_avg15 value from the Riak Stats reply |
BigInteger |
cpuAvg5()
Returns the
cpu_avg5 value from the Riak Stats reply |
BigInteger |
cpuNumProcs()
Returns the
cpu_nprocs value from the Riak Stats reply |
String |
cryptoVersion()
Returns the
crypto_version value from the Riak stats reply |
String |
erlangJsVersion()
Returns the
erlang_js_version value from the Riak stats reply |
BigInteger |
executingMappers()
Returns the
executing_mappers value from the Riak Stats reply |
BigInteger |
gossipReceived() |
BigInteger |
ignoredGossipTotal() |
String |
inetsVersion()
Returns the
inets_version value from the Riak stats reply |
Iterator<NodeStats> |
iterator() |
String |
kernelVersion()
Returns the
kernel_version value from the Riak stats reply |
String |
lagerVersion()
Returns the
lager_version value from the Riak stats reply |
String |
lukeVeriosn()
Returns the
luke_version value from the Riak stats reply |
String |
luwakVersion()
Returns the
luwak_version value from the Riak stats reply |
BigInteger |
memAllocated()
Returns the
mem_allocated value from the Riak Stats reply |
BigInteger |
memoryAtom()
Returns the
memory_atom value from the Riak Stats reply |
BigInteger |
memoryAtomUsed()
Returns the
memory_atom_used value from the Riak Stats reply |
BigInteger |
memoryBinary()
Returns the
memory_binary value from the Riak Stats reply |
BigInteger |
memoryCode()
Returns the
memory_code value from the Riak Stats reply |
BigInteger |
memoryEts()
Returns the
memory_ets value from the Riak Stats reply |
BigInteger |
memoryProcesses()
Returns the
memory_processes value from the Riak Stats reply |
BigInteger |
memoryProcessesUsed()
Returns the
memory_processes_used value from the Riak Stats reply |
BigInteger |
memorySystem()
Returns the
memory_system value from the Riak Stats reply |
BigInteger |
memoryTotal()
Returns the
memory_total value from the Riak Stats reply |
BigInteger |
memTotal()
Returns the
mem_total value from the Riak Stats reply |
String |
mergeIndexVersion()
Returns the
merge_index_version value from the Riak stats reply |
String |
mochiwebVersion()
Returns the
mochiweb_value value from the Riak stats reply |
BigInteger |
nodeGetFsmObjsize95()
Returns the
node_put_fsm_objsize_95 value from the Riak Stats reply |
BigInteger |
nodeGetFsmObjsize99()
Returns the
node_put_fsm_objsize_99 value from the Riak Stats reply |
BigInteger |
nodeGetFsmObjsizeMean()
Returns the
node_get_fsm_objsize_mean value from the Riak Stats reply |
BigInteger |
nodeGetFsmObjsizeMedian()
Returns the
node_put_fsm_objsize_median value from the Riak Stats reply |
BigInteger |
nodeGetFsmSiblings100()
Returns the
node_put_fsm_siblings_100 value from the Riak Stats reply |
BigInteger |
nodeGetFsmSiblings95()
Returns the
node_put_fsm_siblings_95 value from the Riak Stats reply |
BigInteger |
nodeGetFsmSiblings99()
Returns the
node_put_fsm_siblings_99 value from the Riak Stats reply |
BigInteger |
nodeGetFsmSiblingsMean()
Returns the
node_get_fsm_siblings_mean value from the Riak Stats reply |
BigInteger |
nodeGetFsmSiblingsMedian()
Returns the
node_put_fsm_siblings_median value from the Riak Stats reply |
BigInteger |
nodeGetFsmTime100()
Returns the
node_get_fsm_time_100 value from the Riak Stats reply |
BigInteger |
nodeGetFsmTime95()
Returns the
node_get_fsm_time_95 value from the Riak Stats reply |
BigInteger |
nodeGetFsmTime99()
Returns the
node_get_fsm_time_99 value from the Riak Stats reply |
BigInteger |
nodeGetFsmTimeMean()
Returns the
node_get_fsm_time_mean value from the Riak Stats reply |
BigInteger |
nodeGetFsmTimeMedian()
Returns the
node_get_fsm_time_median value from the Riak Stats reply |
BigInteger |
nodeGets()
Returns the
node_gets value from the Riak Stats reply |
BigInteger |
nodeGetsTotal()
Returns the
node_gets_total value from the Riak Stats reply |
String |
nodename()
Returns the
nodename value from the Riak stats reply |
BigInteger |
nodePutFsmSObjsize100()
Returns the
node_put_fsm_objsize_100 value from the Riak Stats reply |
BigInteger |
nodePutFsmTime100()
Returns the
node_put_fsm_time_100 value from the Riak Stats reply |
BigInteger |
nodePutFsmTime95()
Returns the
node_put_fsm_time_95 value from the Riak Stats reply |
BigInteger |
nodePutFsmTime99()
Returns the
node_put_fsm_time_99 value from the Riak Stats reply |
BigInteger |
nodePutFsmTimeMean()
Returns the
node_get_fsm_time_mean value from the Riak Stats reply |
BigInteger |
nodePutFsmTimeMedian()
Returns the
node_put_fsm_time_median value from the Riak Stats reply |
BigInteger |
nodePuts()
Returns the
node_puts value from the Riak Stats reply |
BigInteger |
nodePutsTotal()
Returns the
node_puts_total value from the Riak Stats reply |
String |
osMonVersion()
Returns the
os_mon_version value from the Riak stats reply |
BigInteger |
pbcActive()
Returns the
pbc_active value from the Riak Stats reply |
BigInteger |
pbcConnects()
Returns the
pbc_connects value from the Riak Stats reply |
BigInteger |
pbcConnectsTotal()
Returns the
pbc_connects_total value from the Riak Stats reply |
BigInteger |
postcommitFail() |
BigInteger |
precommitFail() |
String |
publicKeyVersion()
Returns the
public_key_version value from the Riak stats reply |
BigInteger |
readRepairs()
Returns the
read_repairs value from the Riak Stats reply |
BigInteger |
readRepairsTotal()
Returns the
read_repairs_total value from the Riak Stats reply |
BigInteger |
rebalanceDelayLast() |
BigInteger |
rebalanceDelayMax() |
BigInteger |
rebalanceDelayMean() |
BigInteger |
rebalanceDelayMin() |
String |
riak_sysmon_version()
Returns the
riak_sysmon_version value from the Riak stats reply |
String |
riakCoreVersion()
Returns the
riak_core_version value from the Riak stats reply |
String |
riakKvVersion()
Returns the
riak_kv_version value from the Riak stats reply |
BigInteger |
riakKvVnodeqMax() |
BigInteger |
riakKvVnodeqMean() |
BigInteger |
riakKvVnodeqMedian() |
BigInteger |
riakKvVnodeqMin() |
BigInteger |
riakKvVnodeqTotal() |
BigInteger |
riakKvVnodesRunning() |
String |
riakPipeVersion()
Returns the
riak_pipe_version value from the Riak stats reply |
BigInteger |
riakPipeVnodeqMax() |
BigInteger |
riakPipeVnodeqMean() |
BigInteger |
riakPipeVnodeqMedian() |
BigInteger |
riakPipeVnodeqMin() |
BigInteger |
riakPipeVnodeqTotal() |
BigInteger |
riakPipeVnodesRunning() |
String |
riakSearchVersion()
Returns the
riak_search_version value from the Riak stats reply |
BigInteger |
ringCreationSize()
Returns the
ring_creation_size value from the Riak Stats reply |
String[] |
ringMembers()
Returns the
ring_members value from the Riak Stats reply |
BigInteger |
ringNumPartitions()
Returns the
ring_num_partitions value from the Riak Stats reply |
String |
ringOwnership()
Returns the
ring_ownership value from the Riak stats reply |
BigInteger |
ringsReconciled() |
BigInteger |
ringsReconciledTotal() |
String |
runtimeToolsVersion()
Returns the
runtime_tools_version value from the Riak stats reply |
String |
saslVersion()
Returns the
sasl_version value from the Riak stats reply |
String |
skerlVersion()
Returns the
skerl_version value from the Riak stats reply |
String |
sslVeriosn()
Returns the
ssl_version value from the Riak stats reply |
String |
stdlibVersion()
Returns the
stdlib_version value from the Riak stats reply |
String |
storageBackend()
Returns the
storage_backend value from the Riak stats reply |
String |
sysDriverVersion()
Returns the
sys_driver_version value from the Riak stats reply |
BigInteger |
sysGlobalHeapsSize()
Returns the
sys_global_heaps_size value from the Riak Stats reply |
String |
sysHeapType()
Returns the
sys_heap_type value from the Riak stats reply |
BigInteger |
sysLogicalProcessors()
Returns the
sys_logical_processors value from the Riak Stats reply |
String |
sysOtpRelease()
Returns the
sys_otp_release value from the Riak stats reply |
BigInteger |
sysProcessCount()
Returns the
sys_process_count value from the Riak Stats reply |
boolean |
sysSmpSupport()
Returns the
sys_smp_support value from the Riak Stats reply |
String |
sysSystemArchitecture()
Returns the
sys_system_architecture value from the Riak stats reply |
String |
sysSystemVersion()
Returns the
sys_system_version value from the Riak stats reply |
BigInteger |
sysThreadPoolSize()
Returns the
sys_thread_pool_size value from the Riak Stats reply |
boolean |
sysThreadsEnabled()
Returns the
sys_threads_enabled value from the Riak Stats reply |
BigInteger |
sysWordSize()
Returns the
sys_wordsize value from the Riak Stats reply |
BigInteger |
vnodeGets()
Returns the
vnode_gets value from the Riak stats reply |
BigInteger |
vnodeGetsTotal()
Returns the
vnode_gets_total value from the Riak Stats reply |
BigInteger |
vnodeIndexDeletes()
Returns the
vnode_index_deletes value from the Riak Stats reply |
BigInteger |
vnodeIndexDeletesPostingsTotal()
Returns the
vnode_index_deletes_postings_total value from the Riak Stats reply |
BigInteger |
vnodeIndexDeletesTotal()
Returns the
vnode_index_deletes_total value from the Riak Stats reply |
BigInteger |
vnodeIndexReads()
Returns the
vnode_index_reads value from the Riak stats reply |
BigInteger |
vnodeIndexReadsTotal()
Returns the
vnode_index_reads_total value from the Riak Stats reply |
BigInteger |
vnodeIndexWritePostings()
Returns the
vnode_index_writes_postings value from the Riak stats reply |
BigInteger |
vnodeIndexWrites()
Returns the
vnode_index_writes value from the Riak stats reply |
BigInteger |
vnodeIndexWritesPostingsTotal()
Returns the
vnode_index_writes_postings_total value from the Riak Stats reply |
BigInteger |
vnodeIndexWritesTotal()
Returns the
vnode_index_writes_total value from the Riak Stats reply |
BigInteger |
vnodePuts()
Returns the
vnode_gets value from the Riak stats reply |
BigInteger |
vnodePutsTotal()
Returns the
vnode_puts_total value from the Riak Stats reply |
BigInteger |
vnodesIndexDeletesPostings()
Returns the
vnode_index_deletes_postings value from the Riak Stats reply |
String |
webmachineVersion()
Returns the
webmachine_version value from the Riak stats reply |
public BigInteger vnodeGets()
vnode_gets value from the Riak stats replypublic BigInteger vnodePuts()
vnode_gets value from the Riak stats replyint valuepublic BigInteger vnodeIndexReads()
vnode_index_reads value from the Riak stats replyint valuepublic BigInteger vnodeIndexWrites()
vnode_index_writes value from the Riak stats replyint valuepublic BigInteger vnodeIndexWritePostings()
vnode_index_writes_postings value from the Riak stats replyint valuepublic BigInteger vnodeIndexDeletes()
vnode_index_deletes value from the Riak Stats replyint valuepublic BigInteger vnodesIndexDeletesPostings()
vnode_index_deletes_postings value from the Riak Stats replyint valuepublic BigInteger readRepairs()
read_repairs value from the Riak Stats replyint valuepublic BigInteger vnodeGetsTotal()
vnode_gets_total value from the Riak Stats replyint valuepublic BigInteger vnodePutsTotal()
vnode_puts_total value from the Riak Stats replyint valuepublic BigInteger vnodeIndexReadsTotal()
vnode_index_reads_total value from the Riak Stats replyint valuepublic BigInteger vnodeIndexWritesTotal()
vnode_index_writes_total value from the Riak Stats replyint valuepublic BigInteger vnodeIndexWritesPostingsTotal()
vnode_index_writes_postings_total value from the Riak Stats replyint valuepublic BigInteger vnodeIndexDeletesTotal()
vnode_index_deletes_total value from the Riak Stats replyint valuepublic BigInteger vnodeIndexDeletesPostingsTotal()
vnode_index_deletes_postings_total value from the Riak Stats replyint valuepublic BigInteger nodeGets()
node_gets value from the Riak Stats replyint valuepublic BigInteger nodeGetsTotal()
node_gets_total value from the Riak Stats replyint valuepublic BigInteger nodeGetFsmTimeMean()
node_get_fsm_time_mean value from the Riak Stats replyint valuepublic BigInteger nodeGetFsmTimeMedian()
node_get_fsm_time_median value from the Riak Stats replyint valuepublic BigInteger nodeGetFsmTime95()
node_get_fsm_time_95 value from the Riak Stats replyint valuepublic BigInteger nodeGetFsmTime99()
node_get_fsm_time_99 value from the Riak Stats replyint valuepublic BigInteger nodeGetFsmTime100()
node_get_fsm_time_100 value from the Riak Stats replyint valuepublic BigInteger nodePuts()
node_puts value from the Riak Stats replyint valuepublic BigInteger nodePutsTotal()
node_puts_total value from the Riak Stats replyint valuepublic BigInteger nodePutFsmTimeMean()
node_get_fsm_time_mean value from the Riak Stats replyint valuepublic BigInteger nodePutFsmTimeMedian()
node_put_fsm_time_median value from the Riak Stats replyint valuepublic BigInteger nodePutFsmTime95()
node_put_fsm_time_95 value from the Riak Stats replyint valuepublic BigInteger nodePutFsmTime99()
node_put_fsm_time_99 value from the Riak Stats replyint valuepublic BigInteger nodePutFsmTime100()
node_put_fsm_time_100 value from the Riak Stats replyint valuepublic BigInteger nodeGetFsmSiblingsMean()
node_get_fsm_siblings_mean value from the Riak Stats replyint valuepublic BigInteger nodeGetFsmSiblingsMedian()
node_put_fsm_siblings_median value from the Riak Stats replyint valuepublic BigInteger nodeGetFsmSiblings95()
node_put_fsm_siblings_95 value from the Riak Stats replyint valuepublic BigInteger nodeGetFsmSiblings99()
node_put_fsm_siblings_99 value from the Riak Stats replyint valuepublic BigInteger nodeGetFsmSiblings100()
node_put_fsm_siblings_100 value from the Riak Stats replyint valuepublic BigInteger nodeGetFsmObjsizeMean()
node_get_fsm_objsize_mean value from the Riak Stats replyint valuepublic BigInteger nodeGetFsmObjsizeMedian()
node_put_fsm_objsize_median value from the Riak Stats replyint valuepublic BigInteger nodeGetFsmObjsize95()
node_put_fsm_objsize_95 value from the Riak Stats replyint valuepublic BigInteger nodeGetFsmObjsize99()
node_put_fsm_objsize_99 value from the Riak Stats replyint valuepublic BigInteger nodePutFsmSObjsize100()
node_put_fsm_objsize_100 value from the Riak Stats replyint valuepublic BigInteger readRepairsTotal()
read_repairs_total value from the Riak Stats replyint valuepublic BigInteger coordRedirsTotal()
coord_redirs_total value from the Riak Stats replyint valuepublic BigInteger cpuNumProcs()
cpu_nprocs value from the Riak Stats replyint valuepublic BigInteger cpuAvg1()
cpu_avg1 value from the Riak Stats replyint valuepublic BigInteger cpuAvg5()
cpu_avg5 value from the Riak Stats replyint valuepublic BigInteger cpuAvg15()
cpu_avg15 value from the Riak Stats replyint valuepublic BigInteger memTotal()
mem_total value from the Riak Stats replyint valuepublic BigInteger memAllocated()
mem_allocated value from the Riak Stats replyint valuepublic String nodename()
nodename value from the Riak stats replyString valuepublic String[] connectedNodes()
connected_nodes value from the Riak Stats replyString[] of node namespublic String sysDriverVersion()
sys_driver_version value from the Riak stats replyString valuepublic BigInteger sysGlobalHeapsSize()
sys_global_heaps_size value from the Riak Stats replyint valuepublic String sysHeapType()
sys_heap_type value from the Riak stats replyString valuepublic BigInteger sysLogicalProcessors()
sys_logical_processors value from the Riak Stats replyint valuepublic String sysOtpRelease()
sys_otp_release value from the Riak stats replyString valuepublic BigInteger sysProcessCount()
sys_process_count value from the Riak Stats replyint valuepublic boolean sysSmpSupport()
sys_smp_support value from the Riak Stats replyboolean valuepublic String sysSystemVersion()
sys_system_version value from the Riak stats replyString valuepublic String sysSystemArchitecture()
sys_system_architecture value from the Riak stats replyString valuepublic boolean sysThreadsEnabled()
sys_threads_enabled value from the Riak Stats replyboolean valuepublic BigInteger sysThreadPoolSize()
sys_thread_pool_size value from the Riak Stats replyint valuepublic BigInteger sysWordSize()
sys_wordsize value from the Riak Stats replyint valuepublic String[] ringMembers()
ring_members value from the Riak Stats replyString[] of node namespublic BigInteger ringNumPartitions()
ring_num_partitions value from the Riak Stats replyint valuepublic String ringOwnership()
ring_ownership value from the Riak stats replyString valuepublic BigInteger ringCreationSize()
ring_creation_size value from the Riak Stats replyint valuepublic String storageBackend()
storage_backend value from the Riak stats replyString valuepublic BigInteger pbcConnectsTotal()
pbc_connects_total value from the Riak Stats replyint valuepublic BigInteger pbcConnects()
pbc_connects value from the Riak Stats replyint valuepublic BigInteger pbcActive()
pbc_active value from the Riak Stats replyint valuepublic String sslVeriosn()
ssl_version value from the Riak stats replyString valuepublic String publicKeyVersion()
public_key_version value from the Riak stats replyString valuepublic String runtimeToolsVersion()
runtime_tools_version value from the Riak stats replyString valuepublic String bashoStatsVersion()
basho_stats_version value from the Riak stats replyString valuepublic String riakSearchVersion()
riak_search_version value from the Riak stats replyString valuepublic String mergeIndexVersion()
merge_index_version value from the Riak stats replyString valuepublic String luwakVersion()
luwak_version value from the Riak stats replyString valuepublic String skerlVersion()
skerl_version value from the Riak stats replyString valuepublic String riakKvVersion()
riak_kv_version value from the Riak stats replyString valuepublic String bitcaskVersion()
bitcask_version value from the Riak stats replyString valuepublic String lukeVeriosn()
luke_version value from the Riak stats replyString valuepublic String erlangJsVersion()
erlang_js_version value from the Riak stats replyString valuepublic String mochiwebVersion()
mochiweb_value value from the Riak stats replyString valuepublic String inetsVersion()
inets_version value from the Riak stats replyString valuepublic String riakPipeVersion()
riak_pipe_version value from the Riak stats replyString valuepublic String riakCoreVersion()
riak_core_version value from the Riak stats replyString valuepublic String riak_sysmon_version()
riak_sysmon_version value from the Riak stats replyString valuepublic String webmachineVersion()
webmachine_version value from the Riak stats replyString valuepublic String cryptoVersion()
crypto_version value from the Riak stats replyString valuepublic String osMonVersion()
os_mon_version value from the Riak stats replyString valuepublic String clusterInfoVersion()
cluster_info_version value from the Riak stats replyString valuepublic String saslVersion()
sasl_version value from the Riak stats replyString valuepublic String lagerVersion()
lager_version value from the Riak stats replyString valuepublic String bashoMetricsVersion()
basho_lager_version value from the Riak stats replyString valuepublic String stdlibVersion()
stdlib_version value from the Riak stats replyString valuepublic String kernelVersion()
kernel_version value from the Riak stats replyString valuepublic BigInteger executingMappers()
executing_mappers value from the Riak Stats replyint valuepublic BigInteger memoryTotal()
memory_total value from the Riak Stats replyint valuepublic BigInteger memoryProcesses()
memory_processes value from the Riak Stats replyint valuepublic BigInteger memoryProcessesUsed()
memory_processes_used value from the Riak Stats replyint valuepublic BigInteger memorySystem()
memory_system value from the Riak Stats replyint valuepublic BigInteger memoryAtom()
memory_atom value from the Riak Stats replyint valuepublic BigInteger memoryAtomUsed()
memory_atom_used value from the Riak Stats replyint valuepublic BigInteger memoryBinary()
memory_binary value from the Riak Stats replyint valuepublic BigInteger memoryCode()
memory_code value from the Riak Stats replyint valuepublic BigInteger memoryEts()
memory_ets value from the Riak Stats replyint valuepublic BigInteger precommitFail()
public BigInteger postcommitFail()
public BigInteger ignoredGossipTotal()
public BigInteger ringsReconciledTotal()
public BigInteger ringsReconciled()
public BigInteger gossipReceived()
public BigInteger convergeDelayMin()
public BigInteger convergeDelayMax()
public BigInteger convergeDelayMean()
public BigInteger convergeDelayLast()
public BigInteger rebalanceDelayMin()
public BigInteger rebalanceDelayMax()
public BigInteger rebalanceDelayMean()
public BigInteger rebalanceDelayLast()
public BigInteger riakKvVnodesRunning()
public BigInteger riakKvVnodeqMin()
public BigInteger riakKvVnodeqMedian()
public BigInteger riakKvVnodeqMean()
public BigInteger riakKvVnodeqMax()
public BigInteger riakKvVnodeqTotal()
public BigInteger riakPipeVnodesRunning()
public BigInteger riakPipeVnodeqMin()
public BigInteger riakPipeVnodeqMedian()
public BigInteger riakPipeVnodeqMean()
public BigInteger riakPipeVnodeqMax()
public BigInteger riakPipeVnodeqTotal()
public void add(NodeStats anotherStats)
anotherStats - an additional NodeStatsCopyright © 2014. All Rights Reserved.