Package com.linkedin.venice.controller

Class VeniceDistClusterControllerStateModelFactory

java.lang.Object

org.apache.helix.participant.statemachine.StateModelFactory<VeniceControllerStateModel>

com.linkedin.venice.controller.VeniceDistClusterControllerStateModelFactory

public class VeniceDistClusterControllerStateModelFactory
extends org.apache.helix.participant.statemachine.StateModelFactory<VeniceControllerStateModel>

Factory to create VeniceDistClusterControllerStateModel and provide some utility methods to get state model by given cluster.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.helix.participant.statemachine.StateModelFactory

org.apache.helix.participant.statemachine.StateModelFactory.CustomizedExecutorService

Constructor Summary

Constructors

Constructor

Description

VeniceDistClusterControllerStateModelFactory(org.apache.helix.zookeeper.impl.client.ZkClient zkClient, HelixAdapterSerializer adapterSerializer, VeniceHelixAdmin admin, VeniceControllerMultiClusterConfig clusterConfigs, io.tehuti.metrics.MetricsRepository metricsRepository, ClusterLeaderInitializationRoutine controllerInitialization, RealTimeTopicSwitcher realTimeTopicSwitcher, Optional<DynamicAccessController> accessController, HelixAdminClient helixAdminClient)

Method Summary

Modifier and Type	Method	Description
VeniceControllerStateModel	createNewStateModel(String resourceName, String partitionName)
Collection<VeniceControllerStateModel>	getAllModels()
VeniceControllerStateModel	getModel(String veniceClusterName)

Methods inherited from class org.apache.helix.participant.statemachine.StateModelFactory

createAndAddBatchMessageWrapper, createAndAddStateModel, createAndAddStateModel, createBatchMessageWrapper, createNewStateModel, getBatchMessageWrapper, getExecutorService, getExecutorService, getExecutorService, getPartitionSet, getPartitionSet, getResourceSet, getStateModel, getStateModel, removeStateModel, removeStateModel

Methods inherited from class java.lang.Object

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

Constructor Details

VeniceDistClusterControllerStateModelFactory

public VeniceDistClusterControllerStateModelFactory(org.apache.helix.zookeeper.impl.client.ZkClient zkClient,
 HelixAdapterSerializer adapterSerializer,
 VeniceHelixAdmin admin,
 VeniceControllerMultiClusterConfig clusterConfigs,
 io.tehuti.metrics.MetricsRepository metricsRepository,
 ClusterLeaderInitializationRoutine controllerInitialization,
 RealTimeTopicSwitcher realTimeTopicSwitcher,
 Optional<DynamicAccessController> accessController,
 HelixAdminClient helixAdminClient)

Method Details

createNewStateModel

public VeniceControllerStateModel createNewStateModel(String resourceName,
 String partitionName)

Overrides:

createNewStateModel in class org.apache.helix.participant.statemachine.StateModelFactory<VeniceControllerStateModel>

See Also:

• createNewStateModel

getModel

public VeniceControllerStateModel getModel(String veniceClusterName)

Returns:

VeniceControllerStateModel for the input cluster, or null if the input cluster's model is not created by the factory.

getAllModels

public Collection<VeniceControllerStateModel> getAllModels()

Returns:

all VeniceControllerStateModel created by the factory.