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)

Method Summary

Modifier and Type	Method	Description
void	clear()
ClusterLockManager	getClusterLockManager()
VeniceControllerClusterConfig	getConfig()
HelixCustomizedViewOfflinePushRepository	getCustomizedViewRepository()
SafeHelixManager	getHelixManager()
HelixStatusMessageChannel	getMessageChannel()
Optional<MetaStoreWriter>	getMetaStoreWriter()
PushMonitorDelegator	getPushMonitor()
ZkRoutersClusterManager	getRoutersClusterManager()
HelixExternalViewRepository	getRoutingDataRepository()
ReadWriteSchemaRepository	getSchemaRepository()
StoragePersonaRepository	getStoragePersonaRepository()
ZkStoreConfigAccessor	getStoreConfigAccessor()
ReadWriteStoreRepository	getStoreMetadataRepository()
VeniceAdminStats	getVeniceAdminStats()
AutoCloseableLock	lockForShutdown()	Lock the resource for shutdown operation(leadership handle over and controller shutdown).
void	refresh()
void	startErrorPartitionResetTask()	Cause ErrorPartitionResetTask service to begin executing.
void	startLeakedPushStatusCleanUpService()	Cause LeakedPushStatusCleanUpService service to begin executing.
void	stopErrorPartitionResetTask()	Cause ErrorPartitionResetTask service to stop executing.
void	stopLeakedPushStatusCleanUpService()	Cause LeakedPushStatusCleanUpService 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)

Method Details

refresh

public void refresh()

Specified by:

refresh in interface VeniceResource

clear

public void clear()

Specified by:

clear in interface VeniceResource

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.

stopLeakedPushStatusCleanUpService

public void stopLeakedPushStatusCleanUpService()

Cause LeakedPushStatusCleanUpService 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()

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.