Package com.linkedin.venice.helix

Class HelixReadOnlyLiveClusterConfigRepository

java.lang.Object

com.linkedin.venice.helix.HelixReadOnlyLiveClusterConfigRepository

All Implemented Interfaces:

ReadOnlyLiveClusterConfigRepository, VeniceResource

Direct Known Subclasses:

HelixReadWriteLiveClusterConfigRepository

public class HelixReadOnlyLiveClusterConfigRepository
extends Object
implements ReadOnlyLiveClusterConfigRepository

This class is used to cache live cluster configs. The expected users are all venice-backend components.

Field Summary

Fields

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	clear()
LiveClusterConfig	getConfigs()	Get live 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 final org.apache.helix.manager.zk.ZkBaseDataAccessor<LiveClusterConfig> zkDataAccessor

clusterConfigZkPath

protected final String clusterConfigZkPath

liveClusterConfig

protected LiveClusterConfig liveClusterConfig

Constructor Details

HelixReadOnlyLiveClusterConfigRepository

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

Method Details

getConfigs

public LiveClusterConfig getConfigs()

Description copied from interface: ReadOnlyLiveClusterConfigRepository

Get live cluster configs

Specified by:

getConfigs in interface ReadOnlyLiveClusterConfigRepository

Returns:

refresh

public void refresh()

Specified by:

refresh in interface VeniceResource

clear

public void clear()

Specified by:

clear in interface VeniceResource