Class QuorumPeerConfig
- java.lang.Object
-
- org.apache.zookeeper.server.quorum.QuorumPeerConfig
-
@Public public class QuorumPeerConfig extends java.lang.Object
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
QuorumPeerConfig.ConfigException
-
Field Summary
Fields Modifier and Type Field Description protected java.net.InetSocketAddress
clientPortAddress
protected java.lang.String
dataDir
protected java.lang.String
dataLogDir
protected int
electionAlg
protected int
electionPort
protected int
initLimit
protected int
maxClientCnxns
protected int
maxSessionTimeout
defaults to -1 if not set explicitlyprotected int
minSessionTimeout
defaults to -1 if not set explicitlyprotected int
numGroups
protected java.util.HashMap<java.lang.Long,QuorumPeer.QuorumServer>
observers
protected QuorumPeer.LearnerType
peerType
protected int
purgeInterval
protected int
quorumCnxnThreadsSize
protected boolean
quorumEnableSasl
protected java.lang.String
quorumLearnerLoginContext
protected boolean
quorumLearnerRequireSasl
protected boolean
quorumListenOnAllIPs
protected java.lang.String
quorumServerLoginContext
protected boolean
quorumServerRequireSasl
Configurations for the quorumpeer-to-quorumpeer sasl authenticationprotected java.lang.String
quorumServicePrincipal
protected QuorumVerifier
quorumVerifier
protected java.util.HashMap<java.lang.Long,java.lang.Long>
serverGroup
protected long
serverId
protected java.util.HashMap<java.lang.Long,QuorumPeer.QuorumServer>
servers
protected java.util.HashMap<java.lang.Long,java.lang.Long>
serverWeight
protected int
snapRetainCount
protected boolean
syncEnabled
protected int
syncLimit
protected int
tickTime
-
Constructor Summary
Constructors Constructor Description QuorumPeerConfig()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.net.InetSocketAddress
getClientPortAddress()
java.lang.String
getDataDir()
java.lang.String
getDataLogDir()
int
getElectionAlg()
int
getElectionPort()
int
getInitLimit()
int
getMaxClientCnxns()
int
getMaxSessionTimeout()
int
getMinSessionTimeout()
QuorumPeer.LearnerType
getPeerType()
int
getPurgeInterval()
java.lang.Boolean
getQuorumListenOnAllIPs()
QuorumVerifier
getQuorumVerifier()
long
getServerId()
java.util.Map<java.lang.Long,QuorumPeer.QuorumServer>
getServers()
int
getSnapRetainCount()
boolean
getSyncEnabled()
int
getSyncLimit()
int
getTickTime()
boolean
isDistributed()
void
parse(java.lang.String path)
Parse a ZooKeeper configuration filevoid
parseProperties(java.util.Properties zkProp)
Parse config from a Properties.
-
-
-
Field Detail
-
clientPortAddress
protected java.net.InetSocketAddress clientPortAddress
-
dataDir
protected java.lang.String dataDir
-
dataLogDir
protected java.lang.String dataLogDir
-
tickTime
protected int tickTime
-
maxClientCnxns
protected int maxClientCnxns
-
minSessionTimeout
protected int minSessionTimeout
defaults to -1 if not set explicitly
-
maxSessionTimeout
protected int maxSessionTimeout
defaults to -1 if not set explicitly
-
initLimit
protected int initLimit
-
syncLimit
protected int syncLimit
-
electionAlg
protected int electionAlg
-
electionPort
protected int electionPort
-
quorumListenOnAllIPs
protected boolean quorumListenOnAllIPs
-
servers
protected final java.util.HashMap<java.lang.Long,QuorumPeer.QuorumServer> servers
-
observers
protected final java.util.HashMap<java.lang.Long,QuorumPeer.QuorumServer> observers
-
serverId
protected long serverId
-
serverWeight
protected java.util.HashMap<java.lang.Long,java.lang.Long> serverWeight
-
serverGroup
protected java.util.HashMap<java.lang.Long,java.lang.Long> serverGroup
-
numGroups
protected int numGroups
-
quorumVerifier
protected QuorumVerifier quorumVerifier
-
snapRetainCount
protected int snapRetainCount
-
purgeInterval
protected int purgeInterval
-
syncEnabled
protected boolean syncEnabled
-
peerType
protected QuorumPeer.LearnerType peerType
-
quorumServerRequireSasl
protected boolean quorumServerRequireSasl
Configurations for the quorumpeer-to-quorumpeer sasl authentication
-
quorumLearnerRequireSasl
protected boolean quorumLearnerRequireSasl
-
quorumEnableSasl
protected boolean quorumEnableSasl
-
quorumServicePrincipal
protected java.lang.String quorumServicePrincipal
-
quorumLearnerLoginContext
protected java.lang.String quorumLearnerLoginContext
-
quorumServerLoginContext
protected java.lang.String quorumServerLoginContext
-
quorumCnxnThreadsSize
protected int quorumCnxnThreadsSize
-
-
Method Detail
-
parse
public void parse(java.lang.String path) throws QuorumPeerConfig.ConfigException
Parse a ZooKeeper configuration file- Parameters:
path
- the patch of the configuration file- Throws:
QuorumPeerConfig.ConfigException
- error processing configuration
-
parseProperties
public void parseProperties(java.util.Properties zkProp) throws java.io.IOException, QuorumPeerConfig.ConfigException
Parse config from a Properties.- Parameters:
zkProp
- Properties to parse from.- Throws:
java.io.IOException
QuorumPeerConfig.ConfigException
-
getClientPortAddress
public java.net.InetSocketAddress getClientPortAddress()
-
getDataDir
public java.lang.String getDataDir()
-
getDataLogDir
public java.lang.String getDataLogDir()
-
getTickTime
public int getTickTime()
-
getMaxClientCnxns
public int getMaxClientCnxns()
-
getMinSessionTimeout
public int getMinSessionTimeout()
-
getMaxSessionTimeout
public int getMaxSessionTimeout()
-
getInitLimit
public int getInitLimit()
-
getSyncLimit
public int getSyncLimit()
-
getElectionAlg
public int getElectionAlg()
-
getElectionPort
public int getElectionPort()
-
getSnapRetainCount
public int getSnapRetainCount()
-
getPurgeInterval
public int getPurgeInterval()
-
getSyncEnabled
public boolean getSyncEnabled()
-
getQuorumVerifier
public QuorumVerifier getQuorumVerifier()
-
getServers
public java.util.Map<java.lang.Long,QuorumPeer.QuorumServer> getServers()
-
getServerId
public long getServerId()
-
isDistributed
public boolean isDistributed()
-
getPeerType
public QuorumPeer.LearnerType getPeerType()
-
getQuorumListenOnAllIPs
public java.lang.Boolean getQuorumListenOnAllIPs()
-
-