Package com.linkedin.venice.helix

Class ZkStoreConfigAccessor

java.lang.Object

com.linkedin.venice.helix.ZkStoreConfigAccessor

public class ZkStoreConfigAccessor
extends java.lang.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, java.util.Optional<MetaStoreWriter> metaStoreWriter)

Method Summary

Modifier and Type	Method	Description
boolean	containsConfig(java.lang.String store)
void	createConfig(java.lang.String store, java.lang.String cluster)
void	deleteConfig(java.lang.String store)
java.util.List<StoreConfig>	getAllStoreConfigs(int refreshAttemptsForZkReconnect, long refreshIntervalForZkReconnectInMs)
java.util.List<java.lang.String>	getAllStores()
StoreConfig	getStoreConfig(java.lang.String store)
java.util.List<StoreConfig>	getStoreConfigs(java.util.List<java.lang.String> stores)
void	subscribeStoreConfigAddedOrDeletedListener(org.apache.helix.zookeeper.zkclient.IZkChildListener listener)
void	subscribeStoreConfigDataChangedListener(java.lang.String storeName, org.apache.helix.zookeeper.zkclient.IZkDataListener listener)
void	unsubscribeStoreConfigAddedOrDeletedListener(org.apache.helix.zookeeper.zkclient.IZkChildListener listener)
void	unsubscribeStoreConfigDataChangedListener(java.lang.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 Detail

ZkStoreConfigAccessor

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

Method Detail

getAllStores

public java.util.List<java.lang.String> getAllStores()

getAllStoreConfigs

public java.util.List<StoreConfig> getAllStoreConfigs(int refreshAttemptsForZkReconnect,
                                                      long refreshIntervalForZkReconnectInMs)

containsConfig

public boolean containsConfig(java.lang.String store)

getStoreConfig

public StoreConfig getStoreConfig(java.lang.String store)

getStoreConfigs

public java.util.List<StoreConfig> getStoreConfigs(java.util.List<java.lang.String> stores)

createConfig

public void createConfig(java.lang.String store,
                         java.lang.String cluster)

updateConfig

public void updateConfig(StoreConfig config,
                         boolean isStoreMetaSystemStoreEnabled)

subscribeStoreConfigDataChangedListener

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

unsubscribeStoreConfigDataChangedListener

public void unsubscribeStoreConfigDataChangedListener(java.lang.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(java.lang.String store)