Package com.linkedin.venice.controller

Class HelixVeniceClusterResources

java.lang.Object

com.linkedin.venice.controller.HelixVeniceClusterResources

All Implemented Interfaces:

VeniceResource

public class HelixVeniceClusterResources
extends Object
implements VeniceResource

Aggregate all essentials resources required by controller to manage a Venice cluster.

All resources in this class is dedicated for one Venice cluster.

Constructor Summary

Constructors

Constructor

Description

HelixVeniceClusterResources(String clusterName, org.apache.helix.zookeeper.impl.client.ZkClient zkClient, HelixAdapterSerializer adapterSerializer, SafeHelixManager helixManager, VeniceControllerClusterConfig config, VeniceHelixAdmin admin, io.tehuti.metrics.MetricsRepository metricsRepository, RealTimeTopicSwitcher realTimeTopicSwitcher, Optional<DynamicAccessController> accessController, HelixAdminClient helixAdminClient, VeniceVersionLifecycleEventManager veniceVersionLifecycleEventManager)

Method Summary

Modifier and Type	Method	Description
void	clear()
ClusterLockManager	getClusterLockManager()
VeniceControllerClusterConfig	getConfig()
HelixCustomizedViewOfflinePushRepository	getCustomizedViewRepository()
SafeHelixManager	getHelixManager()
HelixStatusMessageChannel	getMessageChannel()
Optional<MetaStoreWriter>	getMetaStoreWriter()
Optional<MultiTaskSchedulerService>	getMultiTaskSchedulerService()
PushMonitorDelegator	getPushMonitor()
ZkRoutersClusterManager	getRoutersClusterManager()
HelixExternalViewRepository	getRoutingDataRepository()
ReadWriteSchemaRepository	getSchemaRepository()
StoragePersonaRepository	getStoragePersonaRepository()
ZkStoreConfigAccessor	getStoreConfigAccessor()
ReadWriteStoreRepository	getStoreMetadataRepository()
VeniceAdminStats	getVeniceAdminStats()
VeniceVersionLifecycleEventManager	getVeniceVersionLifecycleEventManager()
boolean	isSourceCluster(String clusterName, String storeName)
AutoCloseableLock	lockForShutdown()	Lock the resource for shutdown operation(leadership handle over and controller shutdown).
void	refresh()
void	startDeadStoreStatsPreFetchTask()	Cause DeadStoreStatsPreFetchTask service to begin executing.
void	startErrorPartitionResetTask()	Cause ErrorPartitionResetTask service to begin executing.
void	startLeakedPushStatusCleanUpService()	Cause LeakedPushStatusCleanUpService service to begin executing.
void	startLogCompactionService()	Cause LogCompactionService service to begin executing.
void	startMultiTaskSchedulerService()	Cause MultiTaskSchedulerService service to begin executing.
void	startProtocolVersionAutoDetectionService()	Cause ProtocolVersionAutoDetectionService service to begin executing.
void	stopDeadStoreStatsPreFetchTask()	Cause DeadStoreStatsPreFetchTask service to stop executing.
void	stopErrorPartitionResetTask()	Cause ErrorPartitionResetTask service to stop executing.
void	stopLeakedPushStatusCleanUpService()	Cause LeakedPushStatusCleanUpService service to stop executing.
void	stopLogCompactionService()	Cause LogCompactionService service to stop executing.
void	stopMultiTaskSchedulerService()	Cause MultiTaskSchedulerService service to stop executing.
void	stopProtocolVersionAutoDetectionService()	Cause ProtocolVersionAutoDetectionService service to stop executing.

Methods inherited from class java.lang.Object

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

Constructor Details

HelixVeniceClusterResources

