QuorumPeerConfig (Apache ZooKeeper

java.lang.Object
- org.apache.zookeeper.server.quorum.QuorumPeerConfig

@InterfaceAudience.Public
public class QuorumPeerConfig
extends Object

Nested Class Summary

Nested Classes
Modifier and Type Class and Description

static class QuorumPeerConfig.ConfigException

Nested Classes
Modifier and Type	Class and Description
`static class`	`QuorumPeerConfig.ConfigException`

Field Summary

Fields
Modifier and Type	Field and Description
`protected InetSocketAddress`	`clientPortAddress`
`protected String`	`configFileStr`
`protected File`	`dataDir`
`protected File`	`dataLogDir`
`protected String`	`dynamicConfigFileStr`
`protected int`	`electionAlg`
`protected int`	`electionPort`
`protected int`	`initLimit`
`protected QuorumVerifier`	`lastSeenQuorumVerifier`
`protected boolean`	`localSessionsEnabled`
`protected boolean`	`localSessionsUpgradingEnabled`
`protected int`	`maxClientCnxns`
`protected int`	`maxSessionTimeout` defaults to -1 if not set explicitly
`protected int`	`minSessionTimeout` defaults to -1 if not set explicitly
`static String`	`nextDynamicConfigFileSuffix`
`protected QuorumPeer.LearnerType`	`peerType`
`protected int`	`purgeInterval`
`protected int`	`quorumCnxnThreadsSize`
`protected boolean`	`quorumEnableSasl`
`protected String`	`quorumLearnerLoginContext`
`protected boolean`	`quorumLearnerRequireSasl`
`protected boolean`	`quorumListenOnAllIPs`
`protected String`	`quorumServerLoginContext`
`protected boolean`	`quorumServerRequireSasl` Configurations for the quorumpeer-to-quorumpeer sasl authentication
`protected String`	`quorumServicePrincipal`
`protected QuorumVerifier`	`quorumVerifier`
`protected InetSocketAddress`	`secureClientPortAddress`
`protected long`	`serverId`
`protected boolean`	`shouldUsePortUnification`
`protected int`	`snapRetainCount`
`protected boolean`	`sslQuorum`
`protected boolean`	`sslQuorumReloadCertFiles`
`protected boolean`	`syncEnabled`
`protected int`	`syncLimit`
`protected int`	`tickTime`

Constructor Summary

Constructors
Constructor and Description

QuorumPeerConfig()

Constructors
Constructor and Description
`QuorumPeerConfig()`

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`boolean`	`areLocalSessionsEnabled()`
`void`	`checkValidity()`
`static void`	`configureSSLAuth()` Configure SSL authentication only if it is not configured.
`static void`	`deleteFile(String filename)`
`static void`	`editStaticConfig(String configFileStr, String dynamicFileStr, boolean eraseClientPortAddress)` Edit static config file.
`InetSocketAddress`	`getClientPortAddress()`
`String`	`getConfigFilename()`
`File`	`getDataDir()`
`File`	`getDataLogDir()`
`int`	`getElectionAlg()`
`int`	`getElectionPort()`
`int`	`getInitLimit()`
`QuorumVerifier`	`getLastSeenQuorumVerifier()`
`int`	`getMaxClientCnxns()`
`int`	`getMaxSessionTimeout()`
`int`	`getMinSessionTimeout()`
`QuorumPeer.LearnerType`	`getPeerType()`
`int`	`getPurgeInterval()`
`Boolean`	`getQuorumListenOnAllIPs()`
`QuorumVerifier`	`getQuorumVerifier()`
`InetSocketAddress`	`getSecureClientPortAddress()`
`long`	`getServerId()`
`Map<Long,QuorumPeer.QuorumServer>`	`getServers()`
`int`	`getSnapRetainCount()`
`boolean`	`getSyncEnabled()`
`int`	`getSyncLimit()`
`int`	`getTickTime()`
`static String`	`getVersionFromFilename(String filename)`
`boolean`	`isDistributed()`
`boolean`	`isLocalSessionsUpgradingEnabled()`
`static boolean`	`isReconfigEnabled()`
`boolean`	`isSslQuorum()`
`static boolean`	`isStandaloneEnabled()`
`void`	`parse(String path)` Parse a ZooKeeper configuration file
`static QuorumVerifier`	`parseDynamicConfig(Properties dynamicConfigProp, int eAlg, boolean warnings, boolean configBackwardCompatibilityMode)` Parse dynamic configuration file and return quorumVerifier for new configuration.
`void`	`parseProperties(Properties zkProp)` Parse config from a Properties.
`static void`	`setReconfigEnabled(boolean enabled)`
`static void`	`setStandaloneEnabled(boolean enabled)`
`boolean`	`shouldUsePortUnification()`
`static void`	`writeDynamicConfig(String dynamicConfigFilename, QuorumVerifier qv, boolean needKeepVersion)` Writes dynamic configuration file

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

nextDynamicConfigFileSuffix

public static final String nextDynamicConfigFileSuffix

See Also:: Constant Field Values

clientPortAddress

protected InetSocketAddress clientPortAddress

secureClientPortAddress

protected InetSocketAddress secureClientPortAddress

sslQuorum
```
protected boolean sslQuorum
```

shouldUsePortUnification

protected boolean shouldUsePortUnification

sslQuorumReloadCertFiles

protected boolean sslQuorumReloadCertFiles

dataDir
```
protected File dataDir
```

dataLogDir
```
protected File dataLogDir
```

dynamicConfigFileStr
```
protected String dynamicConfigFileStr
```

configFileStr
```
protected String configFileStr
```

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

localSessionsEnabled
```
protected boolean localSessionsEnabled
```

localSessionsUpgradingEnabled

protected boolean localSessionsUpgradingEnabled

initLimit
```
protected int initLimit
```

syncLimit
```
protected int syncLimit
```

electionAlg
```
protected int electionAlg
```

electionPort
```
protected int electionPort
```

quorumListenOnAllIPs
```
protected boolean quorumListenOnAllIPs
```

serverId
```
protected long serverId
```

quorumVerifier

protected QuorumVerifier quorumVerifier

lastSeenQuorumVerifier

protected QuorumVerifier lastSeenQuorumVerifier

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 String quorumServicePrincipal

quorumLearnerLoginContext

protected String quorumLearnerLoginContext

quorumServerLoginContext

protected String quorumServerLoginContext

quorumCnxnThreadsSize
```
protected int quorumCnxnThreadsSize
```

Constructor Detail
- QuorumPeerConfig
```
public QuorumPeerConfig()
```

Method Detail

parse
```
public void parse(String path)
           throws QuorumPeerConfig.ConfigException
```
Parse a ZooKeeper configuration file

Parameters:

path - the patch of the configuration file

Throws:

QuorumPeerConfig.ConfigException - error processing configuration

getVersionFromFilename

public static String getVersionFromFilename(String filename)

parseProperties

public void parseProperties(Properties zkProp)
                     throws IOException,
                            QuorumPeerConfig.ConfigException

Parse config from a Properties.

Parameters:: zkProp - Properties to parse from.
Throws:: IOException; QuorumPeerConfig.ConfigException

configureSSLAuth
```
public static void configureSSLAuth()
                             throws QuorumPeerConfig.ConfigException
```
Configure SSL authentication only if it is not configured.

Throws:

QuorumPeerConfig.ConfigException - If authentication scheme is configured but authentication provider is not configured.

writeDynamicConfig

public static void writeDynamicConfig(String dynamicConfigFilename,
                                      QuorumVerifier qv,
                                      boolean needKeepVersion)
                               throws IOException

Writes dynamic configuration file

Throws:: IOException

editStaticConfig
```
public static void editStaticConfig(String configFileStr,
                                    String dynamicFileStr,
                                    boolean eraseClientPortAddress)
                             throws IOException
```
Edit static config file. If there are quorum information in static file, e.g. "server.X", "group", it will remove them. If it needs to erase client port information left by the old config, "eraseClientPortAddress" should be set true. It should also updates dynamic file pointer on reconfig.

Throws:

IOException

deleteFile

public static void deleteFile(String filename)

parseDynamicConfig

public static QuorumVerifier parseDynamicConfig(Properties dynamicConfigProp,
                                                int eAlg,
                                                boolean warnings,
                                                boolean configBackwardCompatibilityMode)
                                         throws IOException,
                                                QuorumPeerConfig.ConfigException

Parse dynamic configuration file and return quorumVerifier for new configuration.

Parameters:: dynamicConfigProp - Properties to parse from.
Throws:: IOException; QuorumPeerConfig.ConfigException

checkValidity

public void checkValidity()
                   throws IOException,
                          QuorumPeerConfig.ConfigException

Throws:: IOException; QuorumPeerConfig.ConfigException

getClientPortAddress

public InetSocketAddress getClientPortAddress()

getSecureClientPortAddress

public InetSocketAddress getSecureClientPortAddress()

getDataDir
```
public File getDataDir()
```

getDataLogDir
```
public File getDataLogDir()
```

getTickTime
```
public int getTickTime()
```

getMaxClientCnxns
```
public int getMaxClientCnxns()
```

getMinSessionTimeout
```
public int getMinSessionTimeout()
```

getMaxSessionTimeout
```
public int getMaxSessionTimeout()
```

areLocalSessionsEnabled

public boolean areLocalSessionsEnabled()

isLocalSessionsUpgradingEnabled

public boolean isLocalSessionsUpgradingEnabled()

isSslQuorum
```
public boolean isSslQuorum()
```

shouldUsePortUnification

public boolean shouldUsePortUnification()

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()

getLastSeenQuorumVerifier

public QuorumVerifier getLastSeenQuorumVerifier()

getServers

public Map<Long,QuorumPeer.QuorumServer> getServers()

getServerId
```
public long getServerId()
```

isDistributed
```
public boolean isDistributed()
```

getPeerType

public QuorumPeer.LearnerType getPeerType()

getConfigFilename
```
public String getConfigFilename()
```

getQuorumListenOnAllIPs

public Boolean getQuorumListenOnAllIPs()

isStandaloneEnabled

public static boolean isStandaloneEnabled()

setStandaloneEnabled

public static void setStandaloneEnabled(boolean enabled)

isReconfigEnabled

public static boolean isReconfigEnabled()

setReconfigEnabled

public static void setReconfigEnabled(boolean enabled)

Class QuorumPeerConfig

Nested Class Summary

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

nextDynamicConfigFileSuffix

clientPortAddress

secureClientPortAddress

sslQuorum

shouldUsePortUnification

sslQuorumReloadCertFiles

dataDir

dataLogDir

dynamicConfigFileStr

configFileStr

tickTime

maxClientCnxns

minSessionTimeout

maxSessionTimeout

localSessionsEnabled

localSessionsUpgradingEnabled

initLimit

syncLimit

electionAlg

electionPort

quorumListenOnAllIPs

serverId

quorumVerifier

lastSeenQuorumVerifier

snapRetainCount

purgeInterval

syncEnabled

peerType

quorumServerRequireSasl

quorumLearnerRequireSasl

quorumEnableSasl

quorumServicePrincipal

quorumLearnerLoginContext

quorumServerLoginContext

quorumCnxnThreadsSize

Constructor Detail

QuorumPeerConfig

Method Detail

parse

getVersionFromFilename

parseProperties

configureSSLAuth

writeDynamicConfig

editStaticConfig

deleteFile

parseDynamicConfig

checkValidity

getClientPortAddress

getSecureClientPortAddress

getDataDir

getDataLogDir

getTickTime

getMaxClientCnxns

getMinSessionTimeout

getMaxSessionTimeout

areLocalSessionsEnabled

isLocalSessionsUpgradingEnabled

isSslQuorum

shouldUsePortUnification

getInitLimit

getSyncLimit

getElectionAlg

getElectionPort

getSnapRetainCount

getPurgeInterval

getSyncEnabled

getQuorumVerifier

getLastSeenQuorumVerifier

getServers

getServerId

isDistributed

getPeerType

getConfigFilename