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 setClusterInstanceStatus(Set<String> liveInstanceSet, Set<String> instanceSet, Set<String> disabledInstanceSet, Map<StringSet<String>> disabledPartitions, Map<StringSet<String>> tags)
Update the gauges for all instances in the cluster
[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)

public String getSensorName ()

public void onExternalViewChange (ExternalView externalView, IdealState idealState)

public void reset ()

public void setClusterInstanceStatus (Set<String> liveInstanceSet, Set<String> instanceSet, Set<String> disabledInstanceSet, Map<StringSet<String>> disabledPartitions, Map<StringSet<String>> tags)

Update the gauges for all instances in the cluster

Parameters
liveInstanceSet the current set of live instances
instanceSet the current set of configured instances (live or other
disabledInstanceSet the current set of configured instances that are disabled
disabledPartitions a map of instance name to the set of partitions disabled on it
tags a map of instance name to the set of tags on it