public HelixVeniceClusterResources(String clusterName,
 org.apache.helix.zookeeper.impl.client.ZkClient zkClient,
 HelixAdapterSerializer adapterSerializer,
 SafeHelixManager helixManager,
 VeniceControllerClusterConfig config,
 VeniceHelixAdmin admin,
 io.tehuti.metrics.MetricsRepository metricsRepository,
 RealTimeTopicSwitcher realTimeTopicSwitcher,
 Optional<DynamicAccessController> accessController,
 HelixAdminClient helixAdminClient,
 VeniceVersionLifecycleEventManager veniceVersionLifecycleEventManager)

Method Details

refresh

public void refresh()

Specified by:

refresh in interface VeniceResource

clear

public void clear()

Specified by:

clear in interface VeniceResource

startDeadStoreStatsPreFetchTask

public void startDeadStoreStatsPreFetchTask()

Cause DeadStoreStatsPreFetchTask service to begin executing.

stopDeadStoreStatsPreFetchTask

public void stopDeadStoreStatsPreFetchTask()

Cause DeadStoreStatsPreFetchTask service to stop executing.

startErrorPartitionResetTask

public void startErrorPartitionResetTask()

Cause ErrorPartitionResetTask service to begin executing.

stopErrorPartitionResetTask

public void stopErrorPartitionResetTask()

Cause ErrorPartitionResetTask service to stop executing.

startLeakedPushStatusCleanUpService

public void startLeakedPushStatusCleanUpService()

Cause LeakedPushStatusCleanUpService service to begin executing.

startMultiTaskSchedulerService

public void startMultiTaskSchedulerService()

Cause MultiTaskSchedulerService service to begin executing.

stopMultiTaskSchedulerService

public void stopMultiTaskSchedulerService()

Cause MultiTaskSchedulerService service to stop executing.

stopLeakedPushStatusCleanUpService

public void stopLeakedPushStatusCleanUpService()

Cause LeakedPushStatusCleanUpService service to stop executing.

startProtocolVersionAutoDetectionService

public void startProtocolVersionAutoDetectionService()

Cause ProtocolVersionAutoDetectionService service to begin executing.

stopProtocolVersionAutoDetectionService

public void stopProtocolVersionAutoDetectionService()

Cause ProtocolVersionAutoDetectionService service to stop executing.

startLogCompactionService

public void startLogCompactionService()

Cause LogCompactionService service to begin executing.

stopLogCompactionService

public void stopLogCompactionService()

Cause LogCompactionService service to stop executing.

getStoreMetadataRepository

public ReadWriteStoreRepository getStoreMetadataRepository()

getSchemaRepository

public ReadWriteSchemaRepository getSchemaRepository()

getRoutingDataRepository

public HelixExternalViewRepository getRoutingDataRepository()

getCustomizedViewRepository

public HelixCustomizedViewOfflinePushRepository getCustomizedViewRepository()

getMessageChannel

public HelixStatusMessageChannel getMessageChannel()

getHelixManager

public SafeHelixManager getHelixManager()

getConfig

public VeniceControllerClusterConfig getConfig()

getPushMonitor

public PushMonitorDelegator getPushMonitor()

getRoutersClusterManager

public ZkRoutersClusterManager getRoutersClusterManager()

getMetaStoreWriter

public Optional<MetaStoreWriter> getMetaStoreWriter()

getStoreConfigAccessor

public ZkStoreConfigAccessor getStoreConfigAccessor()

getClusterLockManager

public ClusterLockManager getClusterLockManager()

getVeniceAdminStats

public VeniceAdminStats getVeniceAdminStats()

getStoragePersonaRepository

public StoragePersonaRepository getStoragePersonaRepository()

getMultiTaskSchedulerService

public Optional<MultiTaskSchedulerService> getMultiTaskSchedulerService()

lockForShutdown

public AutoCloseableLock lockForShutdown()

Lock the resource for shutdown operation(leadership handle over and controller shutdown). Once acquired the lock, no other thread could operate for this cluster.

getVeniceVersionLifecycleEventManager

public VeniceVersionLifecycleEventManager getVeniceVersionLifecycleEventManager()

isSourceCluster

public boolean isSourceCluster(String clusterName,
 String storeName)