Package com.linkedin.venice.controller

Class ZkHelixAdminClient

java.lang.Object

com.linkedin.venice.controller.ZkHelixAdminClient

All Implemented Interfaces:

HelixAdminClient

public class ZkHelixAdminClient
extends java.lang.Object
implements HelixAdminClient

The purpose of this class is to abstract Helix operations out of the VeniceHelixAdmin and eventually rename it to VeniceAdmin. This is one implementation of the HelixAdminClient interface which uses Zk based Helix API. In the future we might move to the Helix REST API.

Constructor Summary

Constructors

Constructor	Description
ZkHelixAdminClient(VeniceControllerMultiClusterConfig multiClusterConfigs, io.tehuti.metrics.MetricsRepository metricsRepository)

Method Summary

Modifier and Type	Method	Description
void	addClusterToGrandCluster(java.lang.String clusterName)	Add the specified cluster as a resource to the grand cluster to be managed by HaaS controllers.
void	addVeniceStorageClusterToControllerCluster(java.lang.String clusterName)	Add the given Venice storage cluster's cluster resource to the controller cluster.
void	close()	Release resources.
boolean	containsResource(java.lang.String clusterName, java.lang.String resourceName)	Check if a resource exists in a cluster by checking its ideal state.
void	createVeniceControllerCluster(boolean isControllerInAzureFabric)	Create and configure the Venice controller cluster.
void	createVeniceStorageCluster(java.lang.String clusterName, java.util.Map<java.lang.String,java.lang.String> helixClusterProperties, boolean isControllerInAzureFabric)	Create and configure the Venice storage cluster.
void	createVeniceStorageClusterResources(java.lang.String clusterName, java.lang.String kafkaTopic, int numberOfPartition, int replicationFactor)	Create resources for a given storage node cluster.
void	dropResource(java.lang.String clusterName, java.lang.String resourceName)	Drop a resource from a cluster.
void	dropStorageInstance(java.lang.String clusterName, java.lang.String instanceName)	Drop a storage node instance from the given cluster.
void	enablePartition(boolean enabled, java.lang.String clusterName, java.lang.String instanceName, java.lang.String resourceName, java.util.List<java.lang.String> partitionNames)	Disable or enable a list of partitions on an instance.
java.util.Map<java.lang.String,java.util.List<java.lang.String>>	getDisabledPartitionsMap(java.lang.String clusterName, java.lang.String instanceName)	Returns a list of disabled partitions in an instance.
java.util.List<java.lang.String>	getInstancesInCluster(java.lang.String clusterName)	Get a list of instances under a cluster.
boolean	isClusterInGrandCluster(java.lang.String clusterName)	Check if the grand cluster managed by HaaS controllers is aware of the given cluster.
boolean	isVeniceControllerClusterCreated()	Check if the Venice controller cluster is created and configured.
boolean	isVeniceStorageClusterCreated(java.lang.String clusterName)	Check if the given Venice storage cluster is created and configured.
boolean	isVeniceStorageClusterInControllerCluster(java.lang.String clusterName)	Check if the given Venice storage cluster's cluster resource is in the Venice controller cluster.
void	resetPartition(java.lang.String clusterName, java.lang.String instanceName, java.lang.String resourceName, java.util.List<java.lang.String> partitionNames)	Reset a list of partitions in error state for an instance.
void	updateClusterConfigs(java.lang.String clusterName, java.util.Map<java.lang.String,java.lang.String> helixClusterProperties)	Update some Helix cluster properties for the given cluster.

Methods inherited from class java.lang.Object

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

Constructor Detail

ZkHelixAdminClient

public ZkHelixAdminClient(VeniceControllerMultiClusterConfig multiClusterConfigs,
                          io.tehuti.metrics.MetricsRepository metricsRepository)

Method Detail

isVeniceControllerClusterCreated

public boolean isVeniceControllerClusterCreated()

Description copied from interface: HelixAdminClient

Check if the Venice controller cluster is created and configured.

Specified by:

isVeniceControllerClusterCreated in interface HelixAdminClient

Returns:

true or false.

See Also:

HelixAdminClient.isVeniceControllerClusterCreated()

isVeniceStorageClusterCreated

public boolean isVeniceStorageClusterCreated(java.lang.String clusterName)

Description copied from interface: HelixAdminClient

Check if the given Venice storage cluster is created and configured.

Specified by:

isVeniceStorageClusterCreated in interface HelixAdminClient

Parameters:

clusterName - of the Venice cluster.

Returns:

true or false.

See Also:

HelixAdminClient.isVeniceStorageClusterCreated(String)

createVeniceControllerCluster

public void createVeniceControllerCluster(boolean isControllerInAzureFabric)

Description copied from interface: HelixAdminClient

Create and configure the Venice controller cluster.

Specified by:

createVeniceControllerCluster in interface HelixAdminClient

Parameters:

isControllerInAzureFabric - whether the controller is in Azure fabric.

See Also:

HelixAdminClient.createVeniceControllerCluster(boolean)

createVeniceStorageCluster

public void createVeniceStorageCluster(java.lang.String clusterName,
                                       java.util.Map<java.lang.String,java.lang.String> helixClusterProperties,
                                       boolean isControllerInAzureFabric)

Description copied from interface: HelixAdminClient

Create and configure the Venice storage cluster.

Specified by:

createVeniceStorageCluster in interface HelixAdminClient

Parameters:

clusterName - of the Venice storage cluster.

helixClusterProperties - to be applied to the new cluster.

isControllerInAzureFabric - whether the controller is in Azure fabric.

See Also:

HelixAdminClient.createVeniceStorageCluster(String, Map, boolean)

isVeniceStorageClusterInControllerCluster

public boolean isVeniceStorageClusterInControllerCluster(java.lang.String clusterName)

Description copied from interface: HelixAdminClient

Check if the given Venice storage cluster's cluster resource is in the Venice controller cluster.

Specified by:

isVeniceStorageClusterInControllerCluster in interface HelixAdminClient

Parameters:

clusterName - of the Venice storage cluster.

Returns:

true or false.

See Also:

HelixAdminClient.isVeniceStorageClusterInControllerCluster(String)

addVeniceStorageClusterToControllerCluster

public void addVeniceStorageClusterToControllerCluster(java.lang.String clusterName)

Description copied from interface: HelixAdminClient

Add the given Venice storage cluster's cluster resource to the controller cluster.

Specified by:

addVeniceStorageClusterToControllerCluster in interface HelixAdminClient

Parameters:

clusterName - of the Venice storage cluster.

See Also:

HelixAdminClient.addVeniceStorageClusterToControllerCluster(String)

isClusterInGrandCluster

public boolean isClusterInGrandCluster(java.lang.String clusterName)

Description copied from interface: HelixAdminClient

Check if the grand cluster managed by HaaS controllers is aware of the given cluster.

Specified by:

isClusterInGrandCluster in interface HelixAdminClient

Parameters:

clusterName - of the cluster.

Returns:

true or false.

See Also:

HelixAdminClient.isClusterInGrandCluster(String)

addClusterToGrandCluster

public void addClusterToGrandCluster(java.lang.String clusterName)

Description copied from interface: HelixAdminClient

Add the specified cluster as a resource to the grand cluster to be managed by HaaS controllers.

Specified by:

addClusterToGrandCluster in interface HelixAdminClient

Parameters:

clusterName - of the cluster to be added as a resource to the grand cluster.

See Also:

HelixAdminClient.addClusterToGrandCluster(String)

updateClusterConfigs

public void updateClusterConfigs(java.lang.String clusterName,
                                 java.util.Map<java.lang.String,java.lang.String> helixClusterProperties)

Description copied from interface: HelixAdminClient

Update some Helix cluster properties for the given cluster.

Specified by:

updateClusterConfigs in interface HelixAdminClient

Parameters:

clusterName - of the cluster to be updated.

helixClusterProperties - to be applied to the given cluster.

See Also:

HelixAdminClient.updateClusterConfigs(String, Map)

enablePartition

public void enablePartition(boolean enabled,
                            java.lang.String clusterName,
                            java.lang.String instanceName,
                            java.lang.String resourceName,
                            java.util.List<java.lang.String> partitionNames)

Description copied from interface: HelixAdminClient

Disable or enable a list of partitions on an instance.

Specified by:

enablePartition in interface HelixAdminClient

See Also:

HelixAdminClient.enablePartition(boolean, String, String, String, List)

getInstancesInCluster

public java.util.List<java.lang.String> getInstancesInCluster(java.lang.String clusterName)

Description copied from interface: HelixAdminClient

Get a list of instances under a cluster.

Specified by:

getInstancesInCluster in interface HelixAdminClient

Returns:

a list of instance names.

See Also:

HelixAdminClient.getInstancesInCluster(String)

createVeniceStorageClusterResources

public void createVeniceStorageClusterResources(java.lang.String clusterName,
                                                java.lang.String kafkaTopic,
                                                int numberOfPartition,
                                                int replicationFactor)

Description copied from interface: HelixAdminClient

Create resources for a given storage node cluster.

Specified by:

createVeniceStorageClusterResources in interface HelixAdminClient

See Also:

HelixAdminClient.createVeniceStorageClusterResources(String, String, int, int)

containsResource

public boolean containsResource(java.lang.String clusterName,
                                java.lang.String resourceName)

Description copied from interface: HelixAdminClient

Check if a resource exists in a cluster by checking its ideal state.

Specified by:

containsResource in interface HelixAdminClient

dropResource

public void dropResource(java.lang.String clusterName,
                         java.lang.String resourceName)

Description copied from interface: HelixAdminClient

Drop a resource from a cluster.

Specified by:

dropResource in interface HelixAdminClient

See Also:

HelixAdminClient.dropResource(String, String)

dropStorageInstance

public void dropStorageInstance(java.lang.String clusterName,
                                java.lang.String instanceName)

Description copied from interface: HelixAdminClient

Drop a storage node instance from the given cluster.

Specified by:

dropStorageInstance in interface HelixAdminClient

See Also:

HelixAdminClient.dropStorageInstance(String, String)

getDisabledPartitionsMap

public java.util.Map<java.lang.String,java.util.List<java.lang.String>> getDisabledPartitionsMap(java.lang.String clusterName,
                                                                                                       java.lang.String instanceName)

Description copied from interface: HelixAdminClient

Returns a list of disabled partitions in an instance.

Specified by:

getDisabledPartitionsMap in interface HelixAdminClient

resetPartition

public void resetPartition(java.lang.String clusterName,
                           java.lang.String instanceName,
                           java.lang.String resourceName,
                           java.util.List<java.lang.String> partitionNames)

Description copied from interface: HelixAdminClient

Reset a list of partitions in error state for an instance.

The partitions are assumed to be in error state and reset will bring them from error to initial state. An error to initial state transition is required for reset.

Specified by:

resetPartition in interface HelixAdminClient

See Also:

HelixAdminClient.resetPartition(String, String, String, List)

close

public void close()

Description copied from interface: HelixAdminClient

Release resources.

Specified by:

close in interface HelixAdminClient

See Also:

HelixAdminClient.close()