Package com.linkedin.venice.helix

Class ZkAllowlistAccessor

java.lang.Object

com.linkedin.venice.helix.ZkAllowlistAccessor

All Implemented Interfaces:

AllowlistAccessor, Closeable, AutoCloseable

public class ZkAllowlistAccessor
extends Object
implements AllowlistAccessor

Class used to access to the allowlist stored in ZK. As operating allowlist should happen very rarely, all of request will hit ZK directly without cache.

Constructor Summary

Constructors

Constructor	Description
ZkAllowlistAccessor(String zkAddress)
ZkAllowlistAccessor(org.apache.helix.zookeeper.impl.client.ZkClient zkClient, HelixAdapterSerializer adapterSerializer)

Method Summary

Modifier and Type	Method	Description
void	addInstanceToAllowList(String clusterName, String helixNodeId)	Add the given helix nodeId into the allowlist in ZK.
void	close()
Set<String>	getAllowList(String clusterName)	Get all helix nodeIds in the allowlist of the given cluster from ZK.
boolean	isInstanceInAllowlist(String clusterName, String helixNodeId)	Judge whether the given helix nodeId is in the allowlist or not.
void	removeInstanceFromAllowList(String clusterName, String helixNodeId)	Remove the given helix nodeId from the allowlist in ZK.

Methods inherited from class java.lang.Object

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

Constructor Details

ZkAllowlistAccessor

public ZkAllowlistAccessor(org.apache.helix.zookeeper.impl.client.ZkClient zkClient,
 HelixAdapterSerializer adapterSerializer)

ZkAllowlistAccessor

public ZkAllowlistAccessor(String zkAddress)

Method Details

isInstanceInAllowlist

public boolean isInstanceInAllowlist(String clusterName,
 String helixNodeId)

Judge whether the given helix nodeId is in the allowlist or not.

Specified by:

isInstanceInAllowlist in interface AllowlistAccessor

getAllowList

public Set<String> getAllowList(String clusterName)

Get all helix nodeIds in the allowlist of the given cluster from ZK.

Specified by:

getAllowList in interface AllowlistAccessor

addInstanceToAllowList

public void addInstanceToAllowList(String clusterName,
 String helixNodeId)

Add the given helix nodeId into the allowlist in ZK.

Specified by:

addInstanceToAllowList in interface AllowlistAccessor

removeInstanceFromAllowList

public void removeInstanceFromAllowList(String clusterName,
 String helixNodeId)

Remove the given helix nodeId from the allowlist in ZK.

Specified by:

removeInstanceFromAllowList in interface AllowlistAccessor

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable