Package com.linkedin.venice.helix

Class HelixReadOnlyDegradedDcStatesRepository

java.lang.Object

com.linkedin.venice.helix.HelixReadOnlyDegradedDcStatesRepository

Direct Known Subclasses:

HelixReadWriteDegradedDcStatesRepository

public class HelixReadOnlyDegradedDcStatesRepository
extends Object

Read-only ZK-backed repository for degraded DC states. Caches the current state in memory and watches for ZK changes.

Field Summary

Fields

Modifier and Type	Field	Description
protected DegradedDcStates	states
protected final org.apache.helix.manager.zk.ZkBaseDataAccessor<DegradedDcStates>	zkDataAccessor
protected final String	zkPath

Constructor Summary

Constructors

Constructor	Description
HelixReadOnlyDegradedDcStatesRepository(org.apache.helix.zookeeper.impl.client.ZkClient zkClient, HelixAdapterSerializer adapter, String clusterName)

Method Summary

Modifier and Type	Method	Description
void	clear()
DegradedDcStates	getStates()
void	refresh()

Methods inherited from class java.lang.Object

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

Field Details

zkDataAccessor

protected final org.apache.helix.manager.zk.ZkBaseDataAccessor<DegradedDcStates> zkDataAccessor

zkPath

protected final String zkPath

states

protected volatile DegradedDcStates states

Constructor Details

HelixReadOnlyDegradedDcStatesRepository

public HelixReadOnlyDegradedDcStatesRepository(org.apache.helix.zookeeper.impl.client.ZkClient zkClient,
 HelixAdapterSerializer adapter,
 String clusterName)

Method Details

getStates

public DegradedDcStates getStates()

refresh

public void refresh()

clear

public void clear()