Package com.linkedin.venice.stats

Class ZkClientStatusStats

java.lang.Object

com.linkedin.venice.stats.AbstractVeniceStats

com.linkedin.venice.stats.ZkClientStatusStats

All Implemented Interfaces:

org.apache.helix.zookeeper.zkclient.IZkStateListener

public class ZkClientStatusStats
extends AbstractVeniceStats
implements org.apache.helix.zookeeper.zkclient.IZkStateListener

The stats keep track of ZK Client status changes. It maps statuses with integers. Common status: Watcher.Event.KeeperState.Unknown code: -1 (used as init value) Watcher.Event.KeeperState.Disconnected code: 0 Watcher.Event.KeeperState.SyncConnected code: 3

Field Summary

Fields inherited from class com.linkedin.venice.stats.AbstractVeniceStats

DELIMITER

Constructor Summary

Constructors

Constructor	Description
ZkClientStatusStats(io.tehuti.metrics.MetricsRepository metricsRepository, java.lang.String zkClientName)

Method Summary

Modifier and Type	Method	Description
void	handleNewSession(java.lang.String s)
void	handleSessionEstablishmentError(java.lang.Throwable error)
void	handleStateChanged(org.apache.zookeeper.Watcher.Event.KeeperState state)

Methods inherited from class com.linkedin.venice.stats.AbstractVeniceStats

avgAndMax, avgAndTotal, getMetricsRepository, getName, getSensorFullName, getSensorFullName, isTotalStats, minAndMax, registerOnlyTotalRate, registerPerStoreAndTotalSensor, registerSensor, registerSensor, registerSensor, registerSensor, registerSensorAttributeGauge, registerSensorIfAbsent, registerSensorIfAbsent, registerSensorIfAbsent, registerSensorWithAggregate, registerSensorWithAggregate, unregisterAllSensors

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ZkClientStatusStats

public ZkClientStatusStats(io.tehuti.metrics.MetricsRepository metricsRepository,
                           java.lang.String zkClientName)

Method Detail

handleStateChanged

public void handleStateChanged(org.apache.zookeeper.Watcher.Event.KeeperState state)

Specified by:

handleStateChanged in interface org.apache.helix.zookeeper.zkclient.IZkStateListener

handleNewSession

public void handleNewSession(java.lang.String s)

Specified by:

handleNewSession in interface org.apache.helix.zookeeper.zkclient.IZkStateListener

handleSessionEstablishmentError

public void handleSessionEstablishmentError(java.lang.Throwable error)

Specified by:

handleSessionEstablishmentError in interface org.apache.helix.zookeeper.zkclient.IZkStateListener