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.