Package | Description |
---|---|
org.apache.zookeeper.server |
ZooKeeper server theory of operation
ZooKeeperServer is designed to work in standalone mode and also
be extensible so that it can be used to implement the quorum based
version of ZooKeeper.
|
org.apache.zookeeper.server.command | |
org.apache.zookeeper.server.quorum |
Modifier and Type | Class and Description |
---|---|
class |
NettyServerCnxnFactory |
class |
NIOServerCnxnFactory
NIOServerCnxnFactory implements a multi-threaded ServerCnxnFactory using
NIO non-blocking socket calls.
|
Modifier and Type | Field and Description |
---|---|
protected ServerCnxnFactory |
ZooKeeperServer.secureServerCnxnFactory |
protected ServerCnxnFactory |
ZooKeeperServer.serverCnxnFactory |
Modifier and Type | Method and Description |
---|---|
static ServerCnxnFactory |
ServerCnxnFactory.createFactory() |
static ServerCnxnFactory |
ServerCnxnFactory.createFactory(InetSocketAddress addr,
int maxClientCnxns) |
static ServerCnxnFactory |
ServerCnxnFactory.createFactory(InetSocketAddress addr,
int maxClientCnxns,
int backlog) |
static ServerCnxnFactory |
ServerCnxnFactory.createFactory(int clientPort,
int maxClientCnxns) |
static ServerCnxnFactory |
ServerCnxnFactory.createFactory(int clientPort,
int maxClientCnxns,
int backlog) |
ServerCnxnFactory |
ZooKeeperServer.getSecureServerCnxnFactory() |
ServerCnxnFactory |
ZooKeeperServer.getServerCnxnFactory() |
Modifier and Type | Method and Description |
---|---|
static int |
ServerCnxnHelper.getMaxCnxns(ServerCnxnFactory secureServerCnxnFactory,
ServerCnxnFactory serverCnxnFactory)
gets maximum number of connections in ZooKeeper
|
void |
ZooKeeperServer.setSecureServerCnxnFactory(ServerCnxnFactory factory) |
void |
ZooKeeperServer.setServerCnxnFactory(ServerCnxnFactory factory) |
Modifier and Type | Field and Description |
---|---|
protected ServerCnxnFactory |
AbstractFourLetterCommand.factory |
Modifier and Type | Method and Description |
---|---|
boolean |
CommandExecutor.execute(ServerCnxn serverCnxn,
PrintWriter pwriter,
int commandCode,
ZooKeeperServer zkServer,
ServerCnxnFactory factory)
This class decides which command to be executed and then executes
|
void |
AbstractFourLetterCommand.setFactory(ServerCnxnFactory factory) |
Modifier and Type | Method and Description |
---|---|
void |
QuorumPeer.setCnxnFactory(ServerCnxnFactory cnxnFactory) |
void |
QuorumPeer.setSecureCnxnFactory(ServerCnxnFactory secureCnxnFactory) |
Constructor and Description |
---|
QuorumPeer(Map<Long,QuorumPeer.QuorumServer> quorumPeers,
File dataDir,
File dataLogDir,
int electionType,
long myid,
int tickTime,
int initLimit,
int syncLimit,
int connectToLearnerMasterLimit,
boolean quorumListenOnAllIPs,
ServerCnxnFactory cnxnFactory,
QuorumVerifier quorumConfig) |
QuorumPeer(Map<Long,QuorumPeer.QuorumServer> quorumPeers,
File dataDir,
File dataLogDir,
int electionType,
long myid,
int tickTime,
int initLimit,
int syncLimit,
int connectToLearnerMasterLimit,
ServerCnxnFactory cnxnFactory)
For backward compatibility purposes, we instantiate QuorumMaj by default.
|
Copyright © 2008–2020 The Apache Software Foundation. All rights reserved.