Package com.linkedin.venice.controller

Class UserSystemStoreLifeCycleHelper

java.lang.Object

com.linkedin.venice.controller.UserSystemStoreLifeCycleHelper

public class UserSystemStoreLifeCycleHelper
extends Object

This class is responsible for automatically create and delete per user store system store resources when the corresponding user store is created or deleted.

Constructor Summary

Constructors

Constructor	Description
UserSystemStoreLifeCycleHelper(VeniceParentHelixAdmin parentAdmin, Optional<AuthorizerService> authorizerService, VeniceControllerMultiClusterConfig multiClusterConfig)

Method Summary

Modifier and Type	Method	Description
static void	deleteSystemStore(VeniceHelixAdmin admin, ReadWriteStoreRepository storeRepository, PushMonitorDelegator pushMonitor, String clusterName, String systemStoreName, boolean isStoreMigrating, MetaStoreWriter metaStoreWriter, org.apache.logging.log4j.Logger LOGGER)
static boolean	isSystemStoreTypeEnabledInUserStore(Store userStore, VeniceSystemStoreType systemStoreType)	This method checks if a specific system store type is enabled in a given user store.
static Version	materializeSystemStore(VeniceParentHelixAdmin parentAdmin, String clusterName, String systemStoreName, String pushJobId)
List<VeniceSystemStoreType>	materializeSystemStoresForUserStore(String clusterName, String userStoreName)
void	maybeCreateSystemStoreWildcardAcl(String storeName)
static void	maybeDeleteSystemStoresForUserStore(VeniceHelixAdmin admin, ReadWriteStoreRepository storeRepository, PushMonitorDelegator pushMonitor, String clusterName, Store userStore, MetaStoreWriter metaStoreWriter, org.apache.logging.log4j.Logger LOGGER)

Methods inherited from class java.lang.Object

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

Constructor Details

UserSystemStoreLifeCycleHelper

public UserSystemStoreLifeCycleHelper(VeniceParentHelixAdmin parentAdmin,
 Optional<AuthorizerService> authorizerService,
 VeniceControllerMultiClusterConfig multiClusterConfig)

Method Details

materializeSystemStoresForUserStore

public List<VeniceSystemStoreType> materializeSystemStoresForUserStore(String clusterName,
 String userStoreName)

materializeSystemStore

public static Version materializeSystemStore(VeniceParentHelixAdmin parentAdmin,
 String clusterName,
 String systemStoreName,
 String pushJobId)

maybeCreateSystemStoreWildcardAcl

public void maybeCreateSystemStoreWildcardAcl(String storeName)

deleteSystemStore

public static void deleteSystemStore(VeniceHelixAdmin admin,
 ReadWriteStoreRepository storeRepository,
 PushMonitorDelegator pushMonitor,
 String clusterName,
 String systemStoreName,
 boolean isStoreMigrating,
 MetaStoreWriter metaStoreWriter,
 org.apache.logging.log4j.Logger LOGGER)

maybeDeleteSystemStoresForUserStore

public static void maybeDeleteSystemStoresForUserStore(VeniceHelixAdmin admin,
 ReadWriteStoreRepository storeRepository,
 PushMonitorDelegator pushMonitor,
 String clusterName,
 Store userStore,
 MetaStoreWriter metaStoreWriter,
 org.apache.logging.log4j.Logger LOGGER)

isSystemStoreTypeEnabledInUserStore

public static boolean isSystemStoreTypeEnabledInUserStore(Store userStore,
 VeniceSystemStoreType systemStoreType)

This method checks if a specific system store type is enabled in a given user store.