Package com.linkedin.venice.helix

Class HelixReadOnlyDarkClusterConfigRepository

java.lang.Object

com.linkedin.venice.helix.HelixReadOnlyDarkClusterConfigRepository

All Implemented Interfaces:

ReadOnlyDarkClusterConfigRepository, VeniceResource

Direct Known Subclasses:

HelixReadWriteDarkClusterConfigRepository

public class HelixReadOnlyDarkClusterConfigRepository
extends Object
implements ReadOnlyDarkClusterConfigRepository

This class is a read-only implementation of ReadOnlyDarkClusterConfigRepository. It listens to changes in the dark cluster configuration stored in ZooKeeper and updates its in-memory representation accordingly. ZK Config Path:

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	HelixReadOnlyDarkClusterConfigRepository.ClusterConfigZkListener

Field Summary

Fields

Modifier and Type	Field	Description
protected final String	clusterConfigZkPath
protected DarkClusterConfig	darkClusterConfig
protected org.apache.helix.manager.zk.ZkBaseDataAccessor<DarkClusterConfig>	zkDataAccessor

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	clear()
DarkClusterConfig	getConfigs()	Get dark cluster configs
void	refresh()

Methods inherited from class java.lang.Object

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

Field Details

zkDataAccessor

protected org.apache.helix.manager.zk.ZkBaseDataAccessor<DarkClusterConfig> zkDataAccessor

clusterConfigZkPath

protected final String clusterConfigZkPath

darkClusterConfig

protected DarkClusterConfig darkClusterConfig

Constructor Details

HelixReadOnlyDarkClusterConfigRepository

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

Method Details

getConfigs

public DarkClusterConfig getConfigs()

Description copied from interface: ReadOnlyDarkClusterConfigRepository

Get dark cluster configs

Specified by:

getConfigs in interface ReadOnlyDarkClusterConfigRepository

Returns:

refresh

public void refresh()

Specified by:

refresh in interface ReadOnlyDarkClusterConfigRepository

Specified by:

refresh in interface VeniceResource

clear

public void clear()

Specified by:

clear in interface ReadOnlyDarkClusterConfigRepository

Specified by:

clear in interface VeniceResource