Package com.linkedin.venice.helix

Class HelixInstanceConfigRepository

java.lang.Object

com.linkedin.venice.helix.HelixInstanceConfigRepository

All Implemented Interfaces:

VeniceResource, org.apache.helix.api.listeners.ClusterConfigChangeListener, org.apache.helix.api.listeners.InstanceConfigChangeListener

public class HelixInstanceConfigRepository
extends Object
implements VeniceResource, org.apache.helix.api.listeners.InstanceConfigChangeListener, org.apache.helix.api.listeners.ClusterConfigChangeListener

This repository is used to store the instance config per instance. So far it only stores the fault zone type info, and we could add more if necessary in the future.

Field Summary

Fields

Modifier and Type	Field	Description
static final int	DEFAULT_INSTANCE_GROUP_ID

Constructor Summary

Constructors

Constructor	Description
HelixInstanceConfigRepository(SafeHelixManager manager)

Method Summary

Modifier and Type	Method	Description
void	clear()
int	getGroupCount()
int	getInstanceGroupId(String instanceId)
Map<String,Integer>	getInstanceGroupIdMapping()
void	onClusterConfigChange(org.apache.helix.model.ClusterConfig clusterConfig, org.apache.helix.NotificationContext context)
void	onInstanceConfigChange(List<org.apache.helix.model.InstanceConfig> instanceConfigs, org.apache.helix.NotificationContext context)	This function will assign a unique group id per group.
void	refresh()

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT_INSTANCE_GROUP_ID

public static final int DEFAULT_INSTANCE_GROUP_ID

See Also:

• Constant Field Values

Constructor Details

HelixInstanceConfigRepository

public HelixInstanceConfigRepository(SafeHelixManager manager)

Method Details

refresh

public void refresh()

Specified by:

refresh in interface VeniceResource

clear

public void clear()

Specified by:

clear in interface VeniceResource

getInstanceGroupId

public int getInstanceGroupId(String instanceId)

getInstanceGroupIdMapping

public Map<String,Integer> getInstanceGroupIdMapping()

getGroupCount

public int getGroupCount()

onInstanceConfigChange

public void onInstanceConfigChange(List<org.apache.helix.model.InstanceConfig> instanceConfigs,
 org.apache.helix.NotificationContext context)

This function will assign a unique group id per group. If there is no group defined for some instances, this function will use empty string as the default.

Specified by:

onInstanceConfigChange in interface org.apache.helix.api.listeners.InstanceConfigChangeListener

onClusterConfigChange

public void onClusterConfigChange(org.apache.helix.model.ClusterConfig clusterConfig,
 org.apache.helix.NotificationContext context)

Specified by:

onClusterConfigChange in interface org.apache.helix.api.listeners.ClusterConfigChangeListener