Package com.linkedin.venice.helix

Class ZkStoreConfigAccessor

java.lang.Object

com.linkedin.venice.helix.ZkStoreConfigAccessor

public class ZkStoreConfigAccessor
extends Object

The class is used to access the store configs in Zookeeper.

This class is non-cluster specified.

Constructor Summary

Constructors

Constructor	Description
ZkStoreConfigAccessor(org.apache.helix.zookeeper.impl.client.ZkClient zkClient, HelixAdapterSerializer adapterSerializer, Optional<MetaStoreWriter> metaStoreWriter)

Method Summary

Modifier and Type	Method	Description
boolean	containsConfig(String store)
void	createConfig(String store, String cluster)
void	deleteConfig(String store)
List<String>	getAllStores()
StoreConfig	getStoreConfig(String store)
List<StoreConfig>	getStoreConfigs(List<String> stores)
void	subscribeStoreConfigAddedOrDeletedListener(org.apache.helix.zookeeper.zkclient.IZkChildListener listener)
void	subscribeStoreConfigDataChangedListener(String storeName, org.apache.helix.zookeeper.zkclient.IZkDataListener listener)
void	unsubscribeStoreConfigAddedOrDeletedListener(org.apache.helix.zookeeper.zkclient.IZkChildListener listener)
void	unsubscribeStoreConfigDataChangedListener(String storeName, org.apache.helix.zookeeper.zkclient.IZkDataListener listener)
void	updateConfig(StoreConfig config, boolean isStoreMetaSystemStoreEnabled)

Methods inherited from class java.lang.Object

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

Constructor Details

ZkStoreConfigAccessor

public ZkStoreConfigAccessor(org.apache.helix.zookeeper.impl.client.ZkClient zkClient,
 HelixAdapterSerializer adapterSerializer,
 Optional<MetaStoreWriter> metaStoreWriter)

Method Details

getAllStores

public List<String> getAllStores()

containsConfig

public boolean containsConfig(String store)

getStoreConfig

public StoreConfig getStoreConfig(String store)

getStoreConfigs

public List<StoreConfig> getStoreConfigs(List<String> stores)

createConfig

public void createConfig(String store,
 String cluster)

updateConfig

public void updateConfig(StoreConfig config,
 boolean isStoreMetaSystemStoreEnabled)

subscribeStoreConfigDataChangedListener

public void subscribeStoreConfigDataChangedListener(String storeName,
 org.apache.helix.zookeeper.zkclient.IZkDataListener listener)

unsubscribeStoreConfigDataChangedListener

public void unsubscribeStoreConfigDataChangedListener(String storeName,
 org.apache.helix.zookeeper.zkclient.IZkDataListener listener)

subscribeStoreConfigAddedOrDeletedListener

public void subscribeStoreConfigAddedOrDeletedListener(org.apache.helix.zookeeper.zkclient.IZkChildListener listener)

unsubscribeStoreConfigAddedOrDeletedListener

public void unsubscribeStoreConfigAddedOrDeletedListener(org.apache.helix.zookeeper.zkclient.IZkChildListener listener)

deleteConfig

public void deleteConfig(String store)