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 java.lang.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 java.lang.String
clusterConfigZkPath
protected LiveClusterConfig
liveClusterConfig
protected org.apache.helix.manager.zk.ZkBaseDataAccessor<LiveClusterConfig>
zkDataAccessor
-
Constructor Summary
Constructors Constructor Description HelixReadOnlyLiveClusterConfigRepository(org.apache.helix.zookeeper.impl.client.ZkClient zkClient, HelixAdapterSerializer adapter, java.lang.String clusterName)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
clear()
LiveClusterConfig
getConfigs()
Get live cluster configsvoid
refresh()
-
-
-
Field Detail
-
zkDataAccessor
protected final org.apache.helix.manager.zk.ZkBaseDataAccessor<LiveClusterConfig> zkDataAccessor
-
clusterConfigZkPath
protected final java.lang.String clusterConfigZkPath
-
liveClusterConfig
protected LiveClusterConfig liveClusterConfig
-
-
Constructor Detail
-
HelixReadOnlyLiveClusterConfigRepository
public HelixReadOnlyLiveClusterConfigRepository(org.apache.helix.zookeeper.impl.client.ZkClient zkClient, HelixAdapterSerializer adapter, java.lang.String clusterName)
-
-
Method Detail
-
getConfigs
public LiveClusterConfig getConfigs()
Description copied from interface:ReadOnlyLiveClusterConfigRepository
Get live cluster configs- Specified by:
getConfigs
in interfaceReadOnlyLiveClusterConfigRepository
- Returns:
-
refresh
public void refresh()
- Specified by:
refresh
in interfaceVeniceResource
-
clear
public void clear()
- Specified by:
clear
in interfaceVeniceResource
-
-