@InterfaceAudience.LimitedPrivate(value="HDFS") public abstract class ZKFailoverController extends Object
Modifier and Type | Field and Description |
---|---|
protected Configuration |
conf |
protected HAServiceTarget |
localTarget |
protected ZKFCRpcServer |
rpcServer |
protected static String |
USAGE |
static String |
ZK_ACL_KEY |
static String |
ZK_AUTH_KEY |
static String |
ZK_QUORUM_KEY |
protected static String[] |
ZKFC_CONF_KEYS
All of the conf keys used by the ZKFC.
|
Modifier | Constructor and Description |
---|---|
protected |
ZKFailoverController(Configuration conf,
HAServiceTarget localTarget) |
Modifier and Type | Method and Description |
---|---|
protected abstract void |
checkRpcAdminAccess() |
protected abstract HAServiceTarget |
dataToTarget(byte[] data) |
HAServiceTarget |
getLocalTarget() |
protected abstract PolicyProvider |
getPolicyProvider() |
protected abstract InetSocketAddress |
getRpcAddressToBindTo() |
protected abstract String |
getScopeInsideParentNode()
Return the name of a znode inside the configured parent znode in which
the ZKFC will do all of its work.
|
protected void |
initRPC() |
protected abstract void |
loginAsFCUser() |
int |
run(String[] args) |
protected void |
startRPC() |
protected abstract byte[] |
targetToData(HAServiceTarget target) |
public static final String ZK_QUORUM_KEY
public static final String ZK_ACL_KEY
public static final String ZK_AUTH_KEY
protected static final String[] ZKFC_CONF_KEYS
protected static final String USAGE
protected Configuration conf
protected final HAServiceTarget localTarget
protected ZKFCRpcServer rpcServer
protected ZKFailoverController(Configuration conf, HAServiceTarget localTarget)
protected abstract byte[] targetToData(HAServiceTarget target)
protected abstract HAServiceTarget dataToTarget(byte[] data)
protected abstract void loginAsFCUser() throws IOException
IOException
protected abstract void checkRpcAdminAccess() throws AccessControlException, IOException
AccessControlException
IOException
protected abstract InetSocketAddress getRpcAddressToBindTo()
protected abstract PolicyProvider getPolicyProvider()
protected abstract String getScopeInsideParentNode()
public HAServiceTarget getLocalTarget()
protected void initRPC() throws IOException
IOException
protected void startRPC() throws IOException
IOException
Copyright © 2013 Apache Software Foundation. All rights reserved.