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.

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, java.util.Optional<DynamicAccessController> accessController, HelixAdminClient helixAdminClient)

Method Summary

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

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

createAndAddBatchMessageWrapper, createAndAddStateModel, createAndAddStateModel, createBatchMessageWrapper, createNewStateModel, getBatchMessageWrapper, 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 Detail

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,
                                                    java.util.Optional<DynamicAccessController> accessController,
                                                    HelixAdminClient helixAdminClient)

Method Detail

createNewStateModel

public VeniceControllerStateModel createNewStateModel(java.lang.String resourceName,
                                                      java.lang.String partitionName)

Overrides:

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

See Also:

createNewStateModel

getModel

public VeniceControllerStateModel getModel(java.lang.String veniceClusterName)

Returns:

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

getAllModels

public java.util.Collection<VeniceControllerStateModel> getAllModels()

Returns:

all VeniceControllerStateModel created by the factory.