Package | Description |
---|---|
org.apache.zookeeper.server |
ZooKeeper server theory of operation
|
org.apache.zookeeper.server.command | |
org.apache.zookeeper.server.controller | |
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 | Class and Description |
---|---|
class |
ControllableConnectionFactory
Extension of NIOServerCnxnFactory which can inject changes per controller commands.
|
Modifier and Type | Method and Description |
---|---|
protected ServerCnxnFactory |
ZooKeeperServerController.getCnxnFactory() |
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–2023 The Apache Software Foundation. All rights reserved.