Package com.linkedin.venice.helix

Class HelixReadOnlyStoreConfigRepository

java.lang.Object

com.linkedin.venice.helix.HelixReadOnlyStoreConfigRepository

All Implemented Interfaces:

ReadOnlyStoreConfigRepository, VeniceResource

public class HelixReadOnlyStoreConfigRepository
extends Object
implements ReadOnlyStoreConfigRepository, VeniceResource

This class is used to fetch all store configs from ZK and cached locally, then provide the way to read those configs. Also it will listen on the store configs change event and keep the cache up to date.

This class is non-cluster specified.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	HelixReadOnlyStoreConfigRepository.StoreConfigAddedOrDeletedChangedListener
protected class	HelixReadOnlyStoreConfigRepository.StoreConfigChangedListener

Constructor Summary

Constructors

Constructor	Description
HelixReadOnlyStoreConfigRepository(org.apache.helix.zookeeper.impl.client.ZkClient zkClient, HelixAdapterSerializer adapterSerializer)
HelixReadOnlyStoreConfigRepository(org.apache.helix.zookeeper.impl.client.ZkClient zkClient, ZkStoreConfigAccessor accessor)

Method Summary

Modifier and Type	Method	Description
void	clear()
Optional<StoreConfig>	getStoreConfig(String storeName)	Get the store config by store name.
StoreConfig	getStoreConfigOrThrow(String storeName)
Set<String>	getStores(boolean includeSystemStores)
void	refresh()	Obtain all available stores and load them into cache, but it doesn't fetch the store configs and attach ZK watch yet

Methods inherited from class java.lang.Object

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

Constructor Details

HelixReadOnlyStoreConfigRepository

public HelixReadOnlyStoreConfigRepository(org.apache.helix.zookeeper.impl.client.ZkClient zkClient,
 HelixAdapterSerializer adapterSerializer)

HelixReadOnlyStoreConfigRepository

public HelixReadOnlyStoreConfigRepository(org.apache.helix.zookeeper.impl.client.ZkClient zkClient,
 ZkStoreConfigAccessor accessor)

Method Details

refresh

public void refresh()

Obtain all available stores and load them into cache, but it doesn't fetch the store configs and attach ZK watch yet

Specified by:

refresh in interface VeniceResource

clear

public void clear()

Specified by:

clear in interface VeniceResource

getStoreConfig

public Optional<StoreConfig> getStoreConfig(String storeName)

Get the store config by store name. It would fetch the store config from ZK if it's not in cache yet and attach ZK watch. The corresponding Venice store config is returned for metadata system store's store config. This is the most natural way to handle cluster discovery for metadata system stores and store migration.

Specified by:

getStoreConfig in interface ReadOnlyStoreConfigRepository

getStoreConfigOrThrow

public StoreConfig getStoreConfigOrThrow(String storeName)

Specified by:

getStoreConfigOrThrow in interface ReadOnlyStoreConfigRepository

getStores

public Set<String> getStores(boolean includeSystemStores)

Specified by:

getStores in interface ReadOnlyStoreConfigRepository