public class

ClusterStatusMonitor

extends Object
implements ClusterStatusMonitorMBean
java.lang.Object
   ↳ org.apache.helix.monitoring.mbeans.ClusterStatusMonitor

Summary

Public Constructors
ClusterStatusMonitor(String clusterName)
Public Methods
void addMessageQueueSize(String instanceName, int msgQueueSize)
String getBeanName()
long getDisabledInstancesGauge()
long getDisabledPartitionsGauge()
long getDownInstanceGauge()
long getInstancesGauge()
long getMaxMessageQueueSizeGauge()
The max message queue size across all instances including controller will report to ingraph
String getMessageQueueSizes()
Get all message queue sizes as a string will NOT report to ingraph
ObjectName getObjectName(String name)
String getSensorName()
void onExternalViewChange(ExternalView externalView, IdealState idealState)
void reset()
void setClusterStatusCounters(int numberLiveInstances, int numberOfInstances, int disabledInstances, int disabledPartitions)
[Expand]
Inherited Methods
From class java.lang.Object
From interface org.apache.helix.monitoring.SensorNameProvider
From interface org.apache.helix.monitoring.mbeans.ClusterStatusMonitorMBean

Public Constructors

public ClusterStatusMonitor (String clusterName)

Public Methods

public void addMessageQueueSize (String instanceName, int msgQueueSize)

public String getBeanName ()

public long getDisabledInstancesGauge ()

public long getDisabledPartitionsGauge ()

public long getDownInstanceGauge ()

public long getInstancesGauge ()

public long getMaxMessageQueueSizeGauge ()

The max message queue size across all instances including controller will report to ingraph

public String getMessageQueueSizes ()

Get all message queue sizes as a string will NOT report to ingraph

public ObjectName getObjectName (String name)

Throws
MalformedObjectNameException

public String getSensorName ()

public void onExternalViewChange (ExternalView externalView, IdealState idealState)

public void reset ()

public void setClusterStatusCounters (int numberLiveInstances, int numberOfInstances, int disabledInstances, int disabledPartitions)