Package org.apache.zookeeper.server.quorum

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 explicitly
protected int	minSessionTimeout	defaults to -1 if not set explicitly
protected 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 authentication
protected 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

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 file
void	parseProperties(java.util.Properties zkProp)	Parse config from a Properties.

Methods inherited from class java.lang.Object

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

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

Constructor Detail

QuorumPeerConfig

public QuorumPeerConfig()

